etcd

Documentation

Index

• func NewLocker(s *concurrency.Session, pfx string) sync.Locker
• func NewSource(ctx context.Context, cli *clientv3.Client, prefix string, sessionTTL int, ...) (config.Store, error)
• type TLSURLOpener
  • func (o *TLSURLOpener) OpenURL(ctx context.Context, u *url.URL) (config.Store, error)
• type URLOpener
  • func (o *URLOpener) OpenURL(ctx context.Context, u *url.URL) (config.Store, error)

Functions

func NewLocker

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

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

func NewSource

func NewSource(ctx context.Context, cli *clientv3.Client, prefix string, sessionTTL int, withKeys bool, opts ...configx.Option) (config.Store, error)

Types

type TLSURLOpener

type TLSURLOpener struct{}

func (*TLSURLOpener) OpenURL

func (o *TLSURLOpener) OpenURL(ctx context.Context, u *url.URL) (config.Store, error)

type URLOpener

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

func (*URLOpener) OpenURL

func (o *URLOpener) OpenURL(ctx context.Context, u *url.URL) (config.Store, error)