kubernetesk8s.io/kubernetes/pkg/storage/etcd3 Index | Files

package etcd3

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

Index

Functions

func New

func New(c *clientv3.Client, codec runtime.Codec, prefix string) storage.Interface

New returns an etcd3 implementation of storage.Interface.

func NewWithNoQuorumRead

func NewWithNoQuorumRead(c *clientv3.Client, codec runtime.Codec, prefix string) storage.Interface

NewWithNoQuorumRead returns etcd3 implementation of storage.Interface where Get operations don't require quorum read.

func StartCompactor

func StartCompactor(ctx context.Context, client *clientv3.Client)

StartCompactor starts a compactor in the background to compact old version of keys that's not needed. By default, we save the most recent 10 minutes data and compact versions > 10minutes ago. It should be enough for slow watchers and to tolerate burst. TODO: We might keep a longer history (12h) in the future once storage API can take advantage of past version of keys.

Source Files

compact.go event.go store.go watcher.go

Version
v1.5.6
Published
Mar 28, 2017
Platform
js/wasm
Imports
24 packages
Last checked
1 minute ago

Tools for package owners.