class LavinMQ::Etcd

• LavinMQ::Etcd
• Reference
• Object

Defined in:

lavinmq/etcd.cr

Constant Summary

Log = LavinMQ::Log.for("etcd")

Constructors

• .new(endpoints = "localhost:2379")

Instance Method Summary

• #del(key) : Int32
• #elect(name, value, ttl = 10) : Channel(Nil)

  Campaign for an election Returns a Channel when elected leader, when the channel is closed the leadership is lost

• #elect_listen(name, &)
• #election_campaign(name, value, lease = 0_i64) : Int64

  Leader election campaign Returns the lease when the leadership is aquired

• #endpoints : Array(String)
• #get(key) : String | Nil
• #lease_grant(ttl = 10) : Tuple(Int64, Int32)

  Returns {ID, TTL}

• #lease_keepalive(id) : Int32
• #lease_revoke(id) : Nil
• #put(key, value) : String | Nil
• #watch(key, &)

Constructor Detail

Instance Method Detail