Versions in this module Expand all Collapse all v1 v1.0.7 Jun 6, 2022 Changes in this version + func Close() + func EtcdConn() *clientv3.Client + func EtcdOps() clientv3.KV + func Initialize() error + func ZKAddresses() []string + func ZKConn() *zk.Conn + func ZKStatusSignal() <-chan zk.Event + type ElectionStorage interface + Elect func() error + type PositionStorage interface + Get func() (mysql.Position, error) + Initialize func() error + Save func(pos mysql.Position) error + func NewElectionStorage(conf *global.Config) PositionStorage + func NewPositionStorage() PositionStorage
Go to main page