Class: Concord::Thrift::BoltProxyService::Processor

Inherits:
MutableEphemeralStateService::Processor show all
Includes:
Thrift::Processor
Defined in:
lib/gen-rb/bolt_proxy_service.rb

Instance Method Summary collapse

Methods inherited from MutableEphemeralStateService::Processor

#process_getState, #process_setState

Instance Method Details

#process_registerWithScheduler(seqid, iprot, oprot) ⇒ Object 



81
82
83
84
85
 
# File 'lib/gen-rb/bolt_proxy_service.rb', line 81

def process_registerWithScheduler(seqid, iprot, oprot)
  args = read_args(iprot, RegisterWithScheduler_args)
  @handler.registerWithScheduler(args.meta)
  return
end

#process_updateSchedulerAddress(seqid, iprot, oprot) ⇒ Object 



70
71
72
73
74
75
76
77
78
79
 
# File 'lib/gen-rb/bolt_proxy_service.rb', line 70

def process_updateSchedulerAddress(seqid, iprot, oprot)
  args = read_args(iprot, UpdateSchedulerAddress_args)
  result = UpdateSchedulerAddress_result.new()
  begin
    @handler.updateSchedulerAddress(args.e)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'updateSchedulerAddress', seqid)
end

#process_updateTopology(seqid, iprot, oprot) ⇒ Object 



59
60
61
62
63
64
65
66
67
68
 
# File 'lib/gen-rb/bolt_proxy_service.rb', line 59

def process_updateTopology(seqid, iprot, oprot)
  args = read_args(iprot, UpdateTopology_args)
  result = UpdateTopology_result.new()
  begin
    @handler.updateTopology(args.topology)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'updateTopology', seqid)
end