fake

Documentation

Index

• Constants
• type Drainer
  • func (d *Drainer) Assert(t *testing.T, inProgressIDs string, doneIDs string)
  • func (d *Drainer) Drain(id string) (int, error)
• type Request
  • func NewRequest(id string, fp bool) Request
  • func (r Request) Clean() error
  • func (r Request) Heartbeat() error
  • func (r Request) InstanceID() string
  • func (r Request) UseFastpath() bool

Constants

const (
	DrainStateInProgress = "in-progress"
	DrainStateDone       = "done"
)

Types

type Drainer

type Drainer struct {
	LastDrained   string
	DrainCount    int
	DrainDuration time.Duration
	Clock         clock.Clock

	States map[string]string
}

func (*Drainer) Assert

func (d *Drainer) Assert(t *testing.T, inProgressIDs string, doneIDs string)

Assert expects a comma-separated list of instance IDs for the inProgressIDs and doneIDs args. It checks whether all instance are in the wanted state. The IDs are sorted.

func (*Drainer) Drain

func (d *Drainer) Drain(id string) (int, error)

type Request

type Request struct {
	ID       string
	Fastpath bool
}

func NewRequest

func NewRequest(id string, fp bool) Request

func (Request) Clean

func (r Request) Clean() error

func (Request) Heartbeat

func (r Request) Heartbeat() error

func (Request) InstanceID

func (r Request) InstanceID() string

func (Request) UseFastpath

func (r Request) UseFastpath() bool