jobs

Documentation

Index

• type Firehose
  • func NewFirehose() (*Firehose, error)
  • func (f *Firehose) Publish(update *nomad.Job)
  • func (f *Firehose) Start() error
  • func (f *Firehose) Stop()

Types

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 *nomad.Job)

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