watch

Feb 19, 2015

Changes in this version

+ type WaitVar Wait

+ func (w *WaitVar) Set(value string) error

+ func (w *WaitVar) String() string

Feb 5, 2015

Changes in this version

type RetryFunc

+ var DefaultRetryFunc RetryFunc = func(t time.Duration) time.Duration { ... }

+ type WatcherConfig struct

+ Client *api.Client

+ MaxStale time.Duration

+ Once bool

+ RetryFunc RetryFunc

Feb 2, 2015

Changes in this version

type Watcher

+ func (w *Watcher) BatchSize() int

+ func (w *Watcher) SetBatchSize(size int) error

Jan 20, 2015

Changes in this version

type Watcher

+ func (w *Watcher) Add(d dep.Dependency) (bool, error)

+ func (w *Watcher) Remove(d dep.Dependency) bool

+ func (w *Watcher) Watching(d dep.Dependency) bool

Dec 25, 2014

Changes in this version

+ type RetryFunc func(time.Duration) time.Duration

+ type View struct

+ Data interface{}

+ Dependency dependency.Dependency

+ func NewView(client *api.Client, dep dependency.Dependency) (*View, error)

+ type Wait struct

+ Max time.Duration

+ Min time.Duration

+ func ParseWait(s string) (*Wait, error)

+ type Watcher struct

+ DataCh chan *View

+ ErrCh chan error

+ FinishCh chan struct{}

+ func NewWatcher(client *api.Client, dependencies []dependency.Dependency) (*Watcher, error)

+ func (w *Watcher) SetRetry(duration time.Duration)

+ func (w *Watcher) SetRetryFunc(f RetryFunc)

+ func (w *Watcher) Stop()

+ func (w *Watcher) Watch(once bool)