etcd

Documentation

Index

• type Etcd
  • func (cache *Etcd) Close(ctx context.Context) error
  • func (cache *Etcd) Fetch(ctx context.Context, object utilobject.Key, oldResourceVersion string, ...) (*diffcache.Patch, error)
  • func (cache *Etcd) FetchSnapshot(ctx context.Context, object utilobject.Key, snapshotName string) (*diffcache.Snapshot, error)
  • func (cache *Etcd) GetCommonOptions() *diffcache.CommonOptions
  • func (cache *Etcd) Init() error
  • func (cache *Etcd) List(ctx context.Context, object utilobject.Key, limit int) ([]string, error)
  • func (_ *Etcd) MuxImplName() (name string, isDefault bool)
  • func (cache *Etcd) Options() manager.Options
  • func (cache *Etcd) Start(ctx context.Context) error
  • func (cache *Etcd) Store(ctx context.Context, object utilobject.Key, patch *diffcache.Patch)
  • func (cache *Etcd) StoreSnapshot(ctx context.Context, object utilobject.Key, snapshotName string, ...)

Types

type Etcd

type Etcd struct {
	manager.MuxImplBase

	Logger         logrus.FieldLogger
	ClusterConfigs k8sconfig.Config
	// contains filtered or unexported fields
}

func (*Etcd) Close

func (cache *Etcd) Close(ctx context.Context) error

func (*Etcd) Fetch

func (cache *Etcd) Fetch(
	ctx context.Context,
	object utilobject.Key,
	oldResourceVersion string,
	newResourceVersion *string,
) (*diffcache.Patch, error)

func (*Etcd) FetchSnapshot

func (cache *Etcd) FetchSnapshot(ctx context.Context, object utilobject.Key, snapshotName string) (*diffcache.Snapshot, error)

func (*Etcd) GetCommonOptions

func (cache *Etcd) GetCommonOptions() *diffcache.CommonOptions

func (*Etcd) Init

func (cache *Etcd) Init() error

func (*Etcd) List

func (cache *Etcd) List(ctx context.Context, object utilobject.Key, limit int) ([]string, error)

func (*Etcd) MuxImplName

func (_ *Etcd) MuxImplName() (name string, isDefault bool)

func (*Etcd) Options

func (cache *Etcd) Options() manager.Options

func (*Etcd) Start

func (cache *Etcd) Start(ctx context.Context) error

func (*Etcd) Store

func (cache *Etcd) Store(ctx context.Context, object utilobject.Key, patch *diffcache.Patch)

func (*Etcd) StoreSnapshot

func (cache *Etcd) StoreSnapshot(ctx context.Context, object utilobject.Key, snapshotName string, snapshot *diffcache.Snapshot)