Versions in this module Expand all Collapse all v1 v1.0.0 Mar 2, 2019 Changes in this version + var ErrClientClosed = errors.New("client is closed") + var ErrConnotFindRegion = errors.New("cannot find region for the rpc") + var ErrRegionUnavailable = errors.New("region unavailable") + var TableNotFound = errors.New("table not found") + type AdminClient interface + ClusterStatus func() (*pb.ClusterStatus, error) + CreateTable func(t *hrpc.CreateTable) error + DeleteTable func(t *hrpc.DeleteTable) error + DisableTable func(t *hrpc.DisableTable) error + EnableTable func(t *hrpc.EnableTable) error + func NewAdminClient(zkquorum string, options ...Option) AdminClient + type Client interface + Append func(a *hrpc.Mutate) (*hrpc.Result, error) + CheckAndPut func(p *hrpc.Mutate, family string, qualifier string, expectedValue []byte) (bool, error) + Close func() + Delete func(d *hrpc.Mutate) (*hrpc.Result, error) + Get func(g *hrpc.Get) (*hrpc.Result, error) + Increment func(i *hrpc.Mutate) (int64, error) + Put func(p *hrpc.Mutate) (*hrpc.Result, error) + Scan func(s *hrpc.Scan) hrpc.Scanner + func NewClient(zkquorum string, options ...Option) Client + type Option func(*client) + func EffectiveUser(user string) Option + func FlushInterval(interval time.Duration) Option + func RegionLookupTimeout(to time.Duration) Option + func RegionReadTimeout(to time.Duration) Option + func RpcQueueSize(size int) Option + func ZookeeperRoot(root string) Option + func ZookeeperTimeout(to time.Duration) Option + type RPCClient interface + SendRPC func(rpc hrpc.Call) (proto.Message, error)