Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶ added in v0.17.0
Client describes a ETCD configuration client
func NewClient ¶ added in v0.17.0
func NewClient(service common.Service, etcdServers []string, clientTimeout time.Duration) (*Client, error)
NewClient creates a new ETCD client connection to ETCD servers
func (*Client) GetInt64 ¶ added in v0.17.0
GetInt64 returns an int64 value from the configuration key
func (*Client) NewElection ¶ added in v0.22.0
func (client *Client) NewElection(name string) common.MasterElection
NewElection creates a new ETCD master elector
type EmbeddedEtcd ¶
type EmbeddedEtcd struct { Port int // contains filtered or unexported fields }
EmbeddedEtcd provides a single node etcd server.
type MasterElector ¶ added in v0.17.0
type MasterElector struct { common.RWMutex EtcdKeyAPI etcd.KeysAPI Host string // contains filtered or unexported fields }
MasterElector describes an ETCD master elector
func NewMasterElector ¶ added in v0.17.0
func NewMasterElector(etcdClient *Client, key string) *MasterElector
NewMasterElector creates a new ETCD master elector
func (*MasterElector) AddEventListener ¶ added in v0.17.0
func (le *MasterElector) AddEventListener(listener common.MasterElectionListener)
AddEventListener registers a new listener
func (*MasterElector) IsMaster ¶ added in v0.17.0
func (le *MasterElector) IsMaster() bool
IsMaster returns true if the current instance is master
func (*MasterElector) Start ¶ added in v0.17.0
func (le *MasterElector) Start()
Start the master election mechanism
func (*MasterElector) StartAndWait ¶ added in v0.17.0
func (le *MasterElector) StartAndWait()
StartAndWait starts the election mechanism and wait for the first election before returning
func (*MasterElector) Stop ¶ added in v0.17.0
func (le *MasterElector) Stop()
Stop the election mechanism
func (*MasterElector) TTL ¶ added in v0.17.0
func (le *MasterElector) TTL() time.Duration
TTL time to live