etcdsdk

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

type BaseAPI interface {
	NewLeaseID(ttl int) (int64, error)
	KeepLeaseID(leaseID int64) error

	PutWithLease(kv KeyValue, leaseID int64) (*KeyValue, error)
	PutWithTTL(kv KeyValue, ttl int) (*KeyValue, error)
	Put(kv KeyValue) (*KeyValue, error)

	Get(key string) (*KeyValue, error)
	GetWithChild(key string) ([]KeyValue, error)

	Del(key string) error
	Watch(key string) <-chan WatchEvent

	Lock(ctx context.Context, key string) error
	Ulock(ctx context.Context, key string) error
}

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

type DBAPI interface {
	NewTable(name string) (TableAPI, error)
	DelTable(name string) error
}

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

type EVENT_TYPE int

type KeyValue struct {
	Key     string
	Value   []byte
	Version int64
}

type TableAPI interface {
	Insert(key string, value []byte) error
	Delete(key string) error
	Update(key string, value []byte) error

	Query() ([]KeyValue, error)
	QueryKey(key string) (*KeyValue, error)
	Watch() <-chan WatchItem
}

type WatchEvent struct {
	Event EVENT_TYPE
	KeyValue
}

type WatchItem struct {
	Event EVENT_TYPE
	KeyValue
}