xhbase

Documentation

Index

• type Client
  • func NewClient(zkquorum string, options ...gohbase.Option) *Client
  • func (c *Client) Append(ctx context.Context, a *hrpc.Mutate) (*hrpc.Result, error)
  • func (c *Client) Close()
  • func (c *Client) Delete(ctx context.Context, d *hrpc.Mutate) (*hrpc.Result, error)
  • func (c *Client) Get(ctx context.Context, g *hrpc.Get) (*hrpc.Result, error)
  • func (c *Client) Increment(ctx context.Context, i *hrpc.Mutate) (int64, error)
  • func (c *Client) Put(ctx context.Context, p *hrpc.Mutate) (*hrpc.Result, error)
  • func (c *Client) Scan(ctx context.Context, s *hrpc.Scan) ([]*hrpc.Result, error)

Types

type Client

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

func NewClient

func NewClient(zkquorum string, options ...gohbase.Option) *Client

func (*Client) Append

func (c *Client) Append(ctx context.Context, a *hrpc.Mutate) (*hrpc.Result, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) Delete

func (c *Client) Delete(ctx context.Context, d *hrpc.Mutate) (*hrpc.Result, error)

func (*Client) Get

func (c *Client) Get(ctx context.Context, g *hrpc.Get) (*hrpc.Result, error)

func (*Client) Increment

func (c *Client) Increment(ctx context.Context, i *hrpc.Mutate) (int64, error)

func (*Client) Put

func (c *Client) Put(ctx context.Context, p *hrpc.Mutate) (*hrpc.Result, error)

func (*Client) Scan

func (c *Client) Scan(ctx context.Context, s *hrpc.Scan) ([]*hrpc.Result, error)