meta

package

Go to main page

Versions in this module

v0

v0.7.0

Apr 29, 2024

Changes in this version

+ var File_greptime_v1_meta_procedure_proto protoreflect.FileDescriptor

+ var File_greptime_v1_meta_region_proto protoreflect.FileDescriptor

+ var ProcedureService_ServiceDesc = grpc.ServiceDesc

+ var ProcedureStatus_name = map[int32]string

+ var ProcedureStatus_value = map[string]int32

+ func RegisterProcedureServiceServer(s grpc.ServiceRegistrar, srv ProcedureServiceServer)

type ClusterClient

+ MetasrvPeers func(ctx context.Context, in *MetasrvPeersRequest, opts ...grpc.CallOption) (*MetasrvPeersResponse, error)

type ClusterServer

+ MetasrvPeers func(context.Context, *MetasrvPeersRequest) (*MetasrvPeersResponse, error)

+ type CreateDatabaseTask struct

+ CreateDatabase *v1.CreateDatabaseExpr

+ func (*CreateDatabaseTask) Descriptor() ([]byte, []int)

+ func (*CreateDatabaseTask) ProtoMessage()

+ func (x *CreateDatabaseTask) GetCreateDatabase() *v1.CreateDatabaseExpr

+ func (x *CreateDatabaseTask) ProtoReflect() protoreflect.Message

+ func (x *CreateDatabaseTask) Reset()

+ func (x *CreateDatabaseTask) String() string

+ type CreateFlowTask struct

+ CreateFlowTask *v1.CreateFlowTaskExpr

+ func (*CreateFlowTask) Descriptor() ([]byte, []int)

+ func (*CreateFlowTask) ProtoMessage()

+ func (x *CreateFlowTask) GetCreateFlowTask() *v1.CreateFlowTaskExpr

+ func (x *CreateFlowTask) ProtoReflect() protoreflect.Message

+ func (x *CreateFlowTask) Reset()

+ func (x *CreateFlowTask) String() string

+ type DdlTaskRequest struct

+ Header *RequestHeader

+ Task isDdlTaskRequest_Task

+ func (*DdlTaskRequest) Descriptor() ([]byte, []int)

+ func (*DdlTaskRequest) ProtoMessage()

+ func (m *DdlTaskRequest) GetTask() isDdlTaskRequest_Task

+ func (x *DdlTaskRequest) GetAlterTableTask() *AlterTableTask

+ func (x *DdlTaskRequest) GetAlterTableTasks() *AlterTableTasks

+ func (x *DdlTaskRequest) GetCreateDatabaseTask() *CreateDatabaseTask

+ func (x *DdlTaskRequest) GetCreateFlowTask() *CreateFlowTask

+ func (x *DdlTaskRequest) GetCreateTableTask() *CreateTableTask

+ func (x *DdlTaskRequest) GetCreateTableTasks() *CreateTableTasks

+ func (x *DdlTaskRequest) GetDropDatabaseTask() *DropDatabaseTask

+ func (x *DdlTaskRequest) GetDropFlowTask() *DropFlowTask

+ func (x *DdlTaskRequest) GetDropTableTask() *DropTableTask

+ func (x *DdlTaskRequest) GetDropTableTasks() *DropTableTasks

+ func (x *DdlTaskRequest) GetHeader() *RequestHeader

+ func (x *DdlTaskRequest) GetTruncateTableTask() *TruncateTableTask

+ func (x *DdlTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DdlTaskRequest) Reset()

+ func (x *DdlTaskRequest) String() string

+ type DdlTaskRequest_AlterTableTask struct

+ AlterTableTask *AlterTableTask

+ type DdlTaskRequest_AlterTableTasks struct

+ AlterTableTasks *AlterTableTasks

+ type DdlTaskRequest_CreateDatabaseTask struct

+ CreateDatabaseTask *CreateDatabaseTask

+ type DdlTaskRequest_CreateFlowTask struct

+ CreateFlowTask *CreateFlowTask

+ type DdlTaskRequest_CreateTableTask struct

+ CreateTableTask *CreateTableTask

+ type DdlTaskRequest_CreateTableTasks struct

+ CreateTableTasks *CreateTableTasks

+ type DdlTaskRequest_DropDatabaseTask struct

+ DropDatabaseTask *DropDatabaseTask

+ type DdlTaskRequest_DropFlowTask struct

+ DropFlowTask *DropFlowTask

+ type DdlTaskRequest_DropTableTask struct

+ DropTableTask *DropTableTask

+ type DdlTaskRequest_DropTableTasks struct

+ DropTableTasks *DropTableTasks

+ type DdlTaskRequest_TruncateTableTask struct

+ TruncateTableTask *TruncateTableTask

+ type DdlTaskResponse struct

+ Header *ResponseHeader

+ Pid *ProcedureId

+ TableId *TableId

+ TableIds []*TableId

+ func (*DdlTaskResponse) Descriptor() ([]byte, []int)

+ func (*DdlTaskResponse) ProtoMessage()

+ func (x *DdlTaskResponse) GetHeader() *ResponseHeader

+ func (x *DdlTaskResponse) GetPid() *ProcedureId

+ func (x *DdlTaskResponse) GetTableId() *TableId

+ func (x *DdlTaskResponse) GetTableIds() []*TableId

+ func (x *DdlTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *DdlTaskResponse) Reset()

+ func (x *DdlTaskResponse) String() string

+ type DropDatabaseTask struct

+ DropDatabase *v1.DropDatabaseExpr

+ func (*DropDatabaseTask) Descriptor() ([]byte, []int)

+ func (*DropDatabaseTask) ProtoMessage()

+ func (x *DropDatabaseTask) GetDropDatabase() *v1.DropDatabaseExpr

+ func (x *DropDatabaseTask) ProtoReflect() protoreflect.Message

+ func (x *DropDatabaseTask) Reset()

+ func (x *DropDatabaseTask) String() string

+ type DropFlowTask struct

+ DropFlowTask *v1.DropFlowTaskExpr

+ func (*DropFlowTask) Descriptor() ([]byte, []int)

+ func (*DropFlowTask) ProtoMessage()

+ func (x *DropFlowTask) GetDropFlowTask() *v1.DropFlowTaskExpr

+ func (x *DropFlowTask) ProtoReflect() protoreflect.Message

+ func (x *DropFlowTask) Reset()

+ func (x *DropFlowTask) String() string

+ type MetasrvPeersRequest struct

+ Header *RequestHeader

+ func (*MetasrvPeersRequest) Descriptor() ([]byte, []int)

+ func (*MetasrvPeersRequest) ProtoMessage()

+ func (x *MetasrvPeersRequest) GetHeader() *RequestHeader

+ func (x *MetasrvPeersRequest) ProtoReflect() protoreflect.Message

+ func (x *MetasrvPeersRequest) Reset()

+ func (x *MetasrvPeersRequest) String() string

+ type MetasrvPeersResponse struct

+ Followers []*Peer

+ Header *ResponseHeader

+ Leader *Peer

+ func (*MetasrvPeersResponse) Descriptor() ([]byte, []int)

+ func (*MetasrvPeersResponse) ProtoMessage()

