zk

Documentation

Index

• type Coordinator
  • func New(c *conf.CoordinatorZK) (*Coordinator, error)
  • func (coord *Coordinator) WaitUntilLeader() context.Context

Types

type Coordinator

type Coordinator struct {
	sync.Mutex
	// contains filtered or unexported fields
}

Coordinator implements leader election systems backed by ZooKeeper.

func New

func New(c *conf.CoordinatorZK) (*Coordinator, error)

New creates new ZooKeeper-backed coordinator.

func (*Coordinator) WaitUntilLeader

func (coord *Coordinator) WaitUntilLeader() context.Context

WaitUntilLeader blocks until this coordinator instance becomes a leader.