class RedisServiceManager

• RedisServiceManager
• Clustering
• Reference
• Object

Defined in:

Constant Summary

Log = ::Log.for("redis-service-manager")

Constructors

• .new(service : String, redis : String, uri : String = "", ttl : Int32 = 20)
• .new(service : String, redis : Redis::Client, uri : String = "", ttl : Int32 = 20, lock : Mutex = Mutex.new(:reentrant))

Instance Method Summary

• #cluster_ready? : Bool
• #cluster_size
• #finalize
• #generate_version
• #hash_key : String
• #leader? : Bool
• #maintain_registration

  Check if node is registered in the cluster either join cluster or maintain registration

• #node_hash : Hash(String, URI)

  returns a node_id => URI mapping

• #node_info : NodeInfo
• #node_key : String
• #node_keys : Array(String)
• #ready? : Bool
• #register : Bool

  registers this node with the cluster as a member

• #registered? : Bool

  is this node registered as part of the cluster

• #rendezvous : RendezvousHash

  returns the list of known nodes

• #simulate_crash : Nil
• #simulate_split_brain(&recovered) : Nil
• #ulid : String

  the id of the node

• #unregister : Bool

  removes this node from the cluster as a member

• #uri : String

  the service uri for this host

• #watching? : Bool

  is this class watching for changes to the cluster this should return true if registered returns true

Constructor Detail

Instance Method Detail