+ func (x *MetasrvPeersResponse) GetFollowers() []*Peer

+ func (x *MetasrvPeersResponse) GetHeader() *ResponseHeader

+ func (x *MetasrvPeersResponse) GetLeader() *Peer

+ func (x *MetasrvPeersResponse) ProtoReflect() protoreflect.Message

+ func (x *MetasrvPeersResponse) Reset()

+ func (x *MetasrvPeersResponse) String() string

+ type MigrateRegionRequest struct

+ FromPeer uint64

+ Header *RequestHeader

+ RegionId uint64

+ ReplayTimeoutSecs uint32

+ ToPeer uint64

+ func (*MigrateRegionRequest) Descriptor() ([]byte, []int)

+ func (*MigrateRegionRequest) ProtoMessage()

+ func (x *MigrateRegionRequest) GetFromPeer() uint64

+ func (x *MigrateRegionRequest) GetHeader() *RequestHeader

+ func (x *MigrateRegionRequest) GetRegionId() uint64

+ func (x *MigrateRegionRequest) GetReplayTimeoutSecs() uint32

+ func (x *MigrateRegionRequest) GetToPeer() uint64

+ func (x *MigrateRegionRequest) ProtoReflect() protoreflect.Message

+ func (x *MigrateRegionRequest) Reset()

+ func (x *MigrateRegionRequest) String() string

+ type MigrateRegionResponse struct

+ Header *ResponseHeader

+ Pid *ProcedureId

+ func (*MigrateRegionResponse) Descriptor() ([]byte, []int)

+ func (*MigrateRegionResponse) ProtoMessage()

+ func (x *MigrateRegionResponse) GetHeader() *ResponseHeader

+ func (x *MigrateRegionResponse) GetPid() *ProcedureId

+ func (x *MigrateRegionResponse) ProtoReflect() protoreflect.Message

+ func (x *MigrateRegionResponse) Reset()

+ func (x *MigrateRegionResponse) String() string

+ type ProcedureId struct

+ Key []byte

+ func (*ProcedureId) Descriptor() ([]byte, []int)

+ func (*ProcedureId) ProtoMessage()

+ func (x *ProcedureId) GetKey() []byte

+ func (x *ProcedureId) ProtoReflect() protoreflect.Message

+ func (x *ProcedureId) Reset()

+ func (x *ProcedureId) String() string

+ type ProcedureServiceClient interface

+ Ddl func(ctx context.Context, in *DdlTaskRequest, opts ...grpc.CallOption) (*DdlTaskResponse, error)

+ Migrate func(ctx context.Context, in *MigrateRegionRequest, opts ...grpc.CallOption) (*MigrateRegionResponse, error)

+ Query func(ctx context.Context, in *QueryProcedureRequest, opts ...grpc.CallOption) (*ProcedureStateResponse, error)

+ func NewProcedureServiceClient(cc grpc.ClientConnInterface) ProcedureServiceClient

+ type ProcedureServiceServer interface

+ Ddl func(context.Context, *DdlTaskRequest) (*DdlTaskResponse, error)

+ Migrate func(context.Context, *MigrateRegionRequest) (*MigrateRegionResponse, error)

+ Query func(context.Context, *QueryProcedureRequest) (*ProcedureStateResponse, error)

+ type ProcedureStateResponse struct

+ Error string

+ Header *ResponseHeader

+ Status ProcedureStatus

+ func (*ProcedureStateResponse) Descriptor() ([]byte, []int)

+ func (*ProcedureStateResponse) ProtoMessage()

+ func (x *ProcedureStateResponse) GetError() string

+ func (x *ProcedureStateResponse) GetHeader() *ResponseHeader

+ func (x *ProcedureStateResponse) GetStatus() ProcedureStatus

+ func (x *ProcedureStateResponse) ProtoReflect() protoreflect.Message

+ func (x *ProcedureStateResponse) Reset()

+ func (x *ProcedureStateResponse) String() string

+ type ProcedureStatus int32

+ const ProcedureStatus_Done

+ const ProcedureStatus_Failed

+ const ProcedureStatus_PrepareRollback

+ const ProcedureStatus_Retrying

+ const ProcedureStatus_RollingBack

+ const ProcedureStatus_Running

+ func (ProcedureStatus) Descriptor() protoreflect.EnumDescriptor

+ func (ProcedureStatus) EnumDescriptor() ([]byte, []int)

+ func (ProcedureStatus) Type() protoreflect.EnumType

+ func (x ProcedureStatus) Enum() *ProcedureStatus

+ func (x ProcedureStatus) Number() protoreflect.EnumNumber

+ func (x ProcedureStatus) String() string

+ type QueryProcedureRequest struct

+ Header *RequestHeader

+ Pid *ProcedureId

+ func (*QueryProcedureRequest) Descriptor() ([]byte, []int)

+ func (*QueryProcedureRequest) ProtoMessage()

+ func (x *QueryProcedureRequest) GetHeader() *RequestHeader

+ func (x *QueryProcedureRequest) GetPid() *ProcedureId

+ func (x *QueryProcedureRequest) ProtoReflect() protoreflect.Message

+ func (x *QueryProcedureRequest) Reset()

+ func (x *QueryProcedureRequest) String() string

type UnimplementedClusterServer

+ func (UnimplementedClusterServer) MetasrvPeers(context.Context, *MetasrvPeersRequest) (*MetasrvPeersResponse, error)

+ type UnimplementedProcedureServiceServer struct

+ func (UnimplementedProcedureServiceServer) Ddl(context.Context, *DdlTaskRequest) (*DdlTaskResponse, error)

+ func (UnimplementedProcedureServiceServer) Migrate(context.Context, *MigrateRegionRequest) (*MigrateRegionResponse, error)

+ func (UnimplementedProcedureServiceServer) Query(context.Context, *QueryProcedureRequest) (*ProcedureStateResponse, error)

+ type UnsafeProcedureServiceServer interface

v0.4.3

Jan 22, 2024

Changes in this version

+ type AlterTableTasks struct

+ Tasks []*AlterTableTask

+ func (*AlterTableTasks) Descriptor() ([]byte, []int)

+ func (*AlterTableTasks) ProtoMessage()

+ func (x *AlterTableTasks) GetTasks() []*AlterTableTask

+ func (x *AlterTableTasks) ProtoReflect() protoreflect.Message

+ func (x *AlterTableTasks) Reset()

+ func (x *AlterTableTasks) String() string

+ type CreateTableTasks struct

+ Tasks []*CreateTableTask

+ func (*CreateTableTasks) Descriptor() ([]byte, []int)

+ func (*CreateTableTasks) ProtoMessage()

+ func (x *CreateTableTasks) GetTasks() []*CreateTableTask

+ func (x *CreateTableTasks) ProtoReflect() protoreflect.Message

+ func (x *CreateTableTasks) Reset()

+ func (x *CreateTableTasks) String() string

+ type DropTableTasks struct

+ Tasks []*DropTableTask

+ func (*DropTableTasks) Descriptor() ([]byte, []int)

+ func (*DropTableTasks) ProtoMessage()

+ func (x *DropTableTasks) GetTasks() []*DropTableTask

+ func (x *DropTableTasks) ProtoReflect() protoreflect.Message

