Class: Dynflow::Executors::RemoteViaSocket::Core

Inherits:
MicroActor
  • Object
show all
Includes:
Listeners::Serialization
Defined in:
lib/dynflow/executors/remote_via_socket/core.rb

Defined Under Namespace

Modules: TrackedJob

Constant Summary collapse

Message = 
Algebrick.type do
  Job = Algebrick.type do
    variants Event     = Executors::Abstract::Event,
             Execution = Executors::Abstract::Execution
  end

  variants Closed   = atom,
           Received = type { fields message: Protocol::Response },
           Connect  = atom,
           Job
end

Constants inherited from MicroActor

MicroActor::Terminate

Instance Attribute Summary

Attributes inherited from MicroActor

#initialized, #logger

Instance Method Summary collapse

Methods included from Listeners::Serialization

#dump, #load, #receive_message, #send_message

Methods inherited from MicroActor

#<<, #ask, #stopped?

Constructor Details

#initialize(world, socket_path) ⇒ Core

Returns a new instance of Core.



58
59
60
 
# File 'lib/dynflow/executors/remote_via_socket/core.rb', line 58

def initialize(world, socket_path)
  super(world.logger, world, socket_path)
end