Class: Isono::Runner::RpcServer::EndpointBuilder
- Inherits:
-
Object
- Object
- Isono::Runner::RpcServer::EndpointBuilder
- Defined in:
- lib/isono/runner/rpc_server.rb
Defined Under Namespace
Modules: BuildMethods
Class Method Summary collapse
Instance Method Summary collapse
-
#initialize(node) ⇒ EndpointBuilder
constructor
A new instance of EndpointBuilder.
- #job_channel ⇒ Object (also: #job)
- #job_context ⇒ Object
- #rpc_channel ⇒ Object (also: #rpc)
- #session_id ⇒ Object
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 |