+ func (x *DropTableTasks) Reset()

+ func (x *DropTableTasks) String() string

type SubmitDdlTaskRequest

+ func (x *SubmitDdlTaskRequest) GetAlterTableTasks() *AlterTableTasks

+ func (x *SubmitDdlTaskRequest) GetCreateTableTasks() *CreateTableTasks

+ func (x *SubmitDdlTaskRequest) GetDropTableTasks() *DropTableTasks

+ type SubmitDdlTaskRequest_AlterTableTasks struct

+ AlterTableTasks *AlterTableTasks

+ type SubmitDdlTaskRequest_CreateTableTasks struct

+ CreateTableTasks *CreateTableTasks

+ type SubmitDdlTaskRequest_DropTableTasks struct

+ DropTableTasks *DropTableTasks

type SubmitDdlTaskResponse

+ TableIds []*TableId

+ func (x *SubmitDdlTaskResponse) GetTableIds() []*TableId

v0.4.2

Dec 15, 2023

v0.4.1

Dec 14, 2023

Changes in this version

+ var RegionRole_name = map[int32]string

+ var RegionRole_value = map[string]int32

+ type GrantedRegion struct

+ RegionId uint64

+ Role RegionRole

+ func (*GrantedRegion) Descriptor() ([]byte, []int)

+ func (*GrantedRegion) ProtoMessage()

+ func (x *GrantedRegion) GetRegionId() uint64

+ func (x *GrantedRegion) GetRole() RegionRole

+ func (x *GrantedRegion) ProtoReflect() protoreflect.Message

+ func (x *GrantedRegion) Reset()

+ func (x *GrantedRegion) String() string

type RegionLease

+ CloseableRegionIds []uint64

+ func (x *RegionLease) GetCloseableRegionIds() []uint64

+ type RegionRole int32

+ const RegionRole_Follower

+ const RegionRole_Leader

+ func (RegionRole) Descriptor() protoreflect.EnumDescriptor

+ func (RegionRole) EnumDescriptor() ([]byte, []int)

+ func (RegionRole) Type() protoreflect.EnumType

+ func (x RegionRole) Enum() *RegionRole

+ func (x RegionRole) Number() protoreflect.EnumNumber

+ func (x RegionRole) String() string

type RegionStat

+ Role RegionRole

+ func (x *RegionStat) GetRole() RegionRole

type RequestHeader

+ TracingContext map[string]string

+ func (x *RequestHeader) GetTracingContext() map[string]string

v0.4.0

Sep 6, 2023

Changes in this version

type HeartbeatResponse

+ RegionLease *RegionLease

+ func (x *HeartbeatResponse) GetRegionLease() *RegionLease

type RegionLease

+ RegionIds []uint64

+ func (x *RegionLease) GetRegionIds() []uint64

type RegionStat

+ Engine string

+ func (x *RegionStat) GetEngine() string

v0.4.0-test

Oct 31, 2023

v0.3.0

Jul 20, 2023

Changes in this version

+ var Cluster_ServiceDesc = grpc.ServiceDesc

+ var DdlTaskType_name = map[int32]string

+ var DdlTaskType_value = map[string]int32

+ var DdlTask_ServiceDesc = grpc.ServiceDesc

+ var File_greptime_v1_meta_cluster_proto protoreflect.FileDescriptor

+ var File_greptime_v1_meta_common_proto protoreflect.FileDescriptor

+ var File_greptime_v1_meta_ddl_proto protoreflect.FileDescriptor

+ var File_greptime_v1_meta_heartbeat_proto protoreflect.FileDescriptor

+ var File_greptime_v1_meta_lock_proto protoreflect.FileDescriptor

+ var File_greptime_v1_meta_route_proto protoreflect.FileDescriptor

+ var File_greptime_v1_meta_store_proto protoreflect.FileDescriptor

+ var Heartbeat_ServiceDesc = grpc.ServiceDesc

+ var Lock_ServiceDesc = grpc.ServiceDesc

+ var Role_name = map[int32]string

+ var Role_value = map[string]int32

+ var Router_ServiceDesc = grpc.ServiceDesc

+ var Store_ServiceDesc = grpc.ServiceDesc

+ func RegisterClusterServer(s grpc.ServiceRegistrar, srv ClusterServer)

+ func RegisterDdlTaskServer(s grpc.ServiceRegistrar, srv DdlTaskServer)

+ func RegisterHeartbeatServer(s grpc.ServiceRegistrar, srv HeartbeatServer)

+ func RegisterLockServer(s grpc.ServiceRegistrar, srv LockServer)

+ func RegisterRouterServer(s grpc.ServiceRegistrar, srv RouterServer)

+ func RegisterStoreServer(s grpc.ServiceRegistrar, srv StoreServer)

+ type AlterTableTask struct

+ AlterTable *v1.AlterExpr

+ func (*AlterTableTask) Descriptor() ([]byte, []int)

+ func (*AlterTableTask) ProtoMessage()

+ func (x *AlterTableTask) GetAlterTable() *v1.AlterExpr

+ func (x *AlterTableTask) ProtoReflect() protoreflect.Message

+ func (x *AlterTableTask) Reset()

+ func (x *AlterTableTask) String() string

+ type AskLeaderRequest struct

+ Header *RequestHeader

+ func (*AskLeaderRequest) Descriptor() ([]byte, []int)

+ func (*AskLeaderRequest) ProtoMessage()

+ func (x *AskLeaderRequest) GetHeader() *RequestHeader

+ func (x *AskLeaderRequest) ProtoReflect() protoreflect.Message

+ func (x *AskLeaderRequest) Reset()

+ func (x *AskLeaderRequest) String() string

+ type AskLeaderResponse struct

+ Header *ResponseHeader

+ Leader *Peer

+ func (*AskLeaderResponse) Descriptor() ([]byte, []int)

+ func (*AskLeaderResponse) ProtoMessage()

+ func (x *AskLeaderResponse) GetHeader() *ResponseHeader

+ func (x *AskLeaderResponse) GetLeader() *Peer

+ func (x *AskLeaderResponse) ProtoReflect() protoreflect.Message

+ func (x *AskLeaderResponse) Reset()

+ func (x *AskLeaderResponse) String() string

+ type BatchDeleteRequest struct

+ Header *RequestHeader

+ Keys [][]byte

+ PrevKv bool

+ func (*BatchDeleteRequest) Descriptor() ([]byte, []int)

+ func (*BatchDeleteRequest) ProtoMessage()

+ func (x *BatchDeleteRequest) GetHeader() *RequestHeader

+ func (x *BatchDeleteRequest) GetKeys() [][]byte

+ func (x *BatchDeleteRequest) GetPrevKv() bool

+ func (x *BatchDeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *BatchDeleteRequest) Reset()

+ func (x *BatchDeleteRequest) String() string

+ type BatchDeleteResponse struct

+ Header *ResponseHeader

+ PrevKvs []*KeyValue

+ func (*BatchDeleteResponse) Descriptor() ([]byte, []int)

+ func (*BatchDeleteResponse) ProtoMessage()

+ func (x *BatchDeleteResponse) GetHeader() *ResponseHeader

+ func (x *BatchDeleteResponse) GetPrevKvs() []*KeyValue

+ func (x *BatchDeleteResponse) ProtoReflect() protoreflect.Message

+ func (x *BatchDeleteResponse) Reset()

+ func (x *BatchDeleteResponse) String() string

+ type BatchGetRequest struct

+ Header *RequestHeader

+ Keys [][]byte

+ func (*BatchGetRequest) Descriptor() ([]byte, []int)

+ func (*BatchGetRequest) ProtoMessage()

+ func (x *BatchGetRequest) GetHeader() *RequestHeader

+ func (x *BatchGetRequest) GetKeys() [][]byte

+ func (x *BatchGetRequest) ProtoReflect() protoreflect.Message

+ func (x *BatchGetRequest) Reset()

+ func (x *BatchGetRequest) String() string

+ type BatchGetResponse struct

+ Header *ResponseHeader

+ Kvs []*KeyValue

+ func (*BatchGetResponse) Descriptor() ([]byte, []int)

+ func (*BatchGetResponse) ProtoMessage()

+ func (x *BatchGetResponse) GetHeader() *ResponseHeader

+ func (x *BatchGetResponse) GetKvs() []*KeyValue

+ func (x *BatchGetResponse) ProtoReflect() protoreflect.Message

+ func (x *BatchGetResponse) Reset()

+ func (x *BatchGetResponse) String() string

+ type BatchPutRequest struct

+ Header *RequestHeader

+ Kvs []*KeyValue

+ PrevKv bool

+ func (*BatchPutRequest) Descriptor() ([]byte, []int)

+ func (*BatchPutRequest) ProtoMessage()

+ func (x *BatchPutRequest) GetHeader() *RequestHeader

+ func (x *BatchPutRequest) GetKvs() []*KeyValue

+ func (x *BatchPutRequest) GetPrevKv() bool

+ func (x *BatchPutRequest) ProtoReflect() protoreflect.Message

+ func (x *BatchPutRequest) Reset()

+ func (x *BatchPutRequest) String() string

+ type BatchPutResponse struct

+ Header *ResponseHeader

+ PrevKvs []*KeyValue

+ func (*BatchPutResponse) Descriptor() ([]byte, []int)

+ func (*BatchPutResponse) ProtoMessage()

+ func (x *BatchPutResponse) GetHeader() *ResponseHeader

+ func (x *BatchPutResponse) GetPrevKvs() []*KeyValue

+ func (x *BatchPutResponse) ProtoReflect() protoreflect.Message

+ func (x *BatchPutResponse) Reset()

+ func (x *BatchPutResponse) String() string

+ type ClusterClient interface

+ BatchGet func(ctx context.Context, in *BatchGetRequest, opts ...grpc.CallOption) (*BatchGetResponse, error)

+ Range func(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)

+ func NewClusterClient(cc grpc.ClientConnInterface) ClusterClient

+ type ClusterServer interface

+ BatchGet func(context.Context, *BatchGetRequest) (*BatchGetResponse, error)

+ Range func(context.Context, *RangeRequest) (*RangeResponse, error)

+ type CompareAndPutRequest struct

+ Expect []byte

+ Header *RequestHeader

+ Key []byte

+ Value []byte

+ func (*CompareAndPutRequest) Descriptor() ([]byte, []int)

+ func (*CompareAndPutRequest) ProtoMessage()

+ func (x *CompareAndPutRequest) GetExpect() []byte

+ func (x *CompareAndPutRequest) GetHeader() *RequestHeader

+ func (x *CompareAndPutRequest) GetKey() []byte

+ func (x *CompareAndPutRequest) GetValue() []byte

+ func (x *CompareAndPutRequest) ProtoReflect() protoreflect.Message

+ func (x *CompareAndPutRequest) Reset()

+ func (x *CompareAndPutRequest) String() string

+ type CompareAndPutResponse struct

+ Header *ResponseHeader

+ PrevKv *KeyValue

+ Success bool

+ func (*CompareAndPutResponse) Descriptor() ([]byte, []int)

+ func (*CompareAndPutResponse) ProtoMessage()

+ func (x *CompareAndPutResponse) GetHeader() *ResponseHeader

+ func (x *CompareAndPutResponse) GetPrevKv() *KeyValue

+ func (x *CompareAndPutResponse) GetSuccess() bool

+ func (x *CompareAndPutResponse) ProtoReflect() protoreflect.Message

+ func (x *CompareAndPutResponse) Reset()

+ func (x *CompareAndPutResponse) String() string

+ type CreateTableTask struct

+ CreateTable *v1.CreateTableExpr

+ Partitions []*Partition

+ TableInfo []byte

+ func (*CreateTableTask) Descriptor() ([]byte, []int)

+ func (*CreateTableTask) ProtoMessage()

+ func (x *CreateTableTask) GetCreateTable() *v1.CreateTableExpr

+ func (x *CreateTableTask) GetPartitions() []*Partition

+ func (x *CreateTableTask) GetTableInfo() []byte

+ func (x *CreateTableTask) ProtoReflect() protoreflect.Message

+ func (x *CreateTableTask) Reset()

+ func (x *CreateTableTask) String() string

+ type DdlTaskClient interface

+ SubmitDdlTask func(ctx context.Context, in *SubmitDdlTaskRequest, opts ...grpc.CallOption) (*SubmitDdlTaskResponse, error)

+ func NewDdlTaskClient(cc grpc.ClientConnInterface) DdlTaskClient

+ type DdlTaskServer interface

+ SubmitDdlTask func(context.Context, *SubmitDdlTaskRequest) (*SubmitDdlTaskResponse, error)

+ type DdlTaskType int32

+ const DdlTaskType_Create

+ const DdlTaskType_Drop

+ func (DdlTaskType) Descriptor() protoreflect.EnumDescriptor

+ func (DdlTaskType) EnumDescriptor() ([]byte, []int)

+ func (DdlTaskType) Type() protoreflect.EnumType

+ func (x DdlTaskType) Enum() *DdlTaskType

+ func (x DdlTaskType) Number() protoreflect.EnumNumber

+ func (x DdlTaskType) String() string

+ type DeleteRangeRequest struct

+ Header *RequestHeader

+ Key []byte

+ PrevKv bool

+ RangeEnd []byte

+ func (*DeleteRangeRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRangeRequest) ProtoMessage()

+ func (x *DeleteRangeRequest) GetHeader() *RequestHeader

+ func (x *DeleteRangeRequest) GetKey() []byte

+ func (x *DeleteRangeRequest) GetPrevKv() bool

+ func (x *DeleteRangeRequest) GetRangeEnd() []byte

+ func (x *DeleteRangeRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteRangeRequest) Reset()

+ func (x *DeleteRangeRequest) String() string

+ type DeleteRangeResponse struct

+ Deleted int64

+ Header *ResponseHeader

+ PrevKvs []*KeyValue

+ func (*DeleteRangeResponse) Descriptor() ([]byte, []int)

+ func (*DeleteRangeResponse) ProtoMessage()

+ func (x *DeleteRangeResponse) GetDeleted() int64

+ func (x *DeleteRangeResponse) GetHeader() *ResponseHeader

