hbase

package

v0.0.0-...-26e1b9e Latest Latest Go to latest Published: Aug 5, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitee.com/peyton1991/kuat

Documentation ¶

Index ¶

type Client
- func NewClient(config *Config, options ...gohbase.Option) *Client
- func NewRawClient(config *Config, options ...gohbase.Option) *Client
type Config
type HookFunc
type ZKConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Client ¶

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

func NewClient ¶

func NewClient(config *Config, options ...gohbase.Option) *Client

func NewRawClient ¶

func NewRawClient(config *Config, options ...gohbase.Option) *Client

func (*Client) AddHook ¶

func (c *Client) AddHook(hookFn HookFunc)

func (*Client) Append ¶

func (c *Client) Append(ctx context.Context, table string, key string, values map[string]map[string][]byte, options ...func(hrpc.Call) error) (*hrpc.Result, error)

Append do a append command.

func (*Client) Close ¶

func (c *Client) Close() error

Close close client.

func (*Client) Delete ¶

func (c *Client) Delete(ctx context.Context, table string, key string, values map[string]map[string][]byte, options ...func(hrpc.Call) error) (*hrpc.Result, error)

func (*Client) Get ¶

func (c *Client) Get(ctx context.Context, table, key []byte, options ...func(hrpc.Call) error) (result *hrpc.Result, err error)

Get get result for the given table and row key. NOTE: if err != nil then result != nil, if result not exists result.Cells length is 0

func (*Client) GetStr ¶

func (c *Client) GetStr(ctx context.Context, table, key string, options ...func(hrpc.Call) error) (result *hrpc.Result, err error)

GetStr do a get command. NOTE: if err != nil then result != nil, if result not exists result.Cells length is 0

func (*Client) Increment ¶

func (c *Client) Increment(ctx context.Context, table string, key string, values map[string]map[string][]byte, options ...func(hrpc.Call) error) (int64, error)

Increment the given values in HBase under the given table and key.

func (*Client) IncrementSingle ¶

func (c *Client) IncrementSingle(ctx context.Context, table string, key string, family string, qualifier string, amount int64, options ...func(hrpc.Call) error) (int64, error)

IncrementSingle increment the given value by amount in HBase under the given table, key, family and qualifier.

func (*Client) Ping ¶

func (c *Client) Ping(ctx context.Context) (err error)

Ping ping.

func (*Client) PutStr ¶

func (c *Client) PutStr(ctx context.Context, table string, key string, values map[string]map[string][]byte, options ...func(hrpc.Call) error) (*hrpc.Result, error)

PutStr insert the given family-column-values in the given row key of the given table.

func (*Client) Scan ¶

func (c *Client) Scan(ctx context.Context, table []byte, options ...func(hrpc.Call) error) (scanner hrpc.Scanner, err error)

Scan do a scan command.

func (*Client) ScanAll ¶

func (c *Client) ScanAll(ctx context.Context, table []byte, options ...func(hrpc.Call) error) (results []*hrpc.Result, err error)

func (*Client) ScanRange ¶

func (c *Client) ScanRange(ctx context.Context, table, startRow, stopRow []byte, options ...func(hrpc.Call) error) (scanner hrpc.Scanner, err error)

ScanRange get a scanner for the given table and key range. The range is half-open, i.e. [startRow; stopRow[ -- stopRow is not included in the range.

func (*Client) ScanRangeStr ¶

func (c *Client) ScanRangeStr(ctx context.Context, table, startRow, stopRow string, options ...func(hrpc.Call) error) (hrpc.Scanner, error)

ScanRangeStr get a scanner for the given table and key range. The range is half-open, i.e. [startRow; stopRow[ -- stopRow is not included in the range.

type Config ¶

type Config struct {
	Zookeeper          *ZKConfig
	RpcQueenSize       int
	FlushInterval      int
	EffectiveUser      string
	ReginLookupTimeout int
	ReginReadTimeout   int
	TestRowKey         string
}

type HookFunc ¶

type HookFunc func(ctx context.Context, call hrpc.Call, customName string) func(err error)

func HBaseTrace ¶

func HBaseTrace(component, instance string) HookFunc

func MetricsHook ¶

func MetricsHook(config *Config) HookFunc

func NewSlowLogHook ¶

func NewSlowLogHook(threshold time.Duration) HookFunc

type ZKConfig ¶

type ZKConfig struct {
	Root    string
	Addrs   []string
	Timeout int
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL