mongo

Documentation

Index

• type Elector
  • func NewElector(key interface{}, col string, database *mongo.Database, ...) *Elector
  • func (mgo *Elector) KeepLive(ctx context.Context, keepLive leader.KeepLive) error
  • func (mgo *Elector) PostElection(ctx context.Context, election leader.Election) error
  • func (mgo *Elector) WaitElectionNotify(ctx context.Context) (leader.Election, error)

Types

type Elector

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

func NewElector

func NewElector(key interface{}, col string, database *mongo.Database, docTooLaterDuration time.Duration) *Elector

func (*Elector) KeepLive

func (mgo *Elector) KeepLive(ctx context.Context, keepLive leader.KeepLive) error

func (*Elector) PostElection

func (mgo *Elector) PostElection(ctx context.Context, election leader.Election) error

func (*Elector) WaitElectionNotify

func (mgo *Elector) WaitElectionNotify(ctx context.Context) (leader.Election, error)