jobs

Oct 15, 2018

Changes in this version

+ type FirehoseBase struct

+ func NewFirehoseBase() (*FirehoseBase, error)

+ func (f *FirehoseBase) SetRestoreValue(restoreValue interface{}) error

+ func (f *FirehoseBase) Start(w WatchJobListFunc)

+ func (f *FirehoseBase) Stop()

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

+ type JobFirehose struct

+ func NewJobFirehose() (*JobFirehose, error)

+ func (f *JobFirehose) Name() string

+ func (f *JobFirehose) Publish(update *nomad.Job)

+ func (f *JobFirehose) Start()

+ type JobListStubFirehose struct

+ func NewJobListStubFirehose() (*JobListStubFirehose, error)

+ func (f *JobListStubFirehose) Name() string

+ func (f *JobListStubFirehose) Publish(update *nomad.JobListStub)

+ func (f *JobListStubFirehose) Start()

+ type WatchJobListFunc func(job *nomad.JobListStub)

Sep 4, 2018

Changes in this version

type Firehose

+ func (f *Firehose) Name() string

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

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

Jul 12, 2017

Changes in this version

+ type Firehose struct

+ func NewFirehose() (*Firehose, error)

+ func (f *Firehose) Publish(update *nomad.Job)

+ func (f *Firehose) Start() error

+ func (f *Firehose) Stop()