Versions in this module Expand all Collapse all v1 v1.0.0 Dec 5, 2022 Changes in this version + type Client struct + func NewClient(config *Config, options ...gohbase.Option) *Client + func NewRawClient(config *Config, options ...gohbase.Option) *Client + func (c *Client) AddHook(hookFn HookFunc) + func (c *Client) Append(ctx context.Context, table string, key string, ...) (*hrpc.Result, error) + func (c *Client) Close() error + func (c *Client) Delete(ctx context.Context, table string, key string, ...) (*hrpc.Result, error) + func (c *Client) Get(ctx context.Context, table, key []byte, options ...func(hrpc.Call) error) (result *hrpc.Result, err error) + func (c *Client) GetStr(ctx context.Context, table, key string, options ...func(hrpc.Call) error) (result *hrpc.Result, err error) + func (c *Client) Increment(ctx context.Context, table string, key string, ...) (int64, error) + func (c *Client) IncrementSingle(ctx context.Context, table string, key string, family string, qualifier string, ...) (int64, error) + func (c *Client) Ping(ctx context.Context) (err error) + func (c *Client) PutStr(ctx context.Context, table string, key string, ...) (*hrpc.Result, error) + func (c *Client) Scan(ctx context.Context, table []byte, options ...func(hrpc.Call) error) (scanner hrpc.Scanner, err error) + func (c *Client) ScanAll(ctx context.Context, table []byte, options ...func(hrpc.Call) error) (results []*hrpc.Result, err error) + func (c *Client) ScanRange(ctx context.Context, table, startRow, stopRow []byte, ...) (scanner hrpc.Scanner, err error) + func (c *Client) ScanRangeStr(ctx context.Context, table, startRow, stopRow string, ...) (hrpc.Scanner, error) + func (c *Client) ScanStr(ctx context.Context, table string, options ...func(hrpc.Call) error) (hrpc.Scanner, error) + func (c *Client) ScanStrAll(ctx context.Context, table string, options ...func(hrpc.Call) error) ([]*hrpc.Result, error) + type Config struct + EffectiveUser string + FlushInterval xtime.Duration + RPCQueueSize int + RegionLookupTimeout xtime.Duration + RegionReadTimeout xtime.Duration + TestRowKey string + Zookeeper *ZKConfig + type HookFunc func(ctx context.Context, call hrpc.Call, customName string) func(err error) + func MetricsHook(config *Config) HookFunc + func NewSlowLogHook(threshold time.Duration) HookFunc + func TraceHook(component, instance string) HookFunc + type ZKConfig struct + Addrs []string + Root string + Timeout xtime.Duration
Go to main page