class

LavinMQ::Etcd

Inherits Reference < Object

Constants

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

Constructors

new(endpoints = "localhost:2379")
Source

Instance methods

del(key) : Int32
Source
elect(name, value, ttl = 10, id = 0) : Lease

Campaign for an election Returns when elected leader Returns a Lease instance

Source
elect_listen(name, &)
Source
election_campaign(name, value, lease = 0_i64) : ElectionLeader

Leader election campaign Returns the leader key and lease when leadership is acquired.

Source
endpoints
Source
get(key) : String | Nil
Source
lease_grant(ttl = 10, id = 0) : Lease

Returns {ID, TTL}

Source
lease_keepalive(id) : Int32
Source
lease_revoke(id) : Nil
Source
lease_ttl(id) : Int32
Source
put(key, value) : String | Nil
Source
put_if_election_leader(key, value, leader : ElectionLeader) : String | Nil
Source
put_or_get(key, value) : String

Sets value if key doesn't exist Return the value that was set or the value that was already stored

Source
read_chunk_size(tcp) : Int32
Source
read_string(tcp, content_length) : String
Source
watch(key, &)
Source

Nested types