etcd

Documentation

Index

• func Factory(etcdCfg core.CacheProvider, logger core.Logger, stale time.Duration) (core.Storer, error)
• type Etcd
  • func (provider *Etcd) Delete(key string)
  • func (provider *Etcd) DeleteMany(key string)
  • func (provider *Etcd) Get(key string) (item []byte)
  • func (provider *Etcd) GetMultiLevel(key string, req *http.Request, validator *core.Revalidator) (fresh *http.Response, stale *http.Response)
  • func (provider *Etcd) Init() error
  • func (provider *Etcd) ListKeys() []string
  • func (provider *Etcd) MapKeys(prefix string) map[string]string
  • func (provider *Etcd) Name() string
  • func (provider *Etcd) Reconnect()
  • func (provider *Etcd) Reset() error
  • func (provider *Etcd) Set(key string, value []byte, duration time.Duration) error
  • func (provider *Etcd) SetMultiLevel(baseKey, variedKey string, value []byte, variedHeaders http.Header, ...) error
  • func (provider *Etcd) Uuid() string

Functions

func Factory

func Factory(etcdCfg core.CacheProvider, logger core.Logger, stale time.Duration) (core.Storer, error)

Factory function create new Etcd instance.

Types

type Etcd

type Etcd struct {
	*clientv3.Client
	// contains filtered or unexported fields
}

Etcd provider type.

func (*Etcd) Delete

func (provider *Etcd) Delete(key string)

Delete method will delete the response in Etcd provider if exists corresponding to key param.

func (*Etcd) DeleteMany

func (provider *Etcd) DeleteMany(key string)

DeleteMany method will delete the responses in Etcd provider if exists corresponding to the regex key param.

func (*Etcd) Get

func (provider *Etcd) Get(key string) (item []byte)

Get method returns the populated response if exists, empty response then.

func (*Etcd) GetMultiLevel

func (provider *Etcd) GetMultiLevel(key string, req *http.Request, validator *core.Revalidator) (fresh *http.Response, stale *http.Response)

GetMultiLevel tries to load the key and check if one of linked keys is a fresh/stale candidate.

func (*Etcd) Init

func (provider *Etcd) Init() error

Init method will.

func (*Etcd) ListKeys

func (provider *Etcd) ListKeys() []string

ListKeys method returns the list of existing keys.

func (*Etcd) MapKeys

func (provider *Etcd) MapKeys(prefix string) map[string]string

MapKeys method returns the map of existing keys.

func (*Etcd) Name

func (provider *Etcd) Name() string

Name returns the storer name.

func (*Etcd) Reconnect

func (provider *Etcd) Reconnect()

func (*Etcd) Reset

func (provider *Etcd) Reset() error

Reset method will reset or close provider.

func (*Etcd) Set

func (provider *Etcd) Set(key string, value []byte, duration time.Duration) error

Set method will store the response in Etcd provider.

func (*Etcd) SetMultiLevel

func (provider *Etcd) SetMultiLevel(baseKey, variedKey string, value []byte, variedHeaders http.Header, etag string, duration time.Duration, realKey string) error

SetMultiLevel tries to store the key with the given value and update the mapping key to store metadata.

func (*Etcd) Uuid

func (provider *Etcd) Uuid() string

Uuid returns an unique identifier.