mongo_leader

Documentation

Index

• type ElectionResult
• type LeaderDocument
• type LeaderElection
  • func New() *LeaderElection
  • func (l *LeaderElection) AddNotify(fn NotifyFunc)
  • func (l *LeaderElection) Start(mongoDatabase *mongo.Database, collectionName string, key string, ...) error
  • func (l *LeaderElection) Stop()
• type NotifyFunc
• type Role

Types

type ElectionResult

type ElectionResult struct {
	MyRole       Role
	LeaderPeerId string
}

type LeaderDocument

type LeaderDocument struct {
	Id          primitive.ObjectID `bson:"_id,omitempty"`
	Key         string             `bson:"key"`
	PeerId      string             `bson:"peerId"`
	HeartbeatAt time.Time          `bson:"heartbeatAt"`
}

type LeaderElection

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

func New

func New() *LeaderElection

func (*LeaderElection) AddNotify

func (l *LeaderElection) AddNotify(fn NotifyFunc)

func (*LeaderElection) Start

func (l *LeaderElection) Start(mongoDatabase *mongo.Database, collectionName string, key string, peerId string) error

func (*LeaderElection) Stop

func (l *LeaderElection) Stop()

type NotifyFunc

type NotifyFunc func(result ElectionResult)

type Role

type Role string

const (
	RoleLeader   Role = "leader"
	RoleFollower Role = "follower"
)