raftleader

Documentation

Index

• func IsRaftLeadershipError(err error) bool
• type LeaderObserver
  • func NewRaftLeaderHealthObserver(logger log.Logger, m *Metrics) *LeaderObserver
  • func (hs *LeaderObserver) Deregister(r *raft.Raft)
  • func (hs *LeaderObserver) Register(r *raft.Raft, cb func(st raft.RaftState))
• type Metrics
  • func NewMetrics(reg prometheus.Registerer) *Metrics

Functions

func IsRaftLeadershipError

func IsRaftLeadershipError(err error) bool

Types

type LeaderObserver

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

func NewRaftLeaderHealthObserver

func NewRaftLeaderHealthObserver(logger log.Logger, m *Metrics) *LeaderObserver

func (*LeaderObserver) Deregister

func (hs *LeaderObserver) Deregister(r *raft.Raft)

func (*LeaderObserver) Register

func (hs *LeaderObserver) Register(r *raft.Raft, cb func(st raft.RaftState))

type Metrics

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

func NewMetrics

func NewMetrics(reg prometheus.Registerer) *Metrics