leader

Documentation

Index

• type Leader
  • func New(zkClient *zookeeper.ZookeeperClient) *Leader
  • func (l *Leader) LeaderStart()
  • func (l *Leader) LeaderStop()
  • func (l *Leader) Run() error
  • func (l *Leader) Stop()

Types

type Leader

type Leader struct {
	// contains filtered or unexported fields
}

func New

func New(zkClient *zookeeper.ZookeeperClient) *Leader

func (*Leader) LeaderStart

func (l *Leader) LeaderStart()

LeaderStart runs when leader is elected

func (*Leader) LeaderStop

func (l *Leader) LeaderStop()

LeaderStop runs when leader is stopped

func (*Leader) Run

func (l *Leader) Run() error

func (*Leader) Stop

func (l *Leader) Stop()

Stop gracefully shuts down the node