etcd

Documentation

Index

• type ConfigurationWatcher
  • func NewConfigurationWatcher(configStorage *etcd.ConfigurationStorage, settingsKey string, ...) (*ConfigurationWatcher, error)
  • func (cw *ConfigurationWatcher) Stop()
  • func (cw *ConfigurationWatcher) Watch()
  • func (cw *ConfigurationWatcher) WatchChan() chan interface{}

Types

type ConfigurationWatcher

type ConfigurationWatcher struct {
	Client *clientv3.Client
	// contains filtered or unexported fields
}

ConfigurationWatcher wraps etcd client.

func NewConfigurationWatcher

func NewConfigurationWatcher(configStorage *etcd.ConfigurationStorage, settingsKey string, watchChan chan interface{}) (*ConfigurationWatcher, error)

NewConfigurationWatcher creates and returns new etcd-backed configuration watcher.

func (*ConfigurationWatcher) Stop

func (cw *ConfigurationWatcher) Stop()

Stop stops watcher.

func (*ConfigurationWatcher) Watch

func (cw *ConfigurationWatcher) Watch()

Watch watches for configuration updates.

func (*ConfigurationWatcher) WatchChan

func (cw *ConfigurationWatcher) WatchChan() chan interface{}

WatchChan returns watcher's event channel.