etcd3

Documentation

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.