etcd

Documentation

Index

• func New(opts ...EtcdOpts) (storage.Connection, error)
• type Etcd
  • func (e *Etcd) Bucket(bucket ...string) *storage.Bucket
  • func (e *Etcd) Close()
  • func (e *Etcd) Delete(k string) error
  • func (e *Etcd) Encoding() encoding.Coder
  • func (e *Etcd) Exists(k string) bool
  • func (e *Etcd) Get(k string, v any) error
  • func (e *Etcd) Iter(ctx context.Context, pfx string) types.Iterator[string, []byte]
  • func (e *Etcd) Keys(pfx string) ([]string, error)
  • func (e *Etcd) Len(pfx string) (int, error)
  • func (e *Etcd) PrintDebug(pfx string) error
  • func (e *Etcd) Set(k string, v any, op ...storage.Option) error
  • func (e *Etcd) Tx(pfx string, fn func(tx storage.Transactioner) error) error
  • func (e *Etcd) Values(pfx string) ([][]byte, error)
  • func (e *Etcd) Watch(ctx context.Context, pfx string) types.Watcher[string, []byte]
• type EtcdOpts
  • func Coder(coder encoding.Coder) EtcdOpts
  • func Context(ctx context.Context) EtcdOpts
  • func Embed(loadBalancer, token, dir string, test bool) EtcdOpts
  • func Endpoints(edp ...string) EtcdOpts
  • func Logger(lg storage.Logger) EtcdOpts

Functions

func New

func New(opts ...EtcdOpts) (storage.Connection, error)

Types

type Etcd

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

func (*Etcd) Bucket

func (e *Etcd) Bucket(bucket ...string) *storage.Bucket

func (*Etcd) Close

func (e *Etcd) Close()

func (*Etcd) Delete

func (e *Etcd) Delete(k string) error

func (*Etcd) Encoding

func (e *Etcd) Encoding() encoding.Coder

func (*Etcd) Exists

func (e *Etcd) Exists(k string) bool

func (*Etcd) Get

func (e *Etcd) Get(k string, v any) error

func (*Etcd) Iter

func (e *Etcd) Iter(ctx context.Context, pfx string) types.Iterator[string, []byte]

func (*Etcd) Keys

func (e *Etcd) Keys(pfx string) ([]string, error)

func (*Etcd) Len

func (e *Etcd) Len(pfx string) (int, error)

func (*Etcd) PrintDebug

func (e *Etcd) PrintDebug(pfx string) error

func (*Etcd) Set

func (e *Etcd) Set(k string, v any, op ...storage.Option) error

func (*Etcd) Tx

func (e *Etcd) Tx(pfx string, fn func(tx storage.Transactioner) error) error

func (*Etcd) Values

func (e *Etcd) Values(pfx string) ([][]byte, error)

func (*Etcd) Watch

func (e *Etcd) Watch(ctx context.Context, pfx string) types.Watcher[string, []byte]

type EtcdOpts

type EtcdOpts func(*Etcd) error

func Coder

func Coder(coder encoding.Coder) EtcdOpts

func Context

func Context(ctx context.Context) EtcdOpts

func Embed

func Embed(loadBalancer, token, dir string, test bool) EtcdOpts

Start single-node embedded etcd

func Endpoints

func Endpoints(edp ...string) EtcdOpts

Connect to etcd endpoints

func Logger

func Logger(lg storage.Logger) EtcdOpts