package etcd

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

Index ¶

• Constants
• Variables
• func NewEtcdStorage(client etcd.Client, codec runtime.Codec, prefix string, quorum bool, cacheSize int) storage.Interface
• type APIObjectVersioner
• func (a APIObjectVersioner) CompareResourceVersion(lhs, rhs runtime.Object) int
• 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, resourceVersion uint64) 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

Variables ¶

var Versioner storage.Versioner = APIObjectVersioner{}

APIObjectVersioner implements Versioner

Functions ¶

func NewEtcdStorage ¶

func NewEtcdStorage(client etcd.Client, codec runtime.Codec, prefix string, quorum bool, cacheSize int) 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) CompareResourceVersion ¶

func (a APIObjectVersioner) CompareResourceVersion(lhs, rhs runtime.Object) int

CompareResourceVersion compares etcd resource versions. Outside this API they are all strings, but etcd resource versions are special, they're actually ints, so we can easily compare them.

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, resourceVersion uint64) error

UpdateObject implements Versioner

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 ¶