client

Documentation

Index

• Constants
• Variables
• type KeepAliveEventListener
• type KeyValue
• type LeaseOpBuild
• type Lock
  • func (l *Lock) Mutex() *concurrency.Mutex
  • func (l *Lock) Session() *concurrency.Session
  • func (l *Lock) UnLock() error
• type SortOrder
• type SortTarget
• type TxnBuild
• type WatchChannelEventListener

Constants

const (
	DEFAULT_DIAL_TIMEOUT  = 3 * time.Second
	DEFAULT_READ_TIMEOUT  = 3 * time.Second
	DEFAULT_WRITE_TIMEOUT = 3 * time.Second
	DATA_TTL              = 1800
)

const DEFAULT_LOCK_TTL = 60

const LEASE_PREFIX = "/etcd4go-lease/#lease/_%s"

const LOCK_PREFIX = "/etcd4go-lock/#lock/_%s"

Variables

var EtcdClient = etcdClient{}

var LockByOther = lockError{"lock by other"}

var LockError = lockError{"lock error"}

var NotFoundKeyError = etcdError{"NotFoundKey"}

var SortMode = sortMode{}

Types

type KeepAliveEventListener

type KeepAliveEventListener func(lease clientv3.LeaseID) error

type KeyValue

type KeyValue struct {
	Key   string
	Value string
}

type LeaseOpBuild

type LeaseOpBuild func(leaseID clientv3.LeaseID) ([]clientv3.Op, string, error)

LeaseOpBuild return clientv3.Op[], string to description of lease, error if raise error

type Lock

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

func (*Lock) Mutex

func (l *Lock) Mutex() *concurrency.Mutex

func (*Lock) Session

func (l *Lock) Session() *concurrency.Session

func (*Lock) UnLock

func (l *Lock) UnLock() error

UnLock You should invoke Unlock function to release lock resources in defer segment

type SortOrder

type SortOrder clientv3.SortOrder

const (
	SortNone    SortOrder = SortOrder(clientv3.SortNone)
	SortAscend  SortOrder = SortOrder(clientv3.SortAscend)
	SortDescend SortOrder = SortOrder(clientv3.SortDescend)
)

type SortTarget

type SortTarget clientv3.SortTarget

const (
	SortByKey            SortTarget = SortTarget(clientv3.SortByKey)
	SortByVersion        SortTarget = SortTarget(clientv3.SortByVersion)
	SortByCreateRevision SortTarget = SortTarget(clientv3.SortByCreateRevision)
	SortByModRevision    SortTarget = SortTarget(clientv3.SortByModRevision)
	SortByValue          SortTarget = SortTarget(clientv3.SortByValue)
)

type TxnBuild

type TxnBuild func(txn clientv3.Txn, leaseID clientv3.LeaseID) (clientv3.Txn, string, error)

TxnBuild return clientv3.Op[], string to description of lease, error if raise error

type WatchChannelEventListener

type WatchChannelEventListener func(event *clientv3.Event)