Documentation ¶
Index ¶
- Constants
- type Client
- func (client *Client) ConnectStatus() error
- func (client *Client) GetCount(ctx context.Context, prefix string) (int64, error)
- func (client *Client) GetFirstKey(ctx context.Context, prefix string) (string, error)
- func (client *Client) GetPrefix(ctx context.Context, prefix string) (map[string][]byte, error)
- func (client *Client) GetPrefixLimit(ctx context.Context, key string, limit int64) (map[string][]byte, error)
- func (client *Client) GetValue(ctx context.Context, key string) ([]byte, error)
- func (client *Client) NewRegistry() *Registry
- func (client *Client) NewWatch(key string) (*Watcher, error)
- func (client *Client) NewWatchWithPrefixKey(prefixKey string) (*Watcher, error)
- func (client *Client) PutNotExist(ctx context.Context, key, value string) ([]byte, error)
- func (client *Client) Transfer(from string, to string, value string) (bool, error)
- func (client *Client) Update(ctx context.Context, key, value, oldValue string) error
- type Event
- type Option
- type Options
- type Registry
- type Watcher
Constants ¶
View Source
const ( KeyCreate = iota KeyUpdate KeyDelete )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
func (*Client) ConnectStatus ¶
func (*Client) GetFirstKey ¶
func (*Client) GetPrefixLimit ¶
func (*Client) NewRegistry ¶
func (*Client) NewWatchWithPrefixKey ¶
func (*Client) PutNotExist ¶
put a key not exist
type Options ¶
type Options struct { Endpoints []string Timeout int BasicAuth bool Username string Password string CertFile string KeyFile string CaCert string }
func NewOptions ¶
func (*Options) BuildConfig ¶
type Registry ¶
func (*Registry) Deregister ¶
Click to show internal directories.
Click to hide internal directories.