allocations

Documentation

Index

• type AllocationUpdate
• type Firehose
  • func NewFirehose() (*Firehose, error)
  • func (f *Firehose) Publish(update *AllocationUpdate)
  • func (f *Firehose) Start() error
  • func (f *Firehose) Stop()

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) Publish

func (f *Firehose) Publish(update *AllocationUpdate)

Publish an update from the firehose

func (*Firehose) Start

func (f *Firehose) Start() error

Start the firehose

func (*Firehose) Stop

func (f *Firehose) Stop()

Stop the firehose