watcher

Documentation

Index

• Constants
• type Watcher
  • func NewWatcher(logger lager.Logger, workPoolSize int, retryPauseInterval time.Duration, ...) (*Watcher, error)
  • func (watcher *Watcher) Run(signals <-chan os.Signal, ready chan<- struct{}) error

Constants

const DefaultRetryPauseInterval = time.Second

Types

type Watcher

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

func NewWatcher

func NewWatcher(
	logger lager.Logger,
	workPoolSize int,
	retryPauseInterval time.Duration,
	bbsClient bbs.Client,
	ccClient cc_client.CcClient,
) (*Watcher, error)

func (*Watcher) Run

func (watcher *Watcher) Run(signals <-chan os.Signal, ready chan<- struct{}) error