memory

Documentation

Overview

Package memory implements an in-memory variant of the Decider to allow for quick local/single-process testing

Index

• type Decider
  • func NewDecider() *Decider
  • func (d *Decider) ReadCurrent(ctx context.Context) (*entry.RaceEntry, error)
  • func (d *Decider) WriteEntry(ctx context.Context, entry *entry.RaceEntry) (entry.LeaderToken, error)

Types

type Decider

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

Decider implements leaderelection.Decider

func NewDecider

func NewDecider() *Decider

NewDecider returns a new, initialized instance

func (*Decider) ReadCurrent

func (d *Decider) ReadCurrent(ctx context.Context) (*entry.RaceEntry, error)

ReadCurrent should provide the latest version of RaceEntry available and put any additional information needed to ensure transactional behavior in the Token-field.

func (*Decider) WriteEntry

func (d *Decider) WriteEntry(ctx context.Context, entry *entry.RaceEntry) (entry.LeaderToken, error)

WriteEntry accepts writes with the correct incarnation The interface{} return value is a new token if the write succeeded.