node

Documentation

Index

• type ElectionState
• type PinkNode
  • func NewPinkNode(cli *etcd.Cli, eventBus *bus.EventBus) (*PinkNode, error)
  • func (n *PinkNode) NotifyState(state int)
  • func (n *PinkNode) Run() error
  • func (n *PinkNode) Stop()
• type State

Types

type ElectionState

type ElectionState int32

elect

const (
	ElectionReadyState ElectionState = iota
	ElectionDoingState
)

type PinkNode

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

func NewPinkNode

func NewPinkNode(cli *etcd.Cli, eventBus *bus.EventBus) (*PinkNode, error)

func (*PinkNode) NotifyState

func (n *PinkNode) NotifyState(state int)

notify state

func (*PinkNode) Run

func (n *PinkNode) Run() error

self register

func (*PinkNode) Stop

func (n *PinkNode) Stop()

type State

type State int32

const (
	Follower State = iota + 1
	Leader
)