etcd

Documentation

Index

• func NewLocker(s *concurrency.Session, pfx string) sync.Locker
• type Store
  • func NewStore(ctx context.Context, values configx.Values, cli *clientv3.Client, ...) (Store, error)
  • func (m Store) As(out any) bool
  • func (m Store) Close(ctx context.Context) error
  • func (m Store) Context(ctx context.Context) configx.Values
  • func (m Store) Default(def any) configx.Values
  • func (m Store) Del() error
  • func (m Store) Done() <-chan struct{}
  • func (m Store) Flush()
  • func (m Store) Get() any
  • func (m Store) Key() []string
  • func (m Store) Lock()
  • func (m Store) NewLocker(name string) sync.Locker
  • func (m Store) Options() *configx.Options
  • func (m Store) Reset()
  • func (m Store) Save(ctxUser string, ctxMessage string) error
  • func (m Store) Set(data interface{}) error
  • func (m Store) Unlock()
  • func (m Store) Val(path ...string) configx.Values
  • func (m Store) Watch(opts ...watch.WatchOption) (watch.Receiver, error)

Functions

func NewLocker

func NewLocker(s *concurrency.Session, pfx string) sync.Locker

NewLocker creates a sync.Locker backed by an etcd mutex.

Types

type Store

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

func NewStore

func NewStore(ctx context.Context, values configx.Values, cli *clientv3.Client, prefix string, ttl int) (Store, error)

func (Store) As

func (m Store) As(out any) bool

func (Store) Close

func (m Store) Close(ctx context.Context) error

func (Store) Context

func (m Store) Context(ctx context.Context) configx.Values

func (Store) Default

func (m Store) Default(def any) configx.Values

func (Store) Del

func (m Store) Del() error

func (Store) Done

func (m Store) Done() <-chan struct{}

func (Store) Flush

func (m Store) Flush()

func (Store) Get

func (m Store) Get() any

func (Store) Key

func (m Store) Key() []string

func (Store) Lock

func (m Store) Lock()

func (Store) NewLocker

func (m Store) NewLocker(name string) sync.Locker

func (Store) Options

func (m Store) Options() *configx.Options

func (Store) Reset

func (m Store) Reset()

func (Store) Save

func (m Store) Save(ctxUser string, ctxMessage string) error

func (Store) Set

func (m Store) Set(data interface{}) error

func (Store) Unlock

func (m Store) Unlock()

func (Store) Val

func (m Store) Val(path ...string) configx.Values

func (Store) Watch

func (m Store) Watch(opts ...watch.WatchOption) (watch.Receiver, error)