Versions in this module Expand all Collapse all v0 v0.4.3 Oct 30, 2014 v0.4.2 Oct 29, 2014 v0.4.1 Oct 17, 2014 Changes in this version + const EtcdErrorCodeNodeExist + const EtcdErrorCodeNotFound + const EtcdErrorCodeTestFailed + const EtcdErrorCodeValueRequired + var EtcdErrorNodeExist = &etcd.EtcdError + var EtcdErrorNotFound = &etcd.EtcdError + var EtcdErrorTestFailed = &etcd.EtcdError + var EtcdErrorValueRequired = &etcd.EtcdError + func Everything(runtime.Object) bool + func IsEtcdNodeExist(err error) bool + func IsEtcdNotFound(err error) bool + func IsEtcdTestFailed(err error) bool + func IsEtcdWatchStoppedByUser(err error) bool + 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) + 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 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) + 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 + ResourceVersioner EtcdResourceVersioner + func (h *EtcdHelper) AtomicUpdate(key string, ptrToType runtime.Object, tryUpdate EtcdUpdateFunc) error + func (h *EtcdHelper) CreateObj(key string, obj runtime.Object, ttl uint64) error + func (h *EtcdHelper) Delete(key string, recursive bool) error + func (h *EtcdHelper) ExtractList(key string, slicePtr interface{}, resourceVersion *uint64) error + func (h *EtcdHelper) ExtractObj(key string, objPtr runtime.Object, ignoreNotFound bool) error + func (h *EtcdHelper) ExtractToList(key string, listObj runtime.Object) error + func (h *EtcdHelper) SetObj(key string, obj runtime.Object) error + func (h *EtcdHelper) Watch(key string, resourceVersion uint64) watch.Interface + 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 EtcdResourceVersioner interface + ResourceVersion func(obj runtime.Object) (uint64, error) + SetResourceVersion func(obj runtime.Object, version uint64) error + type EtcdResponseWithError struct + E error + N *EtcdResponseWithError + R *etcd.Response + type EtcdUpdateFunc func(input runtime.Object) (output runtime.Object, err error) + type FakeEtcdClient struct + ChangeIndex uint64 + Data map[string]EtcdResponseWithError + DeletedKeys []string + Err error + Ix int + LastSetTTL uint64 + 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) Set(key, value string, ttl uint64) (*etcd.Response, 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 RuntimeVersionAdapter struct + Versioner runtime.ResourceVersioner + func (a RuntimeVersionAdapter) ResourceVersion(obj runtime.Object) (uint64, error) + func (a RuntimeVersionAdapter) SetResourceVersion(obj runtime.Object, version uint64) error + type TestLogger interface + Errorf func(format string, args ...interface{}) + Logf func(format string, args ...interface{}) + type TransformFunc func(runtime.Object) (runtime.Object, error)
Go to main page