etcd_v3

Documentation

Index

• Variables
• func Close()
• func Compact(rev int64, opts ...clientv3.CompactOption) (*clientv3.CompactResponse, error)
• func Delete(key string) (int64, error)
• func DeleteWithPrefix(prefix string) (int64, error)
• func Get(key string) (string, error)
• func GetWithPrefix(prefix string) (map[string]string, error)
• func GrantLease(timeout int64) (clientv3.LeaseID, error)
• func Init(endpoint string) error
• func KeepAliveLease(leaseID clientv3.LeaseID) (<-chan *clientv3.LeaseKeepAliveResponse, error)
• func Put(key string, value string) error
• func PutWithLease(key string, value string, leaseID clientv3.LeaseID) error
• func Watch(key string) clientv3.WatchChan
• func WatchLoop(rch clientv3.WatchChan, cb WatchCallback)
• func WatchWithPrefix(prefix string) clientv3.WatchChan
• type ErrNotFoundKey
  • func (e ErrNotFoundKey) Error() string
• type WatchCallback

Variables

var (
	Endpoint string = "ip:12379"
)

Functions

func Close

func Close()

func Compact

func Compact(rev int64, opts ...clientv3.CompactOption) (*clientv3.CompactResponse, error)

//////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

func Delete

func Delete(key string) (int64, error)

func DeleteWithPrefix

func DeleteWithPrefix(prefix string) (int64, error)

func Get

func Get(key string) (string, error)

func GetWithPrefix

func GetWithPrefix(prefix string) (map[string]string, error)

func GrantLease

func GrantLease(timeout int64) (clientv3.LeaseID, error)

////////////////////////////////////////////////////////////////////////////////////////////////////////////////////// minimum lease TTL is 5-second

func Init

func Init(endpoint string) error

func KeepAliveLease

func KeepAliveLease(leaseID clientv3.LeaseID) (<-chan *clientv3.LeaseKeepAliveResponse, error)

func Put

func Put(key string, value string) error

func PutWithLease

func PutWithLease(key string, value string, leaseID clientv3.LeaseID) error

func Watch

func Watch(key string) clientv3.WatchChan

func WatchLoop

func WatchLoop(rch clientv3.WatchChan, cb WatchCallback)

func WatchWithPrefix

func WatchWithPrefix(prefix string) clientv3.WatchChan

Types

type ErrNotFoundKey

type ErrNotFoundKey struct {
	Key string
}

func (ErrNotFoundKey) Error

func (e ErrNotFoundKey) Error() string

type WatchCallback

type WatchCallback func(ev *clientv3.Event)