nodes

Documentation

Index

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

Types

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

func (f *Firehose) Publish(update *nomad.Node)

Publish an update from the firehose

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{}