etcd

package

v1.3.0-alpha.3 Latest Latest Go to latest Published: Apr 26, 2016 License: Apache-2.0 Imports: 28 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/kdada/kubernetes

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewEtcdStorage(client etcd.Client, codec runtime.Codec, prefix string, quorum bool, ...) storage.Interface
type APIObjectVersioner
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 ¶

View Source

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

Etcd watch event actions

Variables ¶

This section is empty.

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) 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 EtcdConfig ¶ added in v1.2.0

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

Configuration object for constructing etcd.Config

type EtcdStorageConfig ¶ added in v1.2.0

type EtcdStorageConfig struct {
	Config EtcdConfig
	Codec  runtime.Codec
}

storage.Config object for etcd.

func (*EtcdStorageConfig) GetType ¶ added in v1.2.0

func (c *EtcdStorageConfig) GetType() string

implements storage.Config

func (*EtcdStorageConfig) NewStorage ¶ added in v1.2.0

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

implements storage.Config

type HighWaterMark ¶ added in v1.2.0

type HighWaterMark int64

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

func (*HighWaterMark) Update ¶ added in v1.2.0

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 ¶

View all Source files

Directories ¶

Path	Synopsis
etcdtest
metrics
testing
util Package util holds generic etcd-related utility functions that any user of ectd might want to use, without pulling in kubernetes-specific code.	Package util holds generic etcd-related utility functions that any user of ectd might want to use, without pulling in kubernetes-specific code.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL