Class Nanite::Cluster
In: lib/nanite/cluster.rb
Parent: Object

Methods

all   enforce_format?   forward_response   handle_ping   handle_request   least_loaded   nanite_timed_out   nanites_providing   new   publish   random   register   route   rr   setup_heartbeat_queue   setup_queues   setup_registration_queue   setup_request_queue   setup_state   shared_state?   targets_for   timed_out?  

Attributes

agent_timeout  [R] 
amq  [R] 
callbacks  [R] 
identity  [R] 
mapper  [R] 
nanites  [R] 
reaper  [R] 
redis  [R] 
serializer  [R] 

Public Class methods

Public Instance methods

register(reg)

adds nanite to nanites map: key is nanite‘s identity and value is a services/status pair implemented as a hash

targets_for(request)

determine which nanites should receive the given request

Protected Instance methods

all(service, tags=[])

returns all nanites that provide given service

forward_response(res, persistent)

forward response back to agent that originally made the request

handle_ping(ping)

updates nanite information (last ping timestamps, status) when heartbeat message is received

handle_request(request)

forward request coming from agent

least_loaded(service, tags=[])

returns least loaded nanite that provides given service

nanites_providing(service, *tags)

returns all nanites that provide the given service

rr(service, tags=[])

selects next nanite that provides given service using round robin rotation

[Validate]