Class: Isono::Runner::RpcServer::EndpointBuilder

Inherits:
Object
  • Object
show all
Defined in:
lib/isono/runner/rpc_server.rb

Defined Under Namespace

Modules: BuildMethods

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(node) ⇒ EndpointBuilder

Returns a new instance of EndpointBuilder.



138
139
140
141
142
143
 
# File 'lib/isono/runner/rpc_server.rb', line 138

def initialize(node)
  @node = node
  @rpc_channel = NodeModules::RpcChannel.new(@node)
  @job_channel = NodeModules::JobChannel.new(@node)
  after_initialize
end

Class Method Details

.inherited(klass) ⇒ Object 



129
130
131
132
133
134
135
136
 
# File 'lib/isono/runner/rpc_server.rb', line 129

def self.inherited(klass)
  klass.class_eval {
    @builders = {:job=>[], :rpc=>[]}
    @concurrency = 1
    @job_thread_pool = nil
    extend BuildMethods
  }
end

Instance Method Details

#job_channel ⇒ Object Also known as: job 



145
146
147
 
# File 'lib/isono/runner/rpc_server.rb', line 145

def job_channel
  @job_channel
end

#job_context ⇒ Object 



43
44
45
 
# File 'lib/isono/runner/rpc_server.rb', line 43

def job_context
  Thread.current[Isono::NodeModules::JobWorker::JOB_CTX_KEY]
end

#rpc_channel ⇒ Object Also known as: rpc 



150
151
152
 
# File 'lib/isono/runner/rpc_server.rb', line 150

def rpc_channel
  @rpc_channel
end

#session_id ⇒ Object 



40
41
42
 
# File 'lib/isono/runner/rpc_server.rb', line 40

def session_id
  job_context.session_id
end