+ func (x *DeleteRangeResponse) GetPrevKvs() []*KeyValue

+ func (x *DeleteRangeResponse) ProtoReflect() protoreflect.Message

+ func (x *DeleteRangeResponse) Reset()

+ func (x *DeleteRangeResponse) String() string

+ type DropTableTask struct

+ DropTable *v1.DropTableExpr

+ func (*DropTableTask) Descriptor() ([]byte, []int)

+ func (*DropTableTask) ProtoMessage()

+ func (x *DropTableTask) GetDropTable() *v1.DropTableExpr

+ func (x *DropTableTask) ProtoReflect() protoreflect.Message

+ func (x *DropTableTask) Reset()

+ func (x *DropTableTask) String() string

+ type Error struct

+ Code int32

+ ErrMsg string

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (x *Error) GetCode() int32

+ func (x *Error) GetErrMsg() string

+ func (x *Error) ProtoReflect() protoreflect.Message

+ func (x *Error) Reset()

+ func (x *Error) String() string

+ type HeartbeatClient interface

+ AskLeader func(ctx context.Context, in *AskLeaderRequest, opts ...grpc.CallOption) (*AskLeaderResponse, error)

+ Heartbeat func(ctx context.Context, opts ...grpc.CallOption) (Heartbeat_HeartbeatClient, error)

+ func NewHeartbeatClient(cc grpc.ClientConnInterface) HeartbeatClient

+ type HeartbeatRequest struct

+ DurationSinceEpoch uint64

+ Header *RequestHeader

+ MailboxMessage *MailboxMessage

+ NodeEpoch uint64

+ NodeStat *NodeStat

+ Peer *Peer

+ RegionStats []*RegionStat

+ ReportInterval *TimeInterval

+ func (*HeartbeatRequest) Descriptor() ([]byte, []int)

+ func (*HeartbeatRequest) ProtoMessage()

+ func (x *HeartbeatRequest) GetDurationSinceEpoch() uint64

+ func (x *HeartbeatRequest) GetHeader() *RequestHeader

+ func (x *HeartbeatRequest) GetMailboxMessage() *MailboxMessage

+ func (x *HeartbeatRequest) GetNodeEpoch() uint64

+ func (x *HeartbeatRequest) GetNodeStat() *NodeStat

+ func (x *HeartbeatRequest) GetPeer() *Peer

+ func (x *HeartbeatRequest) GetRegionStats() []*RegionStat

+ func (x *HeartbeatRequest) GetReportInterval() *TimeInterval

+ func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatRequest) Reset()

+ func (x *HeartbeatRequest) String() string

+ type HeartbeatResponse struct

+ Header *ResponseHeader

+ MailboxMessage *MailboxMessage

+ RegionLeases []*RegionLease

+ func (*HeartbeatResponse) Descriptor() ([]byte, []int)

+ func (*HeartbeatResponse) ProtoMessage()

+ func (x *HeartbeatResponse) GetHeader() *ResponseHeader

+ func (x *HeartbeatResponse) GetMailboxMessage() *MailboxMessage

+ func (x *HeartbeatResponse) GetRegionLeases() []*RegionLease

+ func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatResponse) Reset()

+ func (x *HeartbeatResponse) String() string

+ type HeartbeatServer interface

+ AskLeader func(context.Context, *AskLeaderRequest) (*AskLeaderResponse, error)

+ Heartbeat func(Heartbeat_HeartbeatServer) error

+ type Heartbeat_HeartbeatClient interface

+ Recv func() (*HeartbeatResponse, error)

+ Send func(*HeartbeatRequest) error

+ type Heartbeat_HeartbeatServer interface

+ Recv func() (*HeartbeatRequest, error)

+ Send func(*HeartbeatResponse) error

+ type KeyValue struct

+ Key []byte

+ Value []byte

+ func (*KeyValue) Descriptor() ([]byte, []int)

+ func (*KeyValue) ProtoMessage()

+ func (x *KeyValue) GetKey() []byte

+ func (x *KeyValue) GetValue() []byte

+ func (x *KeyValue) ProtoReflect() protoreflect.Message

+ func (x *KeyValue) Reset()

+ func (x *KeyValue) String() string

+ type LockClient interface

+ Lock func(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)

+ Unlock func(ctx context.Context, in *UnlockRequest, opts ...grpc.CallOption) (*UnlockResponse, error)

+ func NewLockClient(cc grpc.ClientConnInterface) LockClient

+ type LockRequest struct

+ ExpireSecs int64

+ Header *RequestHeader

+ Name []byte

+ func (*LockRequest) Descriptor() ([]byte, []int)

+ func (*LockRequest) ProtoMessage()

+ func (x *LockRequest) GetExpireSecs() int64

+ func (x *LockRequest) GetHeader() *RequestHeader

+ func (x *LockRequest) GetName() []byte

+ func (x *LockRequest) ProtoReflect() protoreflect.Message

+ func (x *LockRequest) Reset()

+ func (x *LockRequest) String() string

+ type LockResponse struct

+ Header *ResponseHeader

+ Key []byte

+ func (*LockResponse) Descriptor() ([]byte, []int)

+ func (*LockResponse) ProtoMessage()

+ func (x *LockResponse) GetHeader() *ResponseHeader

+ func (x *LockResponse) GetKey() []byte

+ func (x *LockResponse) ProtoReflect() protoreflect.Message

+ func (x *LockResponse) Reset()

+ func (x *LockResponse) String() string

+ type LockServer interface

+ Lock func(context.Context, *LockRequest) (*LockResponse, error)

+ Unlock func(context.Context, *UnlockRequest) (*UnlockResponse, error)

+ type MailboxMessage struct

+ From string

+ Id uint64

+ Payload isMailboxMessage_Payload

+ Subject string

+ TimestampMillis int64

+ To string

+ func (*MailboxMessage) Descriptor() ([]byte, []int)

+ func (*MailboxMessage) ProtoMessage()

+ func (m *MailboxMessage) GetPayload() isMailboxMessage_Payload

+ func (x *MailboxMessage) GetFrom() string

+ func (x *MailboxMessage) GetId() uint64

+ func (x *MailboxMessage) GetJson() string

+ func (x *MailboxMessage) GetSubject() string

+ func (x *MailboxMessage) GetTimestampMillis() int64

+ func (x *MailboxMessage) GetTo() string

+ func (x *MailboxMessage) ProtoReflect() protoreflect.Message

+ func (x *MailboxMessage) Reset()

+ func (x *MailboxMessage) String() string

+ type MailboxMessage_Json struct

+ Json string

+ type MoveValueRequest struct

+ FromKey []byte

+ Header *RequestHeader

+ ToKey []byte

+ func (*MoveValueRequest) Descriptor() ([]byte, []int)

+ func (*MoveValueRequest) ProtoMessage()

+ func (x *MoveValueRequest) GetFromKey() []byte

+ func (x *MoveValueRequest) GetHeader() *RequestHeader

+ func (x *MoveValueRequest) GetToKey() []byte

+ func (x *MoveValueRequest) ProtoReflect() protoreflect.Message

+ func (x *MoveValueRequest) Reset()

+ func (x *MoveValueRequest) String() string

+ type MoveValueResponse struct

+ Header *ResponseHeader

+ Kv *KeyValue

+ func (*MoveValueResponse) Descriptor() ([]byte, []int)

+ func (*MoveValueResponse) ProtoMessage()

+ func (x *MoveValueResponse) GetHeader() *ResponseHeader

+ func (x *MoveValueResponse) GetKv() *KeyValue

+ func (x *MoveValueResponse) ProtoReflect() protoreflect.Message

+ func (x *MoveValueResponse) Reset()

+ func (x *MoveValueResponse) String() string

+ type NodeStat struct

+ Attrs map[string]string

+ Rcus int64

+ RegionNum int64

+ TableNum int64

+ Wcus int64

+ func (*NodeStat) Descriptor() ([]byte, []int)

+ func (*NodeStat) ProtoMessage()

+ func (x *NodeStat) GetAttrs() map[string]string

+ func (x *NodeStat) GetRcus() int64

+ func (x *NodeStat) GetRegionNum() int64

+ func (x *NodeStat) GetTableNum() int64

+ func (x *NodeStat) GetWcus() int64

+ func (x *NodeStat) ProtoReflect() protoreflect.Message

+ func (x *NodeStat) Reset()

+ func (x *NodeStat) String() string

+ type Partition struct

+ ColumnList [][]byte

+ ValueList [][]byte

+ func (*Partition) Descriptor() ([]byte, []int)

+ func (*Partition) ProtoMessage()

+ func (x *Partition) GetColumnList() [][]byte

+ func (x *Partition) GetValueList() [][]byte

+ func (x *Partition) ProtoReflect() protoreflect.Message

+ func (x *Partition) Reset()

+ func (x *Partition) String() string

+ type Peer struct

+ Addr string

+ Id uint64

+ func (*Peer) Descriptor() ([]byte, []int)

+ func (*Peer) ProtoMessage()

+ func (x *Peer) GetAddr() string

+ func (x *Peer) GetId() uint64

+ func (x *Peer) ProtoReflect() protoreflect.Message

+ func (x *Peer) Reset()

+ func (x *Peer) String() string

+ type PutRequest struct

+ Header *RequestHeader

+ Key []byte

+ PrevKv bool

+ Value []byte

+ func (*PutRequest) Descriptor() ([]byte, []int)

+ func (*PutRequest) ProtoMessage()

+ func (x *PutRequest) GetHeader() *RequestHeader

+ func (x *PutRequest) GetKey() []byte

+ func (x *PutRequest) GetPrevKv() bool

+ func (x *PutRequest) GetValue() []byte

+ func (x *PutRequest) ProtoReflect() protoreflect.Message

+ func (x *PutRequest) Reset()

+ func (x *PutRequest) String() string

+ type PutResponse struct

+ Header *ResponseHeader

+ PrevKv *KeyValue

+ func (*PutResponse) Descriptor() ([]byte, []int)

+ func (*PutResponse) ProtoMessage()

+ func (x *PutResponse) GetHeader() *ResponseHeader

+ func (x *PutResponse) GetPrevKv() *KeyValue

+ func (x *PutResponse) ProtoReflect() protoreflect.Message

+ func (x *PutResponse) Reset()

+ func (x *PutResponse) String() string

+ type RangeRequest struct

+ Header *RequestHeader

+ Key []byte

+ KeysOnly bool

+ Limit int64

+ RangeEnd []byte

+ func (*RangeRequest) Descriptor() ([]byte, []int)

+ func (*RangeRequest) ProtoMessage()

+ func (x *RangeRequest) GetHeader() *RequestHeader

+ func (x *RangeRequest) GetKey() []byte

+ func (x *RangeRequest) GetKeysOnly() bool

+ func (x *RangeRequest) GetLimit() int64

+ func (x *RangeRequest) GetRangeEnd() []byte

+ func (x *RangeRequest) ProtoReflect() protoreflect.Message

+ func (x *RangeRequest) Reset()

+ func (x *RangeRequest) String() string

+ type RangeResponse struct

+ Header *ResponseHeader

+ Kvs []*KeyValue

+ More bool

+ func (*RangeResponse) Descriptor() ([]byte, []int)

+ func (*RangeResponse) ProtoMessage()

+ func (x *RangeResponse) GetHeader() *ResponseHeader

+ func (x *RangeResponse) GetKvs() []*KeyValue

+ func (x *RangeResponse) GetMore() bool

+ func (x *RangeResponse) ProtoReflect() protoreflect.Message

+ func (x *RangeResponse) Reset()

+ func (x *RangeResponse) String() string

+ type Region struct

+ Attrs map[string]string

+ Id uint64

+ Name string

+ Partition *Partition

+ func (*Region) Descriptor() ([]byte, []int)

+ func (*Region) ProtoMessage()

+ func (x *Region) GetAttrs() map[string]string

+ func (x *Region) GetId() uint64

+ func (x *Region) GetName() string

+ func (x *Region) GetPartition() *Partition

+ func (x *Region) ProtoReflect() protoreflect.Message

+ func (x *Region) Reset()

+ func (x *Region) String() string

+ type RegionLease struct

+ DurationSinceEpoch uint64

+ LeaseSeconds uint64

+ Regions []uint32

+ TableIdent *TableIdent

+ func (*RegionLease) Descriptor() ([]byte, []int)

+ func (*RegionLease) ProtoMessage()

+ func (x *RegionLease) GetDurationSinceEpoch() uint64

+ func (x *RegionLease) GetLeaseSeconds() uint64

+ func (x *RegionLease) GetRegions() []uint32

+ func (x *RegionLease) GetTableIdent() *TableIdent

+ func (x *RegionLease) ProtoReflect() protoreflect.Message

+ func (x *RegionLease) Reset()

+ func (x *RegionLease) String() string

+ type RegionRoute struct

+ FollowerPeerIndexes []uint64

+ LeaderPeerIndex uint64

+ Region *Region

+ func (*RegionRoute) Descriptor() ([]byte, []int)

+ func (*RegionRoute) ProtoMessage()

+ func (x *RegionRoute) GetFollowerPeerIndexes() []uint64

+ func (x *RegionRoute) GetLeaderPeerIndex() uint64

+ func (x *RegionRoute) GetRegion() *Region

+ func (x *RegionRoute) ProtoReflect() protoreflect.Message

+ func (x *RegionRoute) Reset()

+ func (x *RegionRoute) String() string

+ type RegionStat struct

+ ApproximateBytes int64

+ ApproximateRows int64

+ Attrs map[string]string

+ Rcus int64

+ RegionId uint64

+ TableIdent *TableIdent

+ Wcus int64

+ func (*RegionStat) Descriptor() ([]byte, []int)

+ func (*RegionStat) ProtoMessage()

+ func (x *RegionStat) GetApproximateBytes() int64

+ func (x *RegionStat) GetApproximateRows() int64

+ func (x *RegionStat) GetAttrs() map[string]string

+ func (x *RegionStat) GetRcus() int64

+ func (x *RegionStat) GetRegionId() uint64

+ func (x *RegionStat) GetTableIdent() *TableIdent

+ func (x *RegionStat) GetWcus() int64

+ func (x *RegionStat) ProtoReflect() protoreflect.Message

+ func (x *RegionStat) Reset()

+ func (x *RegionStat) String() string

+ type RequestHeader struct

+ ClusterId uint64

+ MemberId uint64

+ ProtocolVersion uint64

+ Role Role

+ func (*RequestHeader) Descriptor() ([]byte, []int)

+ func (*RequestHeader) ProtoMessage()

+ func (x *RequestHeader) GetClusterId() uint64

+ func (x *RequestHeader) GetMemberId() uint64

+ func (x *RequestHeader) GetProtocolVersion() uint64

+ func (x *RequestHeader) GetRole() Role

+ func (x *RequestHeader) ProtoReflect() protoreflect.Message

+ func (x *RequestHeader) Reset()

+ func (x *RequestHeader) String() string

+ type ResponseHeader struct

+ ClusterId uint64

+ Error *Error

+ ProtocolVersion uint64

+ func (*ResponseHeader) Descriptor() ([]byte, []int)

+ func (*ResponseHeader) ProtoMessage()

+ func (x *ResponseHeader) GetClusterId() uint64

+ func (x *ResponseHeader) GetError() *Error

+ func (x *ResponseHeader) GetProtocolVersion() uint64

+ func (x *ResponseHeader) ProtoReflect() protoreflect.Message

+ func (x *ResponseHeader) Reset()

+ func (x *ResponseHeader) String() string

+ type Role int32

+ const Role_DATANODE

+ const Role_FRONTEND

+ func (Role) Descriptor() protoreflect.EnumDescriptor

+ func (Role) EnumDescriptor() ([]byte, []int)

+ func (Role) Type() protoreflect.EnumType

+ func (x Role) Enum() *Role

+ func (x Role) Number() protoreflect.EnumNumber

+ func (x Role) String() string

+ type RouteRequest struct

+ Header *RequestHeader

+ TableIds []*TableId

+ func (*RouteRequest) Descriptor() ([]byte, []int)

+ func (*RouteRequest) ProtoMessage()

+ func (x *RouteRequest) GetHeader() *RequestHeader

+ func (x *RouteRequest) GetTableIds() []*TableId

+ func (x *RouteRequest) ProtoReflect() protoreflect.Message

+ func (x *RouteRequest) Reset()

+ func (x *RouteRequest) String() string

+ type RouteResponse struct

+ Header *ResponseHeader

+ Peers []*Peer

+ TableRoutes []*TableRoute

+ func (*RouteResponse) Descriptor() ([]byte, []int)

+ func (*RouteResponse) ProtoMessage()

+ func (x *RouteResponse) GetHeader() *ResponseHeader

+ func (x *RouteResponse) GetPeers() []*Peer

+ func (x *RouteResponse) GetTableRoutes() []*TableRoute

+ func (x *RouteResponse) ProtoReflect() protoreflect.Message

+ func (x *RouteResponse) Reset()

+ func (x *RouteResponse) String() string

+ type RouterClient interface

+ Route func(ctx context.Context, in *RouteRequest, opts ...grpc.CallOption) (*RouteResponse, error)

+ func NewRouterClient(cc grpc.ClientConnInterface) RouterClient

+ type RouterServer interface

+ Route func(context.Context, *RouteRequest) (*RouteResponse, error)

+ type StoreClient interface

+ BatchDelete func(ctx context.Context, in *BatchDeleteRequest, opts ...grpc.CallOption) (*BatchDeleteResponse, error)

+ BatchGet func(ctx context.Context, in *BatchGetRequest, opts ...grpc.CallOption) (*BatchGetResponse, error)

+ BatchPut func(ctx context.Context, in *BatchPutRequest, opts ...grpc.CallOption) (*BatchPutResponse, error)

+ CompareAndPut func(ctx context.Context, in *CompareAndPutRequest, opts ...grpc.CallOption) (*CompareAndPutResponse, error)

+ DeleteRange func(ctx context.Context, in *DeleteRangeRequest, opts ...grpc.CallOption) (*DeleteRangeResponse, error)

+ MoveValue func(ctx context.Context, in *MoveValueRequest, opts ...grpc.CallOption) (*MoveValueResponse, error)

+ Put func(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)

+ Range func(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)

+ func NewStoreClient(cc grpc.ClientConnInterface) StoreClient

+ type StoreServer interface

+ BatchDelete func(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error)

+ BatchGet func(context.Context, *BatchGetRequest) (*BatchGetResponse, error)

+ BatchPut func(context.Context, *BatchPutRequest) (*BatchPutResponse, error)

+ CompareAndPut func(context.Context, *CompareAndPutRequest) (*CompareAndPutResponse, error)

+ DeleteRange func(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error)

+ MoveValue func(context.Context, *MoveValueRequest) (*MoveValueResponse, error)

+ Put func(context.Context, *PutRequest) (*PutResponse, error)

+ Range func(context.Context, *RangeRequest) (*RangeResponse, error)

+ type SubmitDdlTaskRequest struct

+ Header *RequestHeader

+ Task isSubmitDdlTaskRequest_Task

+ func (*SubmitDdlTaskRequest) Descriptor() ([]byte, []int)

+ func (*SubmitDdlTaskRequest) ProtoMessage()

+ func (m *SubmitDdlTaskRequest) GetTask() isSubmitDdlTaskRequest_Task

+ func (x *SubmitDdlTaskRequest) GetAlterTableTask() *AlterTableTask

+ func (x *SubmitDdlTaskRequest) GetCreateTableTask() *CreateTableTask

+ func (x *SubmitDdlTaskRequest) GetDropTableTask() *DropTableTask

+ func (x *SubmitDdlTaskRequest) GetHeader() *RequestHeader

+ func (x *SubmitDdlTaskRequest) GetTruncateTableTask() *TruncateTableTask

+ func (x *SubmitDdlTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *SubmitDdlTaskRequest) Reset()

+ func (x *SubmitDdlTaskRequest) String() string

+ type SubmitDdlTaskRequest_AlterTableTask struct

+ AlterTableTask *AlterTableTask

+ type SubmitDdlTaskRequest_CreateTableTask struct

+ CreateTableTask *CreateTableTask

+ type SubmitDdlTaskRequest_DropTableTask struct

+ DropTableTask *DropTableTask

+ type SubmitDdlTaskRequest_TruncateTableTask struct

+ TruncateTableTask *TruncateTableTask

+ type SubmitDdlTaskResponse struct

+ Header *ResponseHeader

+ Key []byte

+ TableId *TableId

+ func (*SubmitDdlTaskResponse) Descriptor() ([]byte, []int)

+ func (*SubmitDdlTaskResponse) ProtoMessage()

+ func (x *SubmitDdlTaskResponse) GetHeader() *ResponseHeader

+ func (x *SubmitDdlTaskResponse) GetKey() []byte

+ func (x *SubmitDdlTaskResponse) GetTableId() *TableId

+ func (x *SubmitDdlTaskResponse) ProtoReflect() protoreflect.Message

+ func (x *SubmitDdlTaskResponse) Reset()

+ func (x *SubmitDdlTaskResponse) String() string

+ type Table struct

+ Id uint64

+ TableName *TableName

+ TableSchema []byte

+ func (*Table) Descriptor() ([]byte, []int)

+ func (*Table) ProtoMessage()

+ func (x *Table) GetId() uint64

+ func (x *Table) GetTableName() *TableName

+ func (x *Table) GetTableSchema() []byte

+ func (x *Table) ProtoReflect() protoreflect.Message

+ func (x *Table) Reset()

+ func (x *Table) String() string

+ type TableId struct

+ Id uint32

+ func (*TableId) Descriptor() ([]byte, []int)

+ func (*TableId) ProtoMessage()

+ func (x *TableId) GetId() uint32

+ func (x *TableId) ProtoReflect() protoreflect.Message

+ func (x *TableId) Reset()

+ func (x *TableId) String() string

+ type TableIdent struct

+ Engine string

+ TableId uint32

+ TableName *TableName

+ func (*TableIdent) Descriptor() ([]byte, []int)

+ func (*TableIdent) ProtoMessage()

+ func (x *TableIdent) GetEngine() string

+ func (x *TableIdent) GetTableId() uint32

+ func (x *TableIdent) GetTableName() *TableName

+ func (x *TableIdent) ProtoReflect() protoreflect.Message

+ func (x *TableIdent) Reset()

+ func (x *TableIdent) String() string

+ type TableName struct

+ CatalogName string

+ SchemaName string

+ TableName string

+ func (*TableName) Descriptor() ([]byte, []int)

+ func (*TableName) ProtoMessage()

+ func (x *TableName) GetCatalogName() string

+ func (x *TableName) GetSchemaName() string

+ func (x *TableName) GetTableName() string

+ func (x *TableName) ProtoReflect() protoreflect.Message

+ func (x *TableName) Reset()

+ func (x *TableName) String() string

+ type TableRoute struct

+ RegionRoutes []*RegionRoute

+ Table *Table

+ func (*TableRoute) Descriptor() ([]byte, []int)

+ func (*TableRoute) ProtoMessage()

+ func (x *TableRoute) GetRegionRoutes() []*RegionRoute

+ func (x *TableRoute) GetTable() *Table

+ func (x *TableRoute) ProtoReflect() protoreflect.Message

+ func (x *TableRoute) Reset()

+ func (x *TableRoute) String() string

+ type TableRouteValue struct

+ Peers []*Peer

+ TableRoute *TableRoute

+ func (*TableRouteValue) Descriptor() ([]byte, []int)

+ func (*TableRouteValue) ProtoMessage()

+ func (x *TableRouteValue) GetPeers() []*Peer

+ func (x *TableRouteValue) GetTableRoute() *TableRoute

+ func (x *TableRouteValue) ProtoReflect() protoreflect.Message

+ func (x *TableRouteValue) Reset()

+ func (x *TableRouteValue) String() string

+ type TimeInterval struct

+ EndTimestampMillis int64

+ StartTimestampMillis int64

+ func (*TimeInterval) Descriptor() ([]byte, []int)

+ func (*TimeInterval) ProtoMessage()

+ func (x *TimeInterval) GetEndTimestampMillis() int64

+ func (x *TimeInterval) GetStartTimestampMillis() int64

+ func (x *TimeInterval) ProtoReflect() protoreflect.Message

+ func (x *TimeInterval) Reset()

+ func (x *TimeInterval) String() string

+ type TruncateTableTask struct

+ TruncateTable *v1.TruncateTableExpr

+ func (*TruncateTableTask) Descriptor() ([]byte, []int)

+ func (*TruncateTableTask) ProtoMessage()

+ func (x *TruncateTableTask) GetTruncateTable() *v1.TruncateTableExpr

+ func (x *TruncateTableTask) ProtoReflect() protoreflect.Message

+ func (x *TruncateTableTask) Reset()

+ func (x *TruncateTableTask) String() string

+ type UnimplementedClusterServer struct

+ func (UnimplementedClusterServer) BatchGet(context.Context, *BatchGetRequest) (*BatchGetResponse, error)

+ func (UnimplementedClusterServer) Range(context.Context, *RangeRequest) (*RangeResponse, error)

+ type UnimplementedDdlTaskServer struct

+ func (UnimplementedDdlTaskServer) SubmitDdlTask(context.Context, *SubmitDdlTaskRequest) (*SubmitDdlTaskResponse, error)

+ type UnimplementedHeartbeatServer struct

+ func (UnimplementedHeartbeatServer) AskLeader(context.Context, *AskLeaderRequest) (*AskLeaderResponse, error)

+ func (UnimplementedHeartbeatServer) Heartbeat(Heartbeat_HeartbeatServer) error

+ type UnimplementedLockServer struct

+ func (UnimplementedLockServer) Lock(context.Context, *LockRequest) (*LockResponse, error)

+ func (UnimplementedLockServer) Unlock(context.Context, *UnlockRequest) (*UnlockResponse, error)

+ type UnimplementedRouterServer struct

+ func (UnimplementedRouterServer) Route(context.Context, *RouteRequest) (*RouteResponse, error)

+ type UnimplementedStoreServer struct

+ func (UnimplementedStoreServer) BatchDelete(context.Context, *BatchDeleteRequest) (*BatchDeleteResponse, error)

+ func (UnimplementedStoreServer) BatchGet(context.Context, *BatchGetRequest) (*BatchGetResponse, error)

+ func (UnimplementedStoreServer) BatchPut(context.Context, *BatchPutRequest) (*BatchPutResponse, error)

+ func (UnimplementedStoreServer) CompareAndPut(context.Context, *CompareAndPutRequest) (*CompareAndPutResponse, error)

+ func (UnimplementedStoreServer) DeleteRange(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error)

+ func (UnimplementedStoreServer) MoveValue(context.Context, *MoveValueRequest) (*MoveValueResponse, error)

+ func (UnimplementedStoreServer) Put(context.Context, *PutRequest) (*PutResponse, error)

+ func (UnimplementedStoreServer) Range(context.Context, *RangeRequest) (*RangeResponse, error)

+ type UnlockRequest struct

+ Header *RequestHeader

+ Key []byte

+ func (*UnlockRequest) Descriptor() ([]byte, []int)

+ func (*UnlockRequest) ProtoMessage()

+ func (x *UnlockRequest) GetHeader() *RequestHeader

+ func (x *UnlockRequest) GetKey() []byte

+ func (x *UnlockRequest) ProtoReflect() protoreflect.Message

+ func (x *UnlockRequest) Reset()

+ func (x *UnlockRequest) String() string

+ type UnlockResponse struct

+ Header *ResponseHeader

+ func (*UnlockResponse) Descriptor() ([]byte, []int)

+ func (*UnlockResponse) ProtoMessage()

+ func (x *UnlockResponse) GetHeader() *ResponseHeader

+ func (x *UnlockResponse) ProtoReflect() protoreflect.Message

+ func (x *UnlockResponse) Reset()

+ func (x *UnlockResponse) String() string

+ type UnsafeClusterServer interface

+ type UnsafeDdlTaskServer interface

+ type UnsafeHeartbeatServer interface

+ type UnsafeLockServer interface

+ type UnsafeRouterServer interface

+ type UnsafeStoreServer interface

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL