Versions in this module Expand all Collapse all v0 v0.19.0 Jun 9, 2015 Changes in this version + const EtcdCAS + const EtcdCreate + const EtcdDelete + const EtcdErrorCodeNodeExist + const EtcdErrorCodeNotFound + const EtcdErrorCodeTestFailed + const EtcdErrorCodeValueRequired + const EtcdGet + const EtcdSet + var EtcdErrorNodeExist = &etcd.EtcdError + var EtcdErrorNotFound = &etcd.EtcdError + var EtcdErrorTestFailed = &etcd.EtcdError + var EtcdErrorValueRequired = &etcd.EtcdError + func Everything(runtime.Object) bool + func GetEtcdVersion(host string) (string, error) + func IsEtcdNodeExist(err error) bool + func IsEtcdNotFound(err error) bool + func IsEtcdTestFailed(err error) bool + func IsEtcdWatchStoppedByUser(err error) bool + func ParseWatchResourceVersion(resourceVersion, kind string) (uint64, error) + type APIObjectVersioner struct + func (a APIObjectVersioner) ObjectResourceVersion(obj runtime.Object) (uint64, error) + func (a APIObjectVersioner) UpdateList(obj runtime.Object, resourceVersion uint64) error + func (a APIObjectVersioner) UpdateObject(obj runtime.Object, node *etcd.Node) error + type EtcdClient interface + AddChild func(key, data string, ttl uint64) (*etcd.Response, error) + CompareAndSwap func(key, value string, ttl uint64, prevValue string, prevIndex uint64) (*etcd.Response, error) + Create func(key, value string, ttl uint64) (*etcd.Response, error) + Delete func(key string, recursive bool) (*etcd.Response, error) + Get func(key string, sort, recursive bool) (*etcd.Response, error) + GetCluster func() []string + Set func(key, value string, ttl uint64) (*etcd.Response, error) + Watch func(prefix string, waitIndex uint64, recursive bool, receiver chan *etcd.Response, ...) (*etcd.Response, error) + func NewEtcdClientStartServerIfNecessary(server string) (EtcdClient, error) + type EtcdGetSet interface + CompareAndSwap func(key, value string, ttl uint64, prevValue string, prevIndex uint64) (*etcd.Response, error) + Create func(key, value string, ttl uint64) (*etcd.Response, error) + Delete func(key string, recursive bool) (*etcd.Response, error) + Get func(key string, sort, recursive bool) (*etcd.Response, error) + GetCluster func() []string + Set func(key, value string, ttl uint64) (*etcd.Response, error) + Watch func(prefix string, waitIndex uint64, recursive bool, receiver chan *etcd.Response, ...) (*etcd.Response, error) + type EtcdHelper struct + Client EtcdGetSet + Codec runtime.Codec + PathPrefix string + Versioner EtcdVersioner + func NewEtcdHelper(client EtcdGetSet, codec runtime.Codec, prefix string) EtcdHelper + func (h *EtcdHelper) CreateObj(key string, obj, out runtime.Object, ttl uint64) error + func (h *EtcdHelper) Delete(key string, recursive bool) error + func (h *EtcdHelper) DeleteObj(key string, out runtime.Object) error + func (h *EtcdHelper) ExtractObj(key string, objPtr runtime.Object, ignoreNotFound bool) error + func (h *EtcdHelper) ExtractObjToList(key string, listObj runtime.Object) error + func (h *EtcdHelper) ExtractToList(key string, listObj runtime.Object) error + func (h *EtcdHelper) GuaranteedUpdate(key string, ptrToType runtime.Object, ignoreNotFound bool, ...) error + func (h *EtcdHelper) MigrateKeys(oldPathPrefix string) error + func (h *EtcdHelper) PrefixEtcdKey(key string) string + func (h *EtcdHelper) SetObj(key string, obj, out runtime.Object, ttl uint64) error + func (h *EtcdHelper) Watch(key string, resourceVersion uint64, filter FilterFunc) (watch.Interface, error) + func (h *EtcdHelper) WatchAndTransform(key string, resourceVersion uint64, transform TransformFunc) watch.Interface + func (h *EtcdHelper) WatchList(key string, resourceVersion uint64, filter FilterFunc) (watch.Interface, error) + type EtcdResponseWithError struct + E error + N *EtcdResponseWithError + R *etcd.Response + type EtcdUpdateFunc func(input runtime.Object, res ResponseMeta) (output runtime.Object, ttl *uint64, err error) + func SimpleUpdate(fn SimpleEtcdUpdateFunc) EtcdUpdateFunc + type EtcdVersioner interface + ObjectResourceVersion func(obj runtime.Object) (uint64, error) + UpdateList func(obj runtime.Object, resourceVersion uint64) error + UpdateObject func(obj runtime.Object, node *etcd.Node) error + type FakeEtcdClient struct + CasErr error + ChangeIndex uint64 + Data map[string]EtcdResponseWithError + DeletedKeys []string + Err error + Ix int + LastSetTTL uint64 + Machines []string + TestIndex bool + WatchImmediateError error + WatchIndex uint64 + WatchInjectError chan<- error + WatchResponse chan *etcd.Response + WatchStop chan<- bool + func NewFakeEtcdClient(t TestLogger) *FakeEtcdClient + func (f *FakeEtcdClient) AddChild(key, data string, ttl uint64) (*etcd.Response, error) + func (f *FakeEtcdClient) CompareAndSwap(key, value string, ttl uint64, prevValue string, prevIndex uint64) (*etcd.Response, error) + func (f *FakeEtcdClient) Create(key, value string, ttl uint64) (*etcd.Response, error) + func (f *FakeEtcdClient) Delete(key string, recursive bool) (*etcd.Response, error) + func (f *FakeEtcdClient) ExpectNotFoundGet(key string) + func (f *FakeEtcdClient) Get(key string, sort, recursive bool) (*etcd.Response, error) + func (f *FakeEtcdClient) GetCluster() []string + func (f *FakeEtcdClient) NewError(code int) *etcd.EtcdError + func (f *FakeEtcdClient) Set(key, value string, ttl uint64) (*etcd.Response, error) + func (f *FakeEtcdClient) SetError(err error) + func (f *FakeEtcdClient) WaitForWatchCompletion() + func (f *FakeEtcdClient) Watch(prefix string, waitIndex uint64, recursive bool, receiver chan *etcd.Response, ...) (*etcd.Response, error) + type FilterFunc func(obj runtime.Object) bool + type ResponseMeta struct + TTL int64 + type SimpleEtcdUpdateFunc func(runtime.Object) (runtime.Object, error) + type TestLogger interface + Errorf func(format string, args ...interface{}) + Fatalf func(format string, args ...interface{}) + Logf func(format string, args ...interface{}) + type TransformFunc func(runtime.Object) (runtime.Object, error)
Go to main page