election

Documentation

Index

• type Database
• type Observer
  • func New(db Database) *Observer
  • func (r *Observer) IsMaster() bool
  • func (r *Observer) Run(ctx context.Context) error

Types

type Database

type Database interface {
	// Elect selects a new master as uid if there is a no existing master that has
	// been updated within expiration. elected will be true if this uid has been
	// elected as the new master or was already elected.
	Elect(uid string, expiration time.Duration) (elected bool, err error)
}

type Observer

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

func New

func New(db Database) *Observer

func (*Observer) IsMaster

func (r *Observer) IsMaster() bool

func (*Observer) Run

func (r *Observer) Run(ctx context.Context) error