client

Jan 3, 2024

Changes in this version

+ func BString(b []byte) string

+ func MaxOpenConn() int64

+ func SetMaxOpenConn(size int64)

+ type BalancerConn struct

+ ID string

+ func (c *BalancerConn) Key() string

+ func (c *BalancerConn) Value() *grpc.ClientConn

+ type ConnectionManager struct

+ func NewConnectionManager(ctx context.Context, endpoint string, maxConn int, opts ...grpc.DialOption) (*ConnectionManager, error)

+ func (m *ConnectionManager) Alloc() (*grpc.ClientConn, error)

+ func (m *ConnectionManager) Close() error

+ func (m *ConnectionManager) Target() string

type InternalClient

+ Snapshot func(ctx context.Context, serverPath *string) error

type Value

+ Key []byte

Nov 9, 2023

Changes in this version

+ func GrpcPoolSize() int64

+ func NewLeaderMonitorReceiver() *chan bool

+ func SetGrpcPoolSize(size int64)

Sep 7, 2023

Changes in this version

+ type GrpcPool struct

+ func NewGrpcPool(ctx context.Context, endpoint string, psize int, opts ...grpc.DialOption) (*GrpcPool, error)

+ func (p *GrpcPool) Alloc() (*GrpcPoolConn, error)

+ func (p *GrpcPool) Close() error

+ func (p *GrpcPool) Free(c *GrpcPoolConn)

+ func (p *GrpcPool) Target() string

+ type GrpcPoolConn struct

+ ID string

+ func (c *GrpcPoolConn) Close() error

+ func (c *GrpcPoolConn) Release()

Aug 5, 2023

Changes in this version

type KvClient

+ WatchPrefix func(ctx context.Context, watcher *Watcher) error

Aug 5, 2023

Changes in this version

+ type MutexLock struct

+ func NewMutexLock(ctx context.Context, client LockerClient, ttl int32, assetID string) *MutexLock

+ func (l *MutexLock) AssetID(assetID string)

+ func (l *MutexLock) Lock() error

+ func (l *MutexLock) TryLock(deadline time.Time) error

+ func (l *MutexLock) Unlock() error

type WatchValue

+ Key []byte

+ Value []byte

type WatcherOption

+ func WatchWithIgnoreErrors() WatcherOption

+ func WatchWithPrefix() WatcherOption

Jul 27, 2023

Changes in this version

type WatchValue

+ TTL uint32

Jun 20, 2023

Changes in this version

+ const DefaultWatchBufSize

+ var ErrWatcherClosed = errors.New("watcher has closed")

+ func LockID() string

+ func Namespace(s string) *string

+ type Client struct

+ func New(ctx context.Context, endpoints []string, syncConn bool) (*Client, error)

+ func (c *Client) Close() error

+ type Conn interface

+ Close func() error

+ ReadOnly func() (*grpc.ClientConn, error)

+ WriteOnly func() (*grpc.ClientConn, error)

+ func NewClientConn(ctx context.Context, endpoints []string, syncConn bool) (Conn, error)

+ type InternalClient interface

+ AppendCluster func(ctx context.Context, serverID string, peerAddr string, voter bool) error

+ LeaderMonitor func(ctx context.Context, recv *chan bool) error

+ type KvClient interface

+ Delete func(ctx context.Context, key []byte, namespace *string) error

+ Get func(ctx context.Context, key []byte, namespace *string) (*Value, error)

+ PrefixScan func(ctx context.Context, prefix []byte, offset, limit uint64, ...) ([]*Value, error)

+ Set func(ctx context.Context, key, value []byte, ttl uint32, namespace *string) error

+ TrySet func(ctx context.Context, key, value []byte, ttl uint32, namespace *string) error

+ Watch func(ctx context.Context, watcher *Watcher) error

+ type LockerClient interface

+ Lock func(ctx context.Context, lockID string, ttl int64) error

+ TryLock func(ctx context.Context, lockID string, ttl, deadline int64) error

+ Unlock func(ctx context.Context, lockID string) error

+ type Value struct

+ Data []byte

+ TTL uint32

+ type WatchValue struct

+ Data []byte

+ Timestamp int64

+ type Watcher struct

+ func NewWatcher(key []byte, ignoreErrors bool, opts ...WatcherOption) *Watcher

+ func (w *Watcher) Close() error

+ func (w *Watcher) Notify() (chan *WatchValue, error)

+ type WatcherOption func(*Watcher)

+ func WatchWithBufSize(bufSize uint32) WatcherOption

+ func WatchWithNamespace(namespace *string) WatcherOption