Versions in this module Expand all Collapse all v1 v1.0.1 Feb 27, 2025 Changes in this version + type MockAdminClient struct + func NewMockAdminClient(ctrl *gomock.Controller) *MockAdminClient + func (m *MockAdminClient) ClusterStatus() (*pb.ClusterStatus, error) + func (m *MockAdminClient) CreateSnapshot(arg0 *hrpc.Snapshot) error + func (m *MockAdminClient) CreateTable(arg0 *hrpc.CreateTable) error + func (m *MockAdminClient) DeleteSnapshot(arg0 *hrpc.Snapshot) error + func (m *MockAdminClient) DeleteTable(arg0 *hrpc.DeleteTable) error + func (m *MockAdminClient) DisableTable(arg0 *hrpc.DisableTable) error + func (m *MockAdminClient) EXPECT() *MockAdminClientMockRecorder + func (m *MockAdminClient) EnableTable(arg0 *hrpc.EnableTable) error + func (m *MockAdminClient) ListSnapshots(arg0 *hrpc.ListSnapshots) ([]*pb.SnapshotDescription, error) + func (m *MockAdminClient) ListTableNames(arg0 *hrpc.ListTableNames) ([]*pb.TableName, error) + func (m *MockAdminClient) MoveRegion(arg0 *hrpc.MoveRegion) error + func (m *MockAdminClient) RestoreSnapshot(arg0 *hrpc.Snapshot) error + func (m *MockAdminClient) SetBalancer(arg0 *hrpc.SetBalancer) (bool, error) + type MockAdminClientMockRecorder struct + func (mr *MockAdminClientMockRecorder) ClusterStatus() *gomock.Call + func (mr *MockAdminClientMockRecorder) CreateSnapshot(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) CreateTable(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) DeleteSnapshot(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) DeleteTable(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) DisableTable(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) EnableTable(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) ListSnapshots(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) ListTableNames(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) MoveRegion(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) RestoreSnapshot(arg0 any) *gomock.Call + func (mr *MockAdminClientMockRecorder) SetBalancer(arg0 any) *gomock.Call + type MockCall struct + func NewMockCall(ctrl *gomock.Controller) *MockCall + func (m *MockCall) Context() context.Context + func (m *MockCall) Description() string + func (m *MockCall) EXPECT() *MockCallMockRecorder + func (m *MockCall) Key() []byte + func (m *MockCall) Name() string + func (m *MockCall) NewResponse() protoreflect.ProtoMessage + func (m *MockCall) Region() hrpc.RegionInfo + func (m *MockCall) ResultChan() chan hrpc.RPCResult + func (m *MockCall) SetRegion(arg0 hrpc.RegionInfo) + func (m *MockCall) Table() []byte + func (m *MockCall) ToProto() protoreflect.ProtoMessage + type MockCallMockRecorder struct + func (mr *MockCallMockRecorder) Context() *gomock.Call + func (mr *MockCallMockRecorder) Description() *gomock.Call + func (mr *MockCallMockRecorder) Key() *gomock.Call + func (mr *MockCallMockRecorder) Name() *gomock.Call + func (mr *MockCallMockRecorder) NewResponse() *gomock.Call + func (mr *MockCallMockRecorder) Region() *gomock.Call + func (mr *MockCallMockRecorder) ResultChan() *gomock.Call + func (mr *MockCallMockRecorder) SetRegion(arg0 any) *gomock.Call + func (mr *MockCallMockRecorder) Table() *gomock.Call + func (mr *MockCallMockRecorder) ToProto() *gomock.Call + type MockClient struct + func NewMockClient(ctrl *gomock.Controller) *MockClient + func (m *MockClient) Append(arg0 *hrpc.Mutate) (*hrpc.Result, error) + func (m *MockClient) CacheRegions(arg0 []byte) error + func (m *MockClient) CheckAndPut(arg0 *hrpc.Mutate, arg1, arg2 string, arg3 []byte) (bool, error) + func (m *MockClient) Close() + func (m *MockClient) Delete(arg0 *hrpc.Mutate) (*hrpc.Result, error) + func (m *MockClient) EXPECT() *MockClientMockRecorder + func (m *MockClient) Get(arg0 *hrpc.Get) (*hrpc.Result, error) + func (m *MockClient) Increment(arg0 *hrpc.Mutate) (int64, error) + func (m *MockClient) Put(arg0 *hrpc.Mutate) (*hrpc.Result, error) + func (m *MockClient) Scan(arg0 *hrpc.Scan) hrpc.Scanner + func (m *MockClient) SendBatch(arg0 context.Context, arg1 []hrpc.Call) ([]hrpc.RPCResult, bool) + type MockClientMockRecorder struct + func (mr *MockClientMockRecorder) Append(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) CacheRegions(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) CheckAndPut(arg0, arg1, arg2, arg3 any) *gomock.Call + func (mr *MockClientMockRecorder) Close() *gomock.Call + func (mr *MockClientMockRecorder) Delete(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) Get(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) Increment(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) Put(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) Scan(arg0 any) *gomock.Call + func (mr *MockClientMockRecorder) SendBatch(arg0, arg1 any) *gomock.Call + type MockConn struct + func NewMockConn(ctrl *gomock.Controller) *MockConn + func (m *MockConn) Close() error + func (m *MockConn) EXPECT() *MockConnMockRecorder + func (m *MockConn) LocalAddr() net.Addr + func (m *MockConn) Read(arg0 []byte) (int, error) + func (m *MockConn) RemoteAddr() net.Addr + func (m *MockConn) SetDeadline(arg0 time.Time) error + func (m *MockConn) SetReadDeadline(arg0 time.Time) error + func (m *MockConn) SetWriteDeadline(arg0 time.Time) error + func (m *MockConn) Write(arg0 []byte) (int, error) + type MockConnMockRecorder struct + func (mr *MockConnMockRecorder) Close() *gomock.Call + func (mr *MockConnMockRecorder) LocalAddr() *gomock.Call + func (mr *MockConnMockRecorder) Read(arg0 any) *gomock.Call + func (mr *MockConnMockRecorder) RemoteAddr() *gomock.Call + func (mr *MockConnMockRecorder) SetDeadline(arg0 any) *gomock.Call + func (mr *MockConnMockRecorder) SetReadDeadline(arg0 any) *gomock.Call + func (mr *MockConnMockRecorder) SetWriteDeadline(arg0 any) *gomock.Call + func (mr *MockConnMockRecorder) Write(arg0 any) *gomock.Call + type MockRPCClient struct + func NewMockRPCClient(ctrl *gomock.Controller) *MockRPCClient + func (m *MockRPCClient) EXPECT() *MockRPCClientMockRecorder + func (m *MockRPCClient) SendRPC(arg0 hrpc.Call) (protoreflect.ProtoMessage, error) + type MockRPCClientMockRecorder struct + func (mr *MockRPCClientMockRecorder) SendRPC(arg0 any) *gomock.Call
Go to main page