watcher

Documentation

Index

• type ActualStreamer
  • func NewActualStreamer(eventDB db.EventDB) *ActualStreamer
  • func (s *ActualStreamer) Stream(logger lager.Logger, eventChan chan<- models.Event) (chan<- bool, <-chan error)
• type DesiredStreamer
  • func NewDesiredStreamer(eventDB db.EventDB) *DesiredStreamer
  • func (s *DesiredStreamer) Stream(logger lager.Logger, eventChan chan<- models.Event) (chan<- bool, <-chan error)
• type EventStreamer
• type TaskStreamer
  • func NewTaskStreamer(eventDB db.EventDB) *TaskStreamer
  • func (s *TaskStreamer) Stream(logger lager.Logger, eventChan chan<- models.Event) (chan<- bool, <-chan error)
• type Watcher
  • func NewWatcher(logger lager.Logger, name string, retryWaitDuration time.Duration, ...) Watcher

Types

type ActualStreamer

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

func NewActualStreamer

func NewActualStreamer(eventDB db.EventDB) *ActualStreamer

func (*ActualStreamer) Stream

func (s *ActualStreamer) Stream(logger lager.Logger, eventChan chan<- models.Event) (chan<- bool, <-chan error)

type DesiredStreamer

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

func NewDesiredStreamer

func NewDesiredStreamer(eventDB db.EventDB) *DesiredStreamer

func (*DesiredStreamer) Stream

func (s *DesiredStreamer) Stream(logger lager.Logger, eventChan chan<- models.Event) (chan<- bool, <-chan error)

type EventStreamer

type EventStreamer interface {
	Stream(logger lager.Logger, eventChan chan<- models.Event) (stop chan<- bool, error <-chan error)
}

type TaskStreamer

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

func NewTaskStreamer

func NewTaskStreamer(eventDB db.EventDB) *TaskStreamer

func (*TaskStreamer) Stream

func (s *TaskStreamer) Stream(logger lager.Logger, eventChan chan<- models.Event) (chan<- bool, <-chan error)

type Watcher

type Watcher ifrit.Runner

func NewWatcher

func NewWatcher(
	logger lager.Logger,
	name string,
	retryWaitDuration time.Duration,
	streamer EventStreamer,
	hub events.Hub,
	clock clock.Clock,
) Watcher