Class: Concord::Thrift::BoltSchedulerService::Processor

Inherits:
Object
  • Object
show all
Includes:
Thrift::Processor
Defined in:
lib/gen-rb/bolt_scheduler_service.rb

Instance Method Summary collapse

Instance Method Details

#process_deployComputation(seqid, iprot, oprot) ⇒ Object 



98
99
100
101
102
103
104
105
106
107
 
# File 'lib/gen-rb/bolt_scheduler_service.rb', line 98

def process_deployComputation(seqid, iprot, oprot)
  args = read_args(iprot, DeployComputation_args)
  result = DeployComputation_result.new()
  begin
    @handler.deployComputation(args.request)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'deployComputation', seqid)
end

#process_getComputationSlug(seqid, iprot, oprot) ⇒ Object 



109
110
111
112
113
114
115
116
117
118
 
# File 'lib/gen-rb/bolt_scheduler_service.rb', line 109

def process_getComputationSlug(seqid, iprot, oprot)
  args = read_args(iprot, GetComputationSlug_args)
  result = GetComputationSlug_result.new()
  begin
    result.success = @handler.getComputationSlug(args.computationName)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'getComputationSlug', seqid)
end

#process_killTask(seqid, iprot, oprot) ⇒ Object 



142
143
144
145
146
147
148
149
150
151
 
# File 'lib/gen-rb/bolt_scheduler_service.rb', line 142

def process_killTask(seqid, iprot, oprot)
  args = read_args(iprot, KillTask_args)
  result = KillTask_result.new()
  begin
    @handler.killTask(args.taskId)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'killTask', seqid)
end

#process_registerComputation(seqid, iprot, oprot) ⇒ Object 



120
121
122
123
124
125
126
127
128
129
 
# File 'lib/gen-rb/bolt_scheduler_service.rb', line 120

def process_registerComputation(seqid, iprot, oprot)
  args = read_args(iprot, RegisterComputation_args)
  result = RegisterComputation_result.new()
  begin
    result.success = @handler.registerComputation(args.computation)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'registerComputation', seqid)
end

#process_scaleComputation(seqid, iprot, oprot) ⇒ Object 



131
132
133
134
135
136
137
138
139
140
 
# File 'lib/gen-rb/bolt_scheduler_service.rb', line 131

def process_scaleComputation(seqid, iprot, oprot)
  args = read_args(iprot, ScaleComputation_args)
  result = ScaleComputation_result.new()
  begin
    @handler.scaleComputation(args.computationName, args.instances)
  rescue ::Concord::Thrift::BoltError => e
    result.e = e
  end
  write_result(result, oprot, 'scaleComputation', seqid)
end