Versions in this module Expand all Collapse all v0 v0.1.0 Mar 6, 2021 Changes in this version + var ErrCannotFindRegion = errors.New("cannot find region for the rpc") + var ErrClientClosed = errors.New("client is closed") + var TableNotFound = errors.New("table not found") + type AdminClient interface + ClusterStatus func() (*pb.ClusterStatus, error) + CreateSnapshot func(t *hrpc.Snapshot) error + CreateTable func(t *hrpc.CreateTable) error + DeleteSnapshot func(t *hrpc.Snapshot) error + DeleteTable func(t *hrpc.DeleteTable) error + DisableTable func(t *hrpc.DisableTable) error + EnableTable func(t *hrpc.EnableTable) error + ListSnapshots func(t *hrpc.ListSnapshots) ([]*pb.SnapshotDescription, error) + ListTableNames func(t *hrpc.ListTableNames) ([]*pb.TableName, error) + MoveRegion func(mr *hrpc.MoveRegion) error + RestoreSnapshot func(t *hrpc.Snapshot) error + SetBalancer func(sb *hrpc.SetBalancer) (bool, error) + func NewAdminClient(zkquorum string, options ...Option) AdminClient + type Client interface + Append func(a *hrpc.Mutate) (*hrpc.Result, error) + CheckAndMutate func(c *hrpc.CheckAndMutate) (bool, *hrpc.Result, 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 CompressionCodec(codec string) Option + 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)
Go to main page