election

Documentation

Index

• Constants
• type Election
  • func NewElection(config *ElectionConfig) *Election
  • func (o *Election) ChangeNotify() <-chan struct{}
  • func (o *Election) GetEpoch() int
  • func (o *Election) IsLeader() bool
  • func (o *Election) QuitNotify() <-chan struct{}
  • func (o *Election) Start() error
  • func (o *Election) Stop() error
• type ElectionConfig
• type WorkingMode

Constants

const (
	WorkingMode_INIT     WorkingMode = "init"
	WorkingMode_FOLLOWER             = "follower"
	WorkingMode_LEADER               = "leader"
	WorkingMode_UNSAFE               = "unsafe"
)

const (
	StatusKey_WorkMode = "work_mode"
)

Types

type Election

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

func NewElection

func NewElection(config *ElectionConfig) *Election

func (*Election) ChangeNotify

func (o *Election) ChangeNotify() <-chan struct{}

func (*Election) GetEpoch

func (o *Election) GetEpoch() int

func (*Election) IsLeader

func (o *Election) IsLeader() bool

func (*Election) QuitNotify

func (o *Election) QuitNotify() <-chan struct{}

func (*Election) Start

func (o *Election) Start() error

func (*Election) Stop

func (o *Election) Stop() error

type ElectionConfig

type ElectionConfig struct {
	ZkAddrs         []string
	ZkRoot          string
	ElectionTimeout int
}

type WorkingMode

type WorkingMode string