Class: FlumeMasterAdminServer::Processor

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

Instance Method Summary collapse

Instance Method Details

#process_getCmdStatus(seqid, iprot, oprot) ⇒ Object 



181
182
183
184
185
186
 
# File 'lib/thrift/flume_master_admin_server.rb', line 181

def process_getCmdStatus(seqid, iprot, oprot)
  args = read_args(iprot, GetCmdStatus_args)
  result = GetCmdStatus_result.new()
  result.success = @handler.getCmdStatus(args.cmdid)
  write_result(result, oprot, 'getCmdStatus', seqid)
end

#process_getConfigs(seqid, iprot, oprot) ⇒ Object 



167
168
169
170
171
172
 
# File 'lib/thrift/flume_master_admin_server.rb', line 167

def process_getConfigs(seqid, iprot, oprot)
  args = read_args(iprot, GetConfigs_args)
  result = GetConfigs_result.new()
  result.success = @handler.getConfigs()
  write_result(result, oprot, 'getConfigs', seqid)
end

#process_getMappings(seqid, iprot, oprot) ⇒ Object 



188
189
190
191
192
193
 
# File 'lib/thrift/flume_master_admin_server.rb', line 188

def process_getMappings(seqid, iprot, oprot)
  args = read_args(iprot, GetMappings_args)
  result = GetMappings_result.new()
  result.success = @handler.getMappings(args.physicalNode)
  write_result(result, oprot, 'getMappings', seqid)
end

#process_getNodeStatuses(seqid, iprot, oprot) ⇒ Object 



160
161
162
163
164
165
 
# File 'lib/thrift/flume_master_admin_server.rb', line 160

def process_getNodeStatuses(seqid, iprot, oprot)
  args = read_args(iprot, GetNodeStatuses_args)
  result = GetNodeStatuses_result.new()
  result.success = @handler.getNodeStatuses()
  write_result(result, oprot, 'getNodeStatuses', seqid)
end

#process_hasCmdId(seqid, iprot, oprot) ⇒ Object 



174
175
176
177
178
179
 
# File 'lib/thrift/flume_master_admin_server.rb', line 174

def process_hasCmdId(seqid, iprot, oprot)
  args = read_args(iprot, HasCmdId_args)
  result = HasCmdId_result.new()
  result.success = @handler.hasCmdId(args.cmdid)
  write_result(result, oprot, 'hasCmdId', seqid)
end

#process_isFailure(seqid, iprot, oprot) ⇒ Object 



153
154
155
156
157
158
 
# File 'lib/thrift/flume_master_admin_server.rb', line 153

def process_isFailure(seqid, iprot, oprot)
  args = read_args(iprot, IsFailure_args)
  result = IsFailure_result.new()
  result.success = @handler.isFailure(args.cmdid)
  write_result(result, oprot, 'isFailure', seqid)
end

#process_isSuccess(seqid, iprot, oprot) ⇒ Object 



146
147
148
149
150
151
 
# File 'lib/thrift/flume_master_admin_server.rb', line 146

def process_isSuccess(seqid, iprot, oprot)
  args = read_args(iprot, IsSuccess_args)
  result = IsSuccess_result.new()
  result.success = @handler.isSuccess(args.cmdid)
  write_result(result, oprot, 'isSuccess', seqid)
end

#process_submit(seqid, iprot, oprot) ⇒ Object 



139
140
141
142
143
144
 
# File 'lib/thrift/flume_master_admin_server.rb', line 139

def process_submit(seqid, iprot, oprot)
  args = read_args(iprot, Submit_args)
  result = Submit_result.new()
  result.success = @handler.submit(args.command)
  write_result(result, oprot, 'submit', seqid)
end