Documentation
¶
Index ¶
- func EtcdHealthCheck(data []byte) error
- func New(c *clientv3.Client, codec runtime.Codec, newFunc func() runtime.Object, ...) storage.Interface
- func NewETCDLatencyTracker(delegate clientv3.KV) clientv3.KV
- func StartCompactor(ctx context.Context, client *clientv3.Client, compactInterval time.Duration)
- func TestOnlySetFatalOnDecodeError(b bool)
- type LeaseManagerConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EtcdHealthCheck ¶ added in v0.16.4
EtcdHealthCheck decodes data returned from etcd /healthz handler.
func New ¶
func New(c *clientv3.Client, codec runtime.Codec, newFunc func() runtime.Object, prefix string, groupResource schema.GroupResource, transformer value.Transformer, pagingEnabled bool, leaseManagerConfig LeaseManagerConfig) storage.Interface
New returns an etcd3 implementation of storage.Interface.
func NewETCDLatencyTracker ¶ added in v0.24.0
NewETCDLatencyTracker returns an implementation of clientv3.KV that times the calls from the specified 'delegate' KV instance in order to track latency incurred.
func StartCompactor ¶
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.
func TestOnlySetFatalOnDecodeError ¶
func TestOnlySetFatalOnDecodeError(b bool)
TestOnlySetFatalOnDecodeError should only be used for cases where decode errors are expected and need to be tested. e.g. conversion webhooks.
Types ¶
type LeaseManagerConfig ¶ added in v0.18.18
type LeaseManagerConfig struct {
// ReuseDurationSeconds specifies time in seconds that each lease is reused
ReuseDurationSeconds int64
// MaxObjectCount specifies how many objects that a lease can attach
MaxObjectCount int64
}
LeaseManagerConfig is configuration for creating a lease manager.
func NewDefaultLeaseManagerConfig ¶ added in v0.18.18
func NewDefaultLeaseManagerConfig() LeaseManagerConfig
NewDefaultLeaseManagerConfig creates a LeaseManagerConfig with default values
Source Files
Directories