etcdclient

Documentation

Index

• func WithAuth(user string, pass string) func(client *Client)
• func WithEndPoints(endPoints ...string) func(client *Client)
• func WithTimeout(timeout time.Duration) func(client *Client)
• type Client
  • func New(opts ...Option) *Client
  • func (this *Client) NewMutex(key string, ttl int) (*Mutex, error)
• type Mutex
  • func CreateMutex(key string, ttl int, machines []string) (*Mutex, error)
  • func (this *Mutex) Lock() (err error)
  • func (this *Mutex) RefreshLockTTL(ttl time.Duration) (err error)
  • func (this *Mutex) Unlock() (err error)
• type Option

Functions

func WithAuth

func WithAuth(user string, pass string) func(client *Client)

func WithEndPoints

func WithEndPoints(endPoints ...string) func(client *Client)

func WithTimeout

func WithTimeout(timeout time.Duration) func(client *Client)

Types

type Client

type Client struct {
	clientv3.KV
	clientv3.Watcher
	*clientv3.Client
	// contains filtered or unexported fields
}

func New

func New(opts ...Option) *Client

func (*Client) NewMutex

func (this *Client) NewMutex(key string, ttl int) (*Mutex, error)

type Mutex

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

func CreateMutex

func CreateMutex(key string, ttl int, machines []string) (*Mutex, error)

func (*Mutex) Lock

func (this *Mutex) Lock() (err error)

func (*Mutex) RefreshLockTTL

func (this *Mutex) RefreshLockTTL(ttl time.Duration) (err error)

func (*Mutex) Unlock

func (this *Mutex) Unlock() (err error)

type Option

type Option func(client *Client)