Versions in this module Expand all Collapse all v1 v1.0.1 May 12, 2022 v1.0.0 May 12, 2022 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) + RestoreSnapshot func(t *hrpc.Snapshot) 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 Auth(auth string) Option + 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