etcdcache

Documentation

Index

• type EtcdCache
  • func New() *EtcdCache
  • func NewForPrefix(prefix string) (*EtcdCache, error)
  • func (e *EtcdCache) Get(key string) (*mvccpb.KeyValue, error)
  • func (e *EtcdCache) GetAll() []*mvccpb.KeyValue
  • func (e *EtcdCache) Invalidate(key string)
  • func (e *EtcdCache) Put(val *mvccpb.KeyValue)

Types

type EtcdCache

type EtcdCache struct {
	// contains filtered or unexported fields
}

EtcdCache stores etcd records in memory to do requests on

func New

func New() *EtcdCache

New gives a new empty EtcdCache

func NewForPrefix

func NewForPrefix(prefix string) (*EtcdCache, error)

NewForPrefix returns a new EtcdCache prefilled with the keys of a specific prefix

func (*EtcdCache) Get

func (e *EtcdCache) Get(key string) (*mvccpb.KeyValue, error)

Get gets a key out of the cache

func (*EtcdCache) GetAll

func (e *EtcdCache) GetAll() []*mvccpb.KeyValue

GetAll returns all cached keysaa

func (*EtcdCache) Invalidate

func (e *EtcdCache) Invalidate(key string)

Invalidate removes a key from cache

func (*EtcdCache) Put

func (e *EtcdCache) Put(val *mvccpb.KeyValue)

Put allows to add a new record