jobs

Documentation

Index

• type FirehoseBase
  • 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
  • func NewJobFirehose() (*JobFirehose, error)
  • func (f *JobFirehose) Name() string
  • func (f *JobFirehose) Publish(update *nomad.Job)
  • func (f *JobFirehose) Start()
• type JobListStubFirehose
  • func NewJobListStubFirehose() (*JobListStubFirehose, error)
  • func (f *JobListStubFirehose) Name() string
  • func (f *JobListStubFirehose) Publish(update *nomad.JobListStub)
  • func (f *JobListStubFirehose) Start()
• type WatchJobListFunc

Types

type FirehoseBase

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

Firehose ...

func NewFirehoseBase

func NewFirehoseBase() (*FirehoseBase, error)

NewFirehose ...

func (*FirehoseBase) SetRestoreValue

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

func (*FirehoseBase) Start

func (f *FirehoseBase) Start(w WatchJobListFunc)

Start the firehose

func (*FirehoseBase) Stop

func (f *FirehoseBase) Stop()

Stop the firehose

func (*FirehoseBase) UpdateCh

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

type JobFirehose

type JobFirehose struct {
	FirehoseBase
}

Firehose ...

func NewJobFirehose

func NewJobFirehose() (*JobFirehose, error)

NewFirehose ...

func (*JobFirehose) Name

func (f *JobFirehose) Name() string

func (*JobFirehose) Publish

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

Publish an update from the firehose

func (*JobFirehose) Start

func (f *JobFirehose) Start()

type JobListStubFirehose

type JobListStubFirehose struct {
	FirehoseBase
}

Firehose ...

func NewJobListStubFirehose

func NewJobListStubFirehose() (*JobListStubFirehose, error)

NewFirehose ...

func (*JobListStubFirehose) Name

func (f *JobListStubFirehose) Name() string

func (*JobListStubFirehose) Publish

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

Publish an update from the firehose

func (*JobListStubFirehose) Start

func (f *JobListStubFirehose) Start()

type WatchJobListFunc

type WatchJobListFunc func(job *nomad.JobListStub)