Everything is a FilterFunc which accepts all objects.

GetEtcdVersion performs a version check against the provided Etcd server, returning the string response, and error (if any).

IsEtcdNodeExist returns true iff err is an etcd node aleady exist error.

IsEtcdNotFound returns true iff err is an etcd not found error.

IsEtcdTestFailed returns true iff err is an etcd write conflict.

IsEtcdWatchStoppedByUser returns true iff err is a client triggered stop.

NewEtcdHelper creates a helper that works against objects that use the internal Kubernetes API objects.

ParseWatchResourceVersion takes a resource version argument and converts it to the etcd version we should pass to helper.Watch().

Etcd watch event actions.

Etcd watch event actions.

Etcd watch event actions.

Etcd watch event actions.

Etcd watch event actions.

APIObjectVersioner implements versioning and extracting etcd node information for objects that have an embedded ObjectMeta or ListMeta field.

EtcdHelper offers common object marshalling/unmarshalling operations on an etcd client.

EtcdClient is an injectable interface for testing.

EtcdGetSet interface exposes only the etcd operations needed by EtcdHelper.

EtcdVersioner abstracts setting and retrieving fields from the etcd response onto the object or list.

TestLogger is a type passed to Test functions to support formatted test logs.

Pass an EtcdUpdateFunc to EtcdHelper.GuaranteedUpdate to make an etcd update that is guaranteed to succeed.

FilterFunc is a predicate which takes an API object and returns true iff the object should remain in the set.

TransformFunc attempts to convert an object to another object for use with a watcher.