watch

Dec 10, 2015

Changes in this version

type Watcher

+ func (w *Watcher) ForceWatching(d dep.Dependency, enabled bool)

Oct 26, 2015

Changes in this version

+ func StringToWaitDurationHookFunc() mapstructure.DecodeHookFunc

Oct 9, 2015

Changes in this version

type WatcherConfig

+ RenewVault bool

Apr 29, 2015

Changes in this version

type WatcherConfig

+ Clients *dep.ClientSet

Mar 30, 2015

Changes in this version

type View

+ LastIndex uint64

+ ReceivedData bool

type Watcher

+ func (w *Watcher) Size() int

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)