Class: Legion::Extensions::Mesh::Client

Inherits:

Object

• Object
• Legion::Extensions::Mesh::Client

Includes:

Runners::Delegation, Runners::Mesh, Runners::Preferences, Runners::TaskRequest

Defined in:

lib/legion/extensions/mesh/client.rb

Constant Summary

Constants included from Runners::TaskRequest

Runners::TaskRequest::DEFAULT_TIMEOUT

Instance Method Summary

• #initialize(**opts) ⇒ Client constructor

  A new instance of Client.

Methods included from Runners::TaskRequest

#expire_pending_tasks, #handle_task_reply, #pending_task_stats, #request_task

Methods included from Runners::Mesh

#dispatch_gossip_message, #expire_silent_agents, #find_agents, #heartbeat, #merge_gossip, #mesh_status, #publish_gossip, #register, #send_message, #unregister

Methods included from Runners::Delegation

#agent_delegations, #complete_delegation, #delegate, #delegation_chain, #delegation_stats, #revoke_delegation

Methods included from Runners::Preferences

#dispatch_preference_message, #expire_pending_requests, #handle_preference_query, #handle_preference_response, #query_preferences

Constructor Details

#initialize(**opts) ⇒ Client

Returns a new instance of Client.

# File 'lib/legion/extensions/mesh/client.rb', line 21

def initialize(**opts)
  @opts = opts
  @mesh_registry = Helpers::Registry.new # rubocop:disable Legion/Singleton/UseInstance
end