client

type Client struct {
	InternalClient
	KvClient
	LockerClient
	// contains filtered or unexported fields
}

type Conn interface {
	ReadOnly() (*grpc.ClientConn, error)
	WriteOnly() (*grpc.ClientConn, error)
	Close() error
}

type InternalClient interface {
	AppendCluster(ctx context.Context, serverID string, peerAddr string, voter bool) error
	LeaderMonitor(ctx context.Context, recv *chan bool) error
}

type KvClient interface {
	Set(ctx context.Context, key, value []byte, ttl uint32, namespace *string) error
	Get(ctx context.Context, key []byte, namespace *string) (*Value, error)
	PrefixScan(ctx context.Context, prefix []byte, offset, limit uint64, reg, namespace *string) ([]*Value, error)
	TrySet(ctx context.Context, key, value []byte, ttl uint32, namespace *string) error
	Delete(ctx context.Context, key []byte, namespace *string) error
	Watch(ctx context.Context, watcher *Watcher) error
}

type LockerClient interface {
	Lock(ctx context.Context, lockID string, ttl int64) error
	Unlock(ctx context.Context, lockID string) error
	TryLock(ctx context.Context, lockID string, ttl, deadline int64) error
}

type Value struct {
	Data []byte
	TTL  uint32
}

type WatchValue struct {
	Timestamp int64
	Data      []byte
	// contains filtered or unexported fields
}

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

type WatcherOption func(*Watcher)