etcd

Documentation

Index

• func DecodeInt64(b [8]byte) int64
• func EncodeInt64(i int64) [8]byte
• type Etcd
  • func (cache *Etcd) Client() *etcdv3.Client
  • func (cache *Etcd) Close(ctx context.Context) error
  • func (cache *Etcd) Fetch(ctx context.Context, key string) (*spancache.Entry, error)
  • func (cache *Etcd) FetchOrReserve(ctx context.Context, key string, ttl time.Duration) (*spancache.Entry, error)
  • func (cache *Etcd) Init() error
  • func (_ *Etcd) MuxImplName() (name string, isDefault bool)
  • func (cache *Etcd) Options() manager.Options
  • func (cache *Etcd) ReservedVarintTime() []byte
  • func (cache *Etcd) SetReserved(ctx context.Context, key string, value []byte, lastUid spancache.Uid, ...) error
  • func (cache *Etcd) Start(ctx context.Context) error

Functions

func DecodeInt64

func DecodeInt64(b [8]byte) int64

func EncodeInt64

func EncodeInt64(i int64) [8]byte

Types

type Etcd

type Etcd struct {
	manager.MuxImplBase

	Logger logrus.FieldLogger
	Clock  clock.Clock
	// contains filtered or unexported fields
}

func (*Etcd) Client

func (cache *Etcd) Client() *etcdv3.Client

func (*Etcd) Close

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

func (*Etcd) Fetch

func (cache *Etcd) Fetch(ctx context.Context, key string) (*spancache.Entry, error)

func (*Etcd) FetchOrReserve

func (cache *Etcd) FetchOrReserve(ctx context.Context, key string, ttl time.Duration) (*spancache.Entry, error)

func (*Etcd) Init

func (cache *Etcd) Init() error

func (*Etcd) MuxImplName

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

func (*Etcd) Options

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

func (*Etcd) ReservedVarintTime

func (cache *Etcd) ReservedVarintTime() []byte

func (*Etcd) SetReserved

func (cache *Etcd) SetReserved(ctx context.Context, key string, value []byte, lastUid spancache.Uid, ttl time.Duration) error

func (*Etcd) Start

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