Class: ThriftFlumeClientServer::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/thrift/thrift_flume_client_server.rb

Instance Method Summary collapse

Instance Method Details

#process_acknowledge(seqid, iprot, oprot) ⇒ Object 



150
151
152
153
154
155
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 150

def process_acknowledge(seqid, iprot, oprot)
  args = read_args(iprot, Acknowledge_args)
  result = Acknowledge_result.new()
  @handler.acknowledge(args.ackid)
  write_result(result, oprot, 'acknowledge', seqid)
end

#process_checkAck(seqid, iprot, oprot) ⇒ Object 



157
158
159
160
161
162
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 157

def process_checkAck(seqid, iprot, oprot)
  args = read_args(iprot, CheckAck_args)
  result = CheckAck_result.new()
  result.success = @handler.checkAck(args.ackid)
  write_result(result, oprot, 'checkAck', seqid)
end

#process_getChokeMap(seqid, iprot, oprot) ⇒ Object 



143
144
145
146
147
148
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 143

def process_getChokeMap(seqid, iprot, oprot)
  args = read_args(iprot, GetChokeMap_args)
  result = GetChokeMap_result.new()
  result.success = @handler.getChokeMap(args.physNode)
  write_result(result, oprot, 'getChokeMap', seqid)
end

#process_getConfig(seqid, iprot, oprot) ⇒ Object 



129
130
131
132
133
134
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 129

def process_getConfig(seqid, iprot, oprot)
  args = read_args(iprot, GetConfig_args)
  result = GetConfig_result.new()
  result.success = @handler.getConfig(args.sourceId)
  write_result(result, oprot, 'getConfig', seqid)
end

#process_getLogicalNodes(seqid, iprot, oprot) ⇒ Object 



136
137
138
139
140
141
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 136

def process_getLogicalNodes(seqid, iprot, oprot)
  args = read_args(iprot, GetLogicalNodes_args)
  result = GetLogicalNodes_result.new()
  result.success = @handler.getLogicalNodes(args.physNode)
  write_result(result, oprot, 'getLogicalNodes', seqid)
end

#process_heartbeat(seqid, iprot, oprot) ⇒ Object 



122
123
124
125
126
127
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 122

def process_heartbeat(seqid, iprot, oprot)
  args = read_args(iprot, Heartbeat_args)
  result = Heartbeat_result.new()
  result.success = @handler.heartbeat(args.logicalNode, args.physicalNode, args.host, args.s, args.timestamp)
  write_result(result, oprot, 'heartbeat', seqid)
end

#process_putReports(seqid, iprot, oprot) ⇒ Object 



164
165
166
167
168
169
 
# File 'lib/thrift/thrift_flume_client_server.rb', line 164

def process_putReports(seqid, iprot, oprot)
  args = read_args(iprot, PutReports_args)
  result = PutReports_result.new()
  @handler.putReports(args.reports)
  write_result(result, oprot, 'putReports', seqid)
end