tools

package

Go to main page

Versions in this module

v0

v0.5.3

Nov 24, 2014

v0.5.2

Nov 19, 2014

v0.5.1

Nov 18, 2014

Changes in this version

+ func ParseWatchResourceVersion(resourceVersion, kind string) (uint64, error)

type EtcdClient

+ func NewEtcdClientStartServerIfNecessary(server string) (EtcdClient, error)

+ GetCluster func() []string

type EtcdGetSet

+ GetCluster func() []string

type FakeEtcdClient

+ Machines []string

+ func (f *FakeEtcdClient) GetCluster() []string

v0.4.4

Nov 19, 2014

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL