etcd

Documentation

Index

• func NewEtcdSync(client *clientv3.Client, opts ...sync.Option) sync.Sync
• func NewSync(opts ...sync.Option) sync.Sync
• type EtcdSync
  • func (e *EtcdSync) GetConn() *clientv3.Client
  • func (e *EtcdSync) Init(opts ...sync.Option) error
  • func (e *EtcdSync) Leader(ctx context.Context, name string, opts ...sync.LeaderOption) (sync.Leader, error)
  • func (e *EtcdSync) ListMembers(ctx context.Context, opts ...sync.ListMembersOption) ([]*sync.Member, error)
  • func (e *EtcdSync) Lock(ctx context.Context, id string, opts ...sync.LockOption) error
  • func (e *EtcdSync) Options() sync.Options
  • func (e *EtcdSync) String() string
  • func (e *EtcdSync) Unlock(ctx context.Context, id string) error
  • func (e *EtcdSync) WatchElect(ctx context.Context, opts ...sync.WatchElectOption) (sync.ElectWatcher, error)
• type Value

Functions

func NewEtcdSync

func NewEtcdSync(client *clientv3.Client, opts ...sync.Option) sync.Sync

func NewSync

func NewSync(opts ...sync.Option) sync.Sync

Types

type EtcdSync

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

func (*EtcdSync) GetConn

func (e *EtcdSync) GetConn() *clientv3.Client

func (*EtcdSync) Init

func (e *EtcdSync) Init(opts ...sync.Option) error

func (*EtcdSync) Leader

func (e *EtcdSync) Leader(ctx context.Context, name string, opts ...sync.LeaderOption) (sync.Leader, error)

func (*EtcdSync) ListMembers

func (e *EtcdSync) ListMembers(ctx context.Context, opts ...sync.ListMembersOption) ([]*sync.Member, error)

func (*EtcdSync) Lock

func (e *EtcdSync) Lock(ctx context.Context, id string, opts ...sync.LockOption) error

func (*EtcdSync) Options

func (e *EtcdSync) Options() sync.Options

func (*EtcdSync) String

func (e *EtcdSync) String() string

func (*EtcdSync) Unlock

func (e *EtcdSync) Unlock(ctx context.Context, id string) error

func (*EtcdSync) WatchElect

func (e *EtcdSync) WatchElect(ctx context.Context, opts ...sync.WatchElectOption) (sync.ElectWatcher, error)

type Value

type Value struct {
	Namespace string `json:"namespace"`
	Id        string `json:"id"`
}