election

Documentation

Index

• func GetMsgExpirationTimeout() time.Duration
• func SetLeaderAliveThreshold(t time.Duration)
• func SetLeaderElectionDuration(t time.Duration)
• func SetMembershipSampleInterval(t time.Duration)
• func SetStartupGracePeriod(t time.Duration)
• type LeaderElectionAdapter
  • func NewAdapter(gossip gossip, pkiid common.PKIidType, channel common.ChainID) LeaderElectionAdapter
• type LeaderElectionService
  • func NewLeaderElectionService(adapter LeaderElectionAdapter, id string, callback leadershipCallback) LeaderElectionService
• type Msg
• type Peer

Functions

func GetMsgExpirationTimeout

func GetMsgExpirationTimeout() time.Duration

GetMsgExpirationTimeout return leadership message expiration timeout

func SetLeaderAliveThreshold

func SetLeaderAliveThreshold(t time.Duration)

SetLeaderAliveThreshold configures leader election alive threshold

func SetLeaderElectionDuration

func SetLeaderElectionDuration(t time.Duration)

SetLeaderElectionDuration configures expected leadership election duration, interval to wait until leader election will be completed

func SetMembershipSampleInterval

func SetMembershipSampleInterval(t time.Duration)

SetMembershipSampleInterval setups/initializes the frequency the membership view should be checked

func SetStartupGracePeriod

func SetStartupGracePeriod(t time.Duration)

SetStartupGracePeriod configures startup grace period interval, the period of time to wait until election algorithm will start

Types

type LeaderElectionAdapter

type LeaderElectionAdapter interface {
	// Gossip gossips a message to other peers
	Gossip(Msg)

	// Accept returns a channel that emits messages
	Accept() <-chan Msg

	// CreateProposalMessage
	CreateMessage(isDeclaration bool) Msg

	// Peers returns a list of peers considered alive
	Peers() []Peer
}

LeaderElectionAdapter is used by the leader election module to send and receive messages and to get membership information

func NewAdapter

func NewAdapter(gossip gossip, pkiid common.PKIidType, channel common.ChainID) LeaderElectionAdapter

NewAdapter creates new leader election adapter

type LeaderElectionService

type LeaderElectionService interface {
	// IsLeader returns whether this peer is a leader or not
	IsLeader() bool

	// Stop stops the LeaderElectionService
	Stop()

	// Yield relinquishes the leadership until a new leader is elected,
	// or a timeout expires
	Yield()
}

LeaderElectionService is the object that runs the leader election algorithm

func NewLeaderElectionService

func NewLeaderElectionService(adapter LeaderElectionAdapter, id string, callback leadershipCallback) LeaderElectionService

NewLeaderElectionService returns a new LeaderElectionService

type Msg

type Msg interface {
	// SenderID returns the ID of the peer sent the message
	SenderID() peerID
	// IsProposal returns whether this message is a leadership proposal
	IsProposal() bool
	// IsDeclaration returns whether this message is a leadership declaration
	IsDeclaration() bool
}

Msg describes a message sent from a remote peer

type Peer

type Peer interface {
	// ID returns the ID of the peer
	ID() peerID
}

Peer describes a remote peer