etcd

Documentation

Index

• Constants
• func NewEtcdStorage(client etcd.Client, codec runtime.Codec, prefix string, quorum bool) storage.Interface
• type APIObjectVersioner
  • 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, expiration *time.Time, resourceVersion uint64) error
• type EtcdConfig
• type EtcdStorageConfig
  • func (c *EtcdStorageConfig) GetType() string
  • func (c *EtcdStorageConfig) NewStorage() (storage.Interface, error)
• type HighWaterMark
  • func (hwm *HighWaterMark) Update(current int64) bool
• type TransformFunc

Constants

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

Etcd watch event actions

Functions

func NewEtcdStorage

func NewEtcdStorage(client etcd.Client, codec runtime.Codec, prefix string, quorum bool) storage.Interface

Creates a new storage interface from the client TODO: deprecate in favor of storage.Config abstraction over time

Types

type APIObjectVersioner

type APIObjectVersioner struct{}

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

func (APIObjectVersioner) ObjectResourceVersion

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

ObjectResourceVersion implements Versioner

func (APIObjectVersioner) UpdateList

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

UpdateList implements Versioner

func (APIObjectVersioner) UpdateObject

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

UpdateObject implements Versioner

type EtcdConfig

type EtcdConfig struct {
	Prefix     string
	ServerList []string
	KeyFile    string
	CertFile   string
	CAFile     string
	Quorum     bool
}

Configuration object for constructing etcd.Config

type EtcdStorageConfig

type EtcdStorageConfig struct {
	Config EtcdConfig
	Codec  runtime.Codec
}

storage.Config object for etcd.

func (*EtcdStorageConfig) GetType

func (c *EtcdStorageConfig) GetType() string

implements storage.Config

func (*EtcdStorageConfig) NewStorage

func (c *EtcdStorageConfig) NewStorage() (storage.Interface, error)

implements storage.Config

type HighWaterMark

type HighWaterMark int64

HighWaterMark is a thread-safe object for tracking the maximum value seen for some quantity.

func (*HighWaterMark) Update

func (hwm *HighWaterMark) Update(current int64) bool

Update returns true if and only if 'current' is the highest value ever seen.

type TransformFunc

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

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