package etcd3

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

Index ¶

• func New(c *clientv3.Client, codec runtime.Codec, prefix string) storage.Interface
• func StartCompactor(ctx context.Context, client *clientv3.Client)

Functions ¶

func New ¶

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

New returns an etcd3 implementation of storage.Interface.

func StartCompactor ¶

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

StartCompactor starts a compactor in the background in order to compact keys older than fixed time. We need to compact keys because we can't let on disk data grow forever. We save the most recent 10 minutes data. 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 multi-version key.

Source Files ¶

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