package etcd

import "k8s.io/kubernetes/pkg/storage/etcd"

Index ¶

• Constants
• func NewEtcdStorage(client etcd.Client, codec runtime.Codec, prefix string) 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
• func (c *EtcdConfig) GetType() string
• func (c *EtcdConfig) 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"
	EtcdExpire = "expire"
)

Etcd watch event actions

Functions ¶

func NewEtcdStorage ¶

func NewEtcdStorage(client etcd.Client, codec runtime.Codec, prefix string) 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 {
	ServerList []string
	Codec      runtime.Codec
	Prefix     string
}

storage.Config object for etcd.

func (*EtcdConfig) GetType ¶

func (c *EtcdConfig) GetType() string

implements storage.Config

func (*EtcdConfig) NewStorage ¶

func (c *EtcdConfig) 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.

Source Files ¶

api_object_versioner.go doc.go etcd_helper.go etcd_watcher.go

Directories ¶