etcd

package

v1.2.0-alpha.2 Latest Latest Go to latest Published: Oct 19, 2015 License: Apache-2.0 Imports: 24 Imported by: 0

Details

View Source

const (
	EtcdCreate = "create"
	EtcdGet    = "get"
	EtcdSet    = "set"
	EtcdCAS    = "compareAndSwap"
	EtcdDelete = "delete"
	EtcdExpire = "expire"
)

Etcd watch event actions

This section is empty.

func EtcdHealthCheck(data []byte) error

func GetEtcdVersion(host string) (string, error)

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

func IsEtcdNodeExist(err error) bool

IsEtcdNodeExist returns true if and only if err is an etcd node already exist error.

func IsEtcdNotFound(err error) bool

IsEtcdNotFound returns true if and only if err is an etcd not found error.

func IsEtcdTestFailed(err error) bool

IsEtcdTestFailed returns true if and only if err is an etcd write conflict.

func IsEtcdWatchStoppedByUser(err error) bool

IsEtcdWatchStoppedByUser returns true if and only if err is a client triggered stop.

func NewEtcdClientStartServerIfNecessary(server string) (tools.EtcdClient, error)

func NewEtcdStorage(client tools.EtcdClient, codec runtime.Codec, prefix string) storage.Interface

type APIObjectVersioner struct{}

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

func (a APIObjectVersioner) ObjectResourceVersion(obj runtime.Object) (uint64, error)

ObjectResourceVersion implements Versioner

func (a APIObjectVersioner) UpdateList(obj runtime.Object, resourceVersion uint64) error

UpdateList implements Versioner

func (a APIObjectVersioner) UpdateObject(obj runtime.Object, expiration *time.Time, resourceVersion uint64) error

UpdateObject implements Versioner

type TransformFunc func(runtime.Object) (runtime.Object, error)

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