etcd

Documentation

Index

• func CreateETCDClient(conf types.ETCDConf) (client.Client, error)
• func HandleError(err error) error
• type Mutex
  • func New(key string, ttl int, c client.Client) *Mutex
  • func (m *Mutex) Lock() (err error)
  • func (m *Mutex) Unlock() (err error)

Functions

func CreateETCDClient

func CreateETCDClient(conf types.ETCDConf) (client.Client, error)

CreateETCDClient 创建etcd客户端

func HandleError

func HandleError(err error) error

HandleError 处理错误

Types

type Mutex

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

A Mutex is a mutual exclusion lock which is distributed across a cluster.

func New

func New(key string, ttl int, c client.Client) *Mutex

New creates a Mutex with the given key which must be the same across the cluster nodes.

func (*Mutex) Lock

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

Lock locks m. If the lock is already in use, the calling goroutine blocks until the mutex is available.

func (*Mutex) Unlock

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

Unlock unlocks m. It is a run-time error if m is not locked on entry to Unlock.

A locked Mutex is not associated with a particular goroutine. It is allowed for one goroutine to lock a Mutex and then arrange for another goroutine to unlock it.