allocations

Documentation

Index

• type AllocationUpdate
• type Firehose
  • func NewFirehose() (*Firehose, error)
  • func (f *Firehose) Name() string
  • func (f *Firehose) SetRestoreValue(restoreValue interface{}) error
  • func (f *Firehose) Start()
  • func (f *Firehose) Stop()
  • func (f *Firehose) UpdateCh() <-chan interface{}

Types

type AllocationUpdate

type AllocationUpdate struct {
	Name               string
	NodeID             string
	AllocationID       string
	DesiredStatus      string
	DesiredDescription string
	ClientStatus       string
	ClientDescription  string
	JobID              string
	GroupName          string
	TaskName           string
	EvalID             string
	TaskState          string
	TaskFailed         bool
	TaskStartedAt      *time.Time
	TaskFinishedAt     *time.Time
	TaskEvent          *nomad.TaskEvent
}

AllocationUpdate ...

type Firehose

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

Firehose ...

func NewFirehose

func NewFirehose() (*Firehose, error)

NewFirehose ...

func (*Firehose) Name

func (f *Firehose) Name() string

func (*Firehose) SetRestoreValue

func (f *Firehose) SetRestoreValue(restoreValue interface{}) error

func (*Firehose) Start

func (f *Firehose) Start()

Start the firehose

func (*Firehose) Stop

func (f *Firehose) Stop()

Stop the firehose

func (*Firehose) UpdateCh

func (f *Firehose) UpdateCh() <-chan interface{}