Documentation ¶
Index ¶
- Variables
- func RegisterMetaRpcServiceServer(s grpc.ServiceRegistrar, srv MetaRpcServiceServer)
- type AllocSchemaIdRequest
- func (*AllocSchemaIdRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AllocSchemaIdRequest) GetHeader() *RequestHeader
- func (x *AllocSchemaIdRequest) GetName() string
- func (*AllocSchemaIdRequest) ProtoMessage()
- func (x *AllocSchemaIdRequest) ProtoReflect() protoreflect.Message
- func (x *AllocSchemaIdRequest) Reset()
- func (x *AllocSchemaIdRequest) String() string
- type AllocSchemaIdResponse
- func (*AllocSchemaIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AllocSchemaIdResponse) GetHeader() *commonpb.ResponseHeader
- func (x *AllocSchemaIdResponse) GetId() uint32
- func (x *AllocSchemaIdResponse) GetName() string
- func (*AllocSchemaIdResponse) ProtoMessage()
- func (x *AllocSchemaIdResponse) ProtoReflect() protoreflect.Message
- func (x *AllocSchemaIdResponse) Reset()
- func (x *AllocSchemaIdResponse) String() string
- type CreateTableRequest
- func (*CreateTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTableRequest) GetCreateIfNotExist() bool
- func (x *CreateTableRequest) GetEncodedSchema() []byte
- func (x *CreateTableRequest) GetEngine() string
- func (x *CreateTableRequest) GetHeader() *RequestHeader
- func (x *CreateTableRequest) GetName() string
- func (x *CreateTableRequest) GetOptions() map[string]string
- func (x *CreateTableRequest) GetPartitionTableInfo() *PartitionTableInfo
- func (x *CreateTableRequest) GetSchemaName() string
- func (*CreateTableRequest) ProtoMessage()
- func (x *CreateTableRequest) ProtoReflect() protoreflect.Message
- func (x *CreateTableRequest) Reset()
- func (x *CreateTableRequest) String() string
- type CreateTableResponse
- func (*CreateTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateTableResponse) GetCreatedTable() *TableInfo
- func (x *CreateTableResponse) GetHeader() *commonpb.ResponseHeader
- func (x *CreateTableResponse) GetShardInfo() *ShardInfo
- func (*CreateTableResponse) ProtoMessage()
- func (x *CreateTableResponse) ProtoReflect() protoreflect.Message
- func (x *CreateTableResponse) Reset()
- func (x *CreateTableResponse) String() string
- type DropTableRequest
- func (*DropTableRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DropTableRequest) GetHeader() *RequestHeader
- func (x *DropTableRequest) GetName() string
- func (x *DropTableRequest) GetPartitionTableInfo() *PartitionTableInfo
- func (x *DropTableRequest) GetSchemaName() string
- func (*DropTableRequest) ProtoMessage()
- func (x *DropTableRequest) ProtoReflect() protoreflect.Message
- func (x *DropTableRequest) Reset()
- func (x *DropTableRequest) String() string
- type DropTableResponse
- func (*DropTableResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DropTableResponse) GetDroppedTable() *TableInfo
- func (x *DropTableResponse) GetHeader() *commonpb.ResponseHeader
- func (*DropTableResponse) ProtoMessage()
- func (x *DropTableResponse) ProtoReflect() protoreflect.Message
- func (x *DropTableResponse) Reset()
- func (x *DropTableResponse) String() string
- type GetNodesRequest
- type GetNodesResponse
- func (*GetNodesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetNodesResponse) GetClusterTopologyVersion() uint64
- func (x *GetNodesResponse) GetHeader() *commonpb.ResponseHeader
- func (x *GetNodesResponse) GetNodeShards() []*NodeShard
- func (*GetNodesResponse) ProtoMessage()
- func (x *GetNodesResponse) ProtoReflect() protoreflect.Message
- func (x *GetNodesResponse) Reset()
- func (x *GetNodesResponse) String() string
- type GetTablesOfShardsRequest
- func (*GetTablesOfShardsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetTablesOfShardsRequest) GetHeader() *RequestHeader
- func (x *GetTablesOfShardsRequest) GetShardIds() []uint32
- func (*GetTablesOfShardsRequest) ProtoMessage()
- func (x *GetTablesOfShardsRequest) ProtoReflect() protoreflect.Message
- func (x *GetTablesOfShardsRequest) Reset()
- func (x *GetTablesOfShardsRequest) String() string
- type GetTablesOfShardsResponse
- func (*GetTablesOfShardsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetTablesOfShardsResponse) GetHeader() *commonpb.ResponseHeader
- func (x *GetTablesOfShardsResponse) GetTablesByShard() map[uint32]*TablesOfShard
- func (*GetTablesOfShardsResponse) ProtoMessage()
- func (x *GetTablesOfShardsResponse) ProtoReflect() protoreflect.Message
- func (x *GetTablesOfShardsResponse) Reset()
- func (x *GetTablesOfShardsResponse) String() string
- type MetaRpcServiceClient
- type MetaRpcServiceServer
- type NodeHeartbeatRequest
- func (*NodeHeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NodeHeartbeatRequest) GetHeader() *RequestHeader
- func (x *NodeHeartbeatRequest) GetInfo() *NodeInfo
- func (*NodeHeartbeatRequest) ProtoMessage()
- func (x *NodeHeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *NodeHeartbeatRequest) Reset()
- func (x *NodeHeartbeatRequest) String() string
- type NodeHeartbeatResponse
- func (*NodeHeartbeatResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NodeHeartbeatResponse) GetHeader() *commonpb.ResponseHeader
- func (*NodeHeartbeatResponse) ProtoMessage()
- func (x *NodeHeartbeatResponse) ProtoReflect() protoreflect.Message
- func (x *NodeHeartbeatResponse) Reset()
- func (x *NodeHeartbeatResponse) String() string
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *NodeInfo) GetBinaryVersion() string
- func (x *NodeInfo) GetClusterType() NodeInfo_ClusterType
- func (x *NodeInfo) GetEndpoint() string
- func (x *NodeInfo) GetLease() uint32
- func (x *NodeInfo) GetShardInfos() []*ShardInfo
- func (x *NodeInfo) GetZone() string
- func (*NodeInfo) ProtoMessage()
- func (x *NodeInfo) ProtoReflect() protoreflect.Message
- func (x *NodeInfo) Reset()
- func (x *NodeInfo) String() string
- type NodeInfo_ClusterType
- func (NodeInfo_ClusterType) Descriptor() protoreflect.EnumDescriptor
- func (x NodeInfo_ClusterType) Enum() *NodeInfo_ClusterType
- func (NodeInfo_ClusterType) EnumDescriptor() ([]byte, []int)deprecated
- func (x NodeInfo_ClusterType) Number() protoreflect.EnumNumber
- func (x NodeInfo_ClusterType) String() string
- func (NodeInfo_ClusterType) Type() protoreflect.EnumType
- type NodeShard
- type PartitionTableInfo
- func (*PartitionTableInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PartitionTableInfo) GetPartitionInfo() *clusterpb.PartitionInfo
- func (x *PartitionTableInfo) GetSubTableNames() []string
- func (*PartitionTableInfo) ProtoMessage()
- func (x *PartitionTableInfo) ProtoReflect() protoreflect.Message
- func (x *PartitionTableInfo) Reset()
- func (x *PartitionTableInfo) String() string
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)deprecated
- func (x *RequestHeader) GetClusterName() string
- func (x *RequestHeader) GetNode() string
- func (*RequestHeader) ProtoMessage()
- func (x *RequestHeader) ProtoReflect() protoreflect.Message
- func (x *RequestHeader) Reset()
- func (x *RequestHeader) String() string
- type RouteEntry
- func (*RouteEntry) Descriptor() ([]byte, []int)deprecated
- func (x *RouteEntry) GetNodeShards() []*NodeShard
- func (x *RouteEntry) GetTable() *TableInfo
- func (*RouteEntry) ProtoMessage()
- func (x *RouteEntry) ProtoReflect() protoreflect.Message
- func (x *RouteEntry) Reset()
- func (x *RouteEntry) String() string
- type RouteTablesRequest
- func (*RouteTablesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RouteTablesRequest) GetHeader() *RequestHeader
- func (x *RouteTablesRequest) GetSchemaName() string
- func (x *RouteTablesRequest) GetTableNames() []string
- func (*RouteTablesRequest) ProtoMessage()
- func (x *RouteTablesRequest) ProtoReflect() protoreflect.Message
- func (x *RouteTablesRequest) Reset()
- func (x *RouteTablesRequest) String() string
- type RouteTablesResponse
- func (*RouteTablesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RouteTablesResponse) GetClusterTopologyVersion() uint64
- func (x *RouteTablesResponse) GetEntries() map[string]*RouteEntry
- func (x *RouteTablesResponse) GetHeader() *commonpb.ResponseHeader
- func (*RouteTablesResponse) ProtoMessage()
- func (x *RouteTablesResponse) ProtoReflect() protoreflect.Message
- func (x *RouteTablesResponse) Reset()
- func (x *RouteTablesResponse) String() string
- type ShardInfo
- func (*ShardInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ShardInfo) GetId() uint32
- func (x *ShardInfo) GetRole() clusterpb.ShardRole
- func (x *ShardInfo) GetStatus() ShardInfo_Status
- func (x *ShardInfo) GetVersion() uint64
- func (*ShardInfo) ProtoMessage()
- func (x *ShardInfo) ProtoReflect() protoreflect.Message
- func (x *ShardInfo) Reset()
- func (x *ShardInfo) String() string
- type ShardInfo_Status
- func (ShardInfo_Status) Descriptor() protoreflect.EnumDescriptor
- func (x ShardInfo_Status) Enum() *ShardInfo_Status
- func (ShardInfo_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x ShardInfo_Status) Number() protoreflect.EnumNumber
- func (x ShardInfo_Status) String() string
- func (ShardInfo_Status) Type() protoreflect.EnumType
- type TableInfo
- func (*TableInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TableInfo) GetId() uint64
- func (x *TableInfo) GetName() string
- func (x *TableInfo) GetPartitionInfo() *clusterpb.PartitionInfo
- func (x *TableInfo) GetSchemaId() uint32
- func (x *TableInfo) GetSchemaName() string
- func (*TableInfo) ProtoMessage()
- func (x *TableInfo) ProtoReflect() protoreflect.Message
- func (x *TableInfo) Reset()
- func (x *TableInfo) String() string
- type TablesOfShard
- func (*TablesOfShard) Descriptor() ([]byte, []int)deprecated
- func (x *TablesOfShard) GetShardInfo() *ShardInfo
- func (x *TablesOfShard) GetTables() []*TableInfo
- func (*TablesOfShard) ProtoMessage()
- func (x *TablesOfShard) ProtoReflect() protoreflect.Message
- func (x *TablesOfShard) Reset()
- func (x *TablesOfShard) String() string
- type UnimplementedMetaRpcServiceServer
- func (UnimplementedMetaRpcServiceServer) AllocSchemaID(context.Context, *AllocSchemaIdRequest) (*AllocSchemaIdResponse, error)
- func (UnimplementedMetaRpcServiceServer) CreateTable(context.Context, *CreateTableRequest) (*CreateTableResponse, error)
- func (UnimplementedMetaRpcServiceServer) DropTable(context.Context, *DropTableRequest) (*DropTableResponse, error)
- func (UnimplementedMetaRpcServiceServer) GetNodes(context.Context, *GetNodesRequest) (*GetNodesResponse, error)
- func (UnimplementedMetaRpcServiceServer) GetTablesOfShards(context.Context, *GetTablesOfShardsRequest) (*GetTablesOfShardsResponse, error)
- func (UnimplementedMetaRpcServiceServer) NodeHeartbeat(context.Context, *NodeHeartbeatRequest) (*NodeHeartbeatResponse, error)
- func (UnimplementedMetaRpcServiceServer) RouteTables(context.Context, *RouteTablesRequest) (*RouteTablesResponse, error)
- type UnsafeMetaRpcServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( ShardInfo_Status_name = map[int32]string{ 0: "Ready", 1: "PartialOpen", } ShardInfo_Status_value = map[string]int32{ "Ready": 0, "PartialOpen": 1, } )
Enum value maps for ShardInfo_Status.
var ( NodeInfo_ClusterType_name = map[int32]string{ 0: "HoraeDB", 1: "CompactionServer", } NodeInfo_ClusterType_value = map[string]int32{ "HoraeDB": 0, "CompactionServer": 1, } )
Enum value maps for NodeInfo_ClusterType.
var File_meta_service_proto protoreflect.FileDescriptor
var MetaRpcService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "meta_service.MetaRpcService", HandlerType: (*MetaRpcServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AllocSchemaID", Handler: _MetaRpcService_AllocSchemaID_Handler, }, { MethodName: "GetTablesOfShards", Handler: _MetaRpcService_GetTablesOfShards_Handler, }, { MethodName: "CreateTable", Handler: _MetaRpcService_CreateTable_Handler, }, { MethodName: "DropTable", Handler: _MetaRpcService_DropTable_Handler, }, { MethodName: "RouteTables", Handler: _MetaRpcService_RouteTables_Handler, }, { MethodName: "GetNodes", Handler: _MetaRpcService_GetNodes_Handler, }, { MethodName: "NodeHeartbeat", Handler: _MetaRpcService_NodeHeartbeat_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "meta_service.proto", }
MetaRpcService_ServiceDesc is the grpc.ServiceDesc for MetaRpcService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMetaRpcServiceServer ¶
func RegisterMetaRpcServiceServer(s grpc.ServiceRegistrar, srv MetaRpcServiceServer)
Types ¶
type AllocSchemaIdRequest ¶
type AllocSchemaIdRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*AllocSchemaIdRequest) Descriptor
deprecated
func (*AllocSchemaIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use AllocSchemaIdRequest.ProtoReflect.Descriptor instead.
func (*AllocSchemaIdRequest) GetHeader ¶
func (x *AllocSchemaIdRequest) GetHeader() *RequestHeader
func (*AllocSchemaIdRequest) GetName ¶
func (x *AllocSchemaIdRequest) GetName() string
func (*AllocSchemaIdRequest) ProtoMessage ¶
func (*AllocSchemaIdRequest) ProtoMessage()
func (*AllocSchemaIdRequest) ProtoReflect ¶
func (x *AllocSchemaIdRequest) ProtoReflect() protoreflect.Message
func (*AllocSchemaIdRequest) Reset ¶
func (x *AllocSchemaIdRequest) Reset()
func (*AllocSchemaIdRequest) String ¶
func (x *AllocSchemaIdRequest) String() string
type AllocSchemaIdResponse ¶
type AllocSchemaIdResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Id uint32 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*AllocSchemaIdResponse) Descriptor
deprecated
func (*AllocSchemaIdResponse) Descriptor() ([]byte, []int)
Deprecated: Use AllocSchemaIdResponse.ProtoReflect.Descriptor instead.
func (*AllocSchemaIdResponse) GetHeader ¶
func (x *AllocSchemaIdResponse) GetHeader() *commonpb.ResponseHeader
func (*AllocSchemaIdResponse) GetId ¶
func (x *AllocSchemaIdResponse) GetId() uint32
func (*AllocSchemaIdResponse) GetName ¶
func (x *AllocSchemaIdResponse) GetName() string
func (*AllocSchemaIdResponse) ProtoMessage ¶
func (*AllocSchemaIdResponse) ProtoMessage()
func (*AllocSchemaIdResponse) ProtoReflect ¶
func (x *AllocSchemaIdResponse) ProtoReflect() protoreflect.Message
func (*AllocSchemaIdResponse) Reset ¶
func (x *AllocSchemaIdResponse) Reset()
func (*AllocSchemaIdResponse) String ¶
func (x *AllocSchemaIdResponse) String() string
type CreateTableRequest ¶
type CreateTableRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` EncodedSchema []byte `protobuf:"bytes,4,opt,name=encoded_schema,json=encodedSchema,proto3" json:"encoded_schema,omitempty"` Engine string `protobuf:"bytes,5,opt,name=engine,proto3" json:"engine,omitempty"` CreateIfNotExist bool `protobuf:"varint,6,opt,name=create_if_not_exist,json=createIfNotExist,proto3" json:"create_if_not_exist,omitempty"` Options map[string]string `` /* 155-byte string literal not displayed */ PartitionTableInfo *PartitionTableInfo `protobuf:"bytes,8,opt,name=partition_table_info,json=partitionTableInfo,proto3" json:"partition_table_info,omitempty"` // contains filtered or unexported fields }
func (*CreateTableRequest) Descriptor
deprecated
func (*CreateTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateTableRequest.ProtoReflect.Descriptor instead.
func (*CreateTableRequest) GetCreateIfNotExist ¶
func (x *CreateTableRequest) GetCreateIfNotExist() bool
func (*CreateTableRequest) GetEncodedSchema ¶
func (x *CreateTableRequest) GetEncodedSchema() []byte
func (*CreateTableRequest) GetEngine ¶
func (x *CreateTableRequest) GetEngine() string
func (*CreateTableRequest) GetHeader ¶
func (x *CreateTableRequest) GetHeader() *RequestHeader
func (*CreateTableRequest) GetName ¶
func (x *CreateTableRequest) GetName() string
func (*CreateTableRequest) GetOptions ¶
func (x *CreateTableRequest) GetOptions() map[string]string
func (*CreateTableRequest) GetPartitionTableInfo ¶
func (x *CreateTableRequest) GetPartitionTableInfo() *PartitionTableInfo
func (*CreateTableRequest) GetSchemaName ¶
func (x *CreateTableRequest) GetSchemaName() string
func (*CreateTableRequest) ProtoMessage ¶
func (*CreateTableRequest) ProtoMessage()
func (*CreateTableRequest) ProtoReflect ¶
func (x *CreateTableRequest) ProtoReflect() protoreflect.Message
func (*CreateTableRequest) Reset ¶
func (x *CreateTableRequest) Reset()
func (*CreateTableRequest) String ¶
func (x *CreateTableRequest) String() string
type CreateTableResponse ¶
type CreateTableResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` CreatedTable *TableInfo `protobuf:"bytes,2,opt,name=created_table,json=createdTable,proto3" json:"created_table,omitempty"` ShardInfo *ShardInfo `protobuf:"bytes,3,opt,name=shard_info,json=shardInfo,proto3" json:"shard_info,omitempty"` // contains filtered or unexported fields }
func (*CreateTableResponse) Descriptor
deprecated
func (*CreateTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateTableResponse.ProtoReflect.Descriptor instead.
func (*CreateTableResponse) GetCreatedTable ¶
func (x *CreateTableResponse) GetCreatedTable() *TableInfo
func (*CreateTableResponse) GetHeader ¶
func (x *CreateTableResponse) GetHeader() *commonpb.ResponseHeader
func (*CreateTableResponse) GetShardInfo ¶
func (x *CreateTableResponse) GetShardInfo() *ShardInfo
func (*CreateTableResponse) ProtoMessage ¶
func (*CreateTableResponse) ProtoMessage()
func (*CreateTableResponse) ProtoReflect ¶
func (x *CreateTableResponse) ProtoReflect() protoreflect.Message
func (*CreateTableResponse) Reset ¶
func (x *CreateTableResponse) Reset()
func (*CreateTableResponse) String ¶
func (x *CreateTableResponse) String() string
type DropTableRequest ¶
type DropTableRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` PartitionTableInfo *PartitionTableInfo `protobuf:"bytes,4,opt,name=partition_table_info,json=partitionTableInfo,proto3" json:"partition_table_info,omitempty"` // contains filtered or unexported fields }
func (*DropTableRequest) Descriptor
deprecated
func (*DropTableRequest) Descriptor() ([]byte, []int)
Deprecated: Use DropTableRequest.ProtoReflect.Descriptor instead.
func (*DropTableRequest) GetHeader ¶
func (x *DropTableRequest) GetHeader() *RequestHeader
func (*DropTableRequest) GetName ¶
func (x *DropTableRequest) GetName() string
func (*DropTableRequest) GetPartitionTableInfo ¶
func (x *DropTableRequest) GetPartitionTableInfo() *PartitionTableInfo
func (*DropTableRequest) GetSchemaName ¶
func (x *DropTableRequest) GetSchemaName() string
func (*DropTableRequest) ProtoMessage ¶
func (*DropTableRequest) ProtoMessage()
func (*DropTableRequest) ProtoReflect ¶
func (x *DropTableRequest) ProtoReflect() protoreflect.Message
func (*DropTableRequest) Reset ¶
func (x *DropTableRequest) Reset()
func (*DropTableRequest) String ¶
func (x *DropTableRequest) String() string
type DropTableResponse ¶
type DropTableResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` DroppedTable *TableInfo `protobuf:"bytes,2,opt,name=dropped_table,json=droppedTable,proto3" json:"dropped_table,omitempty"` // contains filtered or unexported fields }
func (*DropTableResponse) Descriptor
deprecated
func (*DropTableResponse) Descriptor() ([]byte, []int)
Deprecated: Use DropTableResponse.ProtoReflect.Descriptor instead.
func (*DropTableResponse) GetDroppedTable ¶
func (x *DropTableResponse) GetDroppedTable() *TableInfo
func (*DropTableResponse) GetHeader ¶
func (x *DropTableResponse) GetHeader() *commonpb.ResponseHeader
func (*DropTableResponse) ProtoMessage ¶
func (*DropTableResponse) ProtoMessage()
func (*DropTableResponse) ProtoReflect ¶
func (x *DropTableResponse) ProtoReflect() protoreflect.Message
func (*DropTableResponse) Reset ¶
func (x *DropTableResponse) Reset()
func (*DropTableResponse) String ¶
func (x *DropTableResponse) String() string
type GetNodesRequest ¶
type GetNodesRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // contains filtered or unexported fields }
func (*GetNodesRequest) Descriptor
deprecated
func (*GetNodesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetNodesRequest.ProtoReflect.Descriptor instead.
func (*GetNodesRequest) GetHeader ¶
func (x *GetNodesRequest) GetHeader() *RequestHeader
func (*GetNodesRequest) ProtoMessage ¶
func (*GetNodesRequest) ProtoMessage()
func (*GetNodesRequest) ProtoReflect ¶
func (x *GetNodesRequest) ProtoReflect() protoreflect.Message
func (*GetNodesRequest) Reset ¶
func (x *GetNodesRequest) Reset()
func (*GetNodesRequest) String ¶
func (x *GetNodesRequest) String() string
type GetNodesResponse ¶
type GetNodesResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` ClusterTopologyVersion uint64 `` /* 130-byte string literal not displayed */ NodeShards []*NodeShard `protobuf:"bytes,3,rep,name=node_shards,json=nodeShards,proto3" json:"node_shards,omitempty"` // contains filtered or unexported fields }
func (*GetNodesResponse) Descriptor
deprecated
func (*GetNodesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetNodesResponse.ProtoReflect.Descriptor instead.
func (*GetNodesResponse) GetClusterTopologyVersion ¶
func (x *GetNodesResponse) GetClusterTopologyVersion() uint64
func (*GetNodesResponse) GetHeader ¶
func (x *GetNodesResponse) GetHeader() *commonpb.ResponseHeader
func (*GetNodesResponse) GetNodeShards ¶
func (x *GetNodesResponse) GetNodeShards() []*NodeShard
func (*GetNodesResponse) ProtoMessage ¶
func (*GetNodesResponse) ProtoMessage()
func (*GetNodesResponse) ProtoReflect ¶
func (x *GetNodesResponse) ProtoReflect() protoreflect.Message
func (*GetNodesResponse) Reset ¶
func (x *GetNodesResponse) Reset()
func (*GetNodesResponse) String ¶
func (x *GetNodesResponse) String() string
type GetTablesOfShardsRequest ¶
type GetTablesOfShardsRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` ShardIds []uint32 `protobuf:"varint,2,rep,packed,name=shard_ids,json=shardIds,proto3" json:"shard_ids,omitempty"` // contains filtered or unexported fields }
func (*GetTablesOfShardsRequest) Descriptor
deprecated
func (*GetTablesOfShardsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTablesOfShardsRequest.ProtoReflect.Descriptor instead.
func (*GetTablesOfShardsRequest) GetHeader ¶
func (x *GetTablesOfShardsRequest) GetHeader() *RequestHeader
func (*GetTablesOfShardsRequest) GetShardIds ¶
func (x *GetTablesOfShardsRequest) GetShardIds() []uint32
func (*GetTablesOfShardsRequest) ProtoMessage ¶
func (*GetTablesOfShardsRequest) ProtoMessage()
func (*GetTablesOfShardsRequest) ProtoReflect ¶
func (x *GetTablesOfShardsRequest) ProtoReflect() protoreflect.Message
func (*GetTablesOfShardsRequest) Reset ¶
func (x *GetTablesOfShardsRequest) Reset()
func (*GetTablesOfShardsRequest) String ¶
func (x *GetTablesOfShardsRequest) String() string
type GetTablesOfShardsResponse ¶
type GetTablesOfShardsResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // ShardId -> TablesOfShard TablesByShard map[uint32]*TablesOfShard `` /* 191-byte string literal not displayed */ // contains filtered or unexported fields }
func (*GetTablesOfShardsResponse) Descriptor
deprecated
func (*GetTablesOfShardsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTablesOfShardsResponse.ProtoReflect.Descriptor instead.
func (*GetTablesOfShardsResponse) GetHeader ¶
func (x *GetTablesOfShardsResponse) GetHeader() *commonpb.ResponseHeader
func (*GetTablesOfShardsResponse) GetTablesByShard ¶
func (x *GetTablesOfShardsResponse) GetTablesByShard() map[uint32]*TablesOfShard
func (*GetTablesOfShardsResponse) ProtoMessage ¶
func (*GetTablesOfShardsResponse) ProtoMessage()
func (*GetTablesOfShardsResponse) ProtoReflect ¶
func (x *GetTablesOfShardsResponse) ProtoReflect() protoreflect.Message
func (*GetTablesOfShardsResponse) Reset ¶
func (x *GetTablesOfShardsResponse) Reset()
func (*GetTablesOfShardsResponse) String ¶
func (x *GetTablesOfShardsResponse) String() string
type MetaRpcServiceClient ¶
type MetaRpcServiceClient interface { AllocSchemaID(ctx context.Context, in *AllocSchemaIdRequest, opts ...grpc.CallOption) (*AllocSchemaIdResponse, error) GetTablesOfShards(ctx context.Context, in *GetTablesOfShardsRequest, opts ...grpc.CallOption) (*GetTablesOfShardsResponse, error) CreateTable(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*CreateTableResponse, error) DropTable(ctx context.Context, in *DropTableRequest, opts ...grpc.CallOption) (*DropTableResponse, error) RouteTables(ctx context.Context, in *RouteTablesRequest, opts ...grpc.CallOption) (*RouteTablesResponse, error) GetNodes(ctx context.Context, in *GetNodesRequest, opts ...grpc.CallOption) (*GetNodesResponse, error) NodeHeartbeat(ctx context.Context, in *NodeHeartbeatRequest, opts ...grpc.CallOption) (*NodeHeartbeatResponse, error) }
MetaRpcServiceClient is the client API for MetaRpcService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMetaRpcServiceClient ¶
func NewMetaRpcServiceClient(cc grpc.ClientConnInterface) MetaRpcServiceClient
type MetaRpcServiceServer ¶
type MetaRpcServiceServer interface { AllocSchemaID(context.Context, *AllocSchemaIdRequest) (*AllocSchemaIdResponse, error) GetTablesOfShards(context.Context, *GetTablesOfShardsRequest) (*GetTablesOfShardsResponse, error) CreateTable(context.Context, *CreateTableRequest) (*CreateTableResponse, error) DropTable(context.Context, *DropTableRequest) (*DropTableResponse, error) RouteTables(context.Context, *RouteTablesRequest) (*RouteTablesResponse, error) GetNodes(context.Context, *GetNodesRequest) (*GetNodesResponse, error) NodeHeartbeat(context.Context, *NodeHeartbeatRequest) (*NodeHeartbeatResponse, error) // contains filtered or unexported methods }
MetaRpcServiceServer is the server API for MetaRpcService service. All implementations must embed UnimplementedMetaRpcServiceServer for forward compatibility
type NodeHeartbeatRequest ¶
type NodeHeartbeatRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Info *NodeInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*NodeHeartbeatRequest) Descriptor
deprecated
func (*NodeHeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use NodeHeartbeatRequest.ProtoReflect.Descriptor instead.
func (*NodeHeartbeatRequest) GetHeader ¶
func (x *NodeHeartbeatRequest) GetHeader() *RequestHeader
func (*NodeHeartbeatRequest) GetInfo ¶
func (x *NodeHeartbeatRequest) GetInfo() *NodeInfo
func (*NodeHeartbeatRequest) ProtoMessage ¶
func (*NodeHeartbeatRequest) ProtoMessage()
func (*NodeHeartbeatRequest) ProtoReflect ¶
func (x *NodeHeartbeatRequest) ProtoReflect() protoreflect.Message
func (*NodeHeartbeatRequest) Reset ¶
func (x *NodeHeartbeatRequest) Reset()
func (*NodeHeartbeatRequest) String ¶
func (x *NodeHeartbeatRequest) String() string
type NodeHeartbeatResponse ¶
type NodeHeartbeatResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // contains filtered or unexported fields }
func (*NodeHeartbeatResponse) Descriptor
deprecated
func (*NodeHeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use NodeHeartbeatResponse.ProtoReflect.Descriptor instead.
func (*NodeHeartbeatResponse) GetHeader ¶
func (x *NodeHeartbeatResponse) GetHeader() *commonpb.ResponseHeader
func (*NodeHeartbeatResponse) ProtoMessage ¶
func (*NodeHeartbeatResponse) ProtoMessage()
func (*NodeHeartbeatResponse) ProtoReflect ¶
func (x *NodeHeartbeatResponse) ProtoReflect() protoreflect.Message
func (*NodeHeartbeatResponse) Reset ¶
func (x *NodeHeartbeatResponse) Reset()
func (*NodeHeartbeatResponse) String ¶
func (x *NodeHeartbeatResponse) String() string
type NodeInfo ¶
type NodeInfo struct { // ip:port Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` Lease uint32 `protobuf:"varint,2,opt,name=lease,proto3" json:"lease,omitempty"` Zone string `protobuf:"bytes,3,opt,name=zone,proto3" json:"zone,omitempty"` BinaryVersion string `protobuf:"bytes,4,opt,name=binary_version,json=binaryVersion,proto3" json:"binary_version,omitempty"` ShardInfos []*ShardInfo `protobuf:"bytes,5,rep,name=shard_infos,json=shardInfos,proto3" json:"shard_infos,omitempty"` ClusterType NodeInfo_ClusterType `` /* 134-byte string literal not displayed */ // contains filtered or unexported fields }
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) GetBinaryVersion ¶
func (*NodeInfo) GetClusterType ¶
func (x *NodeInfo) GetClusterType() NodeInfo_ClusterType
func (*NodeInfo) GetEndpoint ¶
func (*NodeInfo) GetShardInfos ¶
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
type NodeInfo_ClusterType ¶
type NodeInfo_ClusterType int32
Type of server in cluster mode.
const ( NodeInfo_HoraeDB NodeInfo_ClusterType = 0 NodeInfo_CompactionServer NodeInfo_ClusterType = 1 )
func (NodeInfo_ClusterType) Descriptor ¶
func (NodeInfo_ClusterType) Descriptor() protoreflect.EnumDescriptor
func (NodeInfo_ClusterType) Enum ¶
func (x NodeInfo_ClusterType) Enum() *NodeInfo_ClusterType
func (NodeInfo_ClusterType) EnumDescriptor
deprecated
func (NodeInfo_ClusterType) EnumDescriptor() ([]byte, []int)
Deprecated: Use NodeInfo_ClusterType.Descriptor instead.
func (NodeInfo_ClusterType) Number ¶
func (x NodeInfo_ClusterType) Number() protoreflect.EnumNumber
func (NodeInfo_ClusterType) String ¶
func (x NodeInfo_ClusterType) String() string
func (NodeInfo_ClusterType) Type ¶
func (NodeInfo_ClusterType) Type() protoreflect.EnumType
type NodeShard ¶
type NodeShard struct { Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` ShardInfo *ShardInfo `protobuf:"bytes,2,opt,name=shard_info,json=shardInfo,proto3" json:"shard_info,omitempty"` // contains filtered or unexported fields }
func (*NodeShard) Descriptor
deprecated
func (*NodeShard) GetEndpoint ¶
func (*NodeShard) GetShardInfo ¶
func (*NodeShard) ProtoMessage ¶
func (*NodeShard) ProtoMessage()
func (*NodeShard) ProtoReflect ¶
func (x *NodeShard) ProtoReflect() protoreflect.Message
type PartitionTableInfo ¶
type PartitionTableInfo struct { PartitionInfo *clusterpb.PartitionInfo `protobuf:"bytes,1,opt,name=partition_info,json=partitionInfo,proto3" json:"partition_info,omitempty"` SubTableNames []string `protobuf:"bytes,2,rep,name=sub_table_names,json=subTableNames,proto3" json:"sub_table_names,omitempty"` // contains filtered or unexported fields }
func (*PartitionTableInfo) Descriptor
deprecated
func (*PartitionTableInfo) Descriptor() ([]byte, []int)
Deprecated: Use PartitionTableInfo.ProtoReflect.Descriptor instead.
func (*PartitionTableInfo) GetPartitionInfo ¶
func (x *PartitionTableInfo) GetPartitionInfo() *clusterpb.PartitionInfo
func (*PartitionTableInfo) GetSubTableNames ¶
func (x *PartitionTableInfo) GetSubTableNames() []string
func (*PartitionTableInfo) ProtoMessage ¶
func (*PartitionTableInfo) ProtoMessage()
func (*PartitionTableInfo) ProtoReflect ¶
func (x *PartitionTableInfo) ProtoReflect() protoreflect.Message
func (*PartitionTableInfo) Reset ¶
func (x *PartitionTableInfo) Reset()
func (*PartitionTableInfo) String ¶
func (x *PartitionTableInfo) String() string
type RequestHeader ¶
type RequestHeader struct { Node string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"` ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"` // contains filtered or unexported fields }
func (*RequestHeader) Descriptor
deprecated
func (*RequestHeader) Descriptor() ([]byte, []int)
Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.
func (*RequestHeader) GetClusterName ¶
func (x *RequestHeader) GetClusterName() string
func (*RequestHeader) GetNode ¶
func (x *RequestHeader) GetNode() string
func (*RequestHeader) ProtoMessage ¶
func (*RequestHeader) ProtoMessage()
func (*RequestHeader) ProtoReflect ¶
func (x *RequestHeader) ProtoReflect() protoreflect.Message
func (*RequestHeader) Reset ¶
func (x *RequestHeader) Reset()
func (*RequestHeader) String ¶
func (x *RequestHeader) String() string
type RouteEntry ¶
type RouteEntry struct { Table *TableInfo `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` NodeShards []*NodeShard `protobuf:"bytes,2,rep,name=node_shards,json=nodeShards,proto3" json:"node_shards,omitempty"` // contains filtered or unexported fields }
func (*RouteEntry) Descriptor
deprecated
func (*RouteEntry) Descriptor() ([]byte, []int)
Deprecated: Use RouteEntry.ProtoReflect.Descriptor instead.
func (*RouteEntry) GetNodeShards ¶
func (x *RouteEntry) GetNodeShards() []*NodeShard
func (*RouteEntry) GetTable ¶
func (x *RouteEntry) GetTable() *TableInfo
func (*RouteEntry) ProtoMessage ¶
func (*RouteEntry) ProtoMessage()
func (*RouteEntry) ProtoReflect ¶
func (x *RouteEntry) ProtoReflect() protoreflect.Message
func (*RouteEntry) Reset ¶
func (x *RouteEntry) Reset()
func (*RouteEntry) String ¶
func (x *RouteEntry) String() string
type RouteTablesRequest ¶
type RouteTablesRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` SchemaName string `protobuf:"bytes,2,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` TableNames []string `protobuf:"bytes,3,rep,name=table_names,json=tableNames,proto3" json:"table_names,omitempty"` // contains filtered or unexported fields }
func (*RouteTablesRequest) Descriptor
deprecated
func (*RouteTablesRequest) Descriptor() ([]byte, []int)
Deprecated: Use RouteTablesRequest.ProtoReflect.Descriptor instead.
func (*RouteTablesRequest) GetHeader ¶
func (x *RouteTablesRequest) GetHeader() *RequestHeader
func (*RouteTablesRequest) GetSchemaName ¶
func (x *RouteTablesRequest) GetSchemaName() string
func (*RouteTablesRequest) GetTableNames ¶
func (x *RouteTablesRequest) GetTableNames() []string
func (*RouteTablesRequest) ProtoMessage ¶
func (*RouteTablesRequest) ProtoMessage()
func (*RouteTablesRequest) ProtoReflect ¶
func (x *RouteTablesRequest) ProtoReflect() protoreflect.Message
func (*RouteTablesRequest) Reset ¶
func (x *RouteTablesRequest) Reset()
func (*RouteTablesRequest) String ¶
func (x *RouteTablesRequest) String() string
type RouteTablesResponse ¶
type RouteTablesResponse struct { Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` ClusterTopologyVersion uint64 `` /* 130-byte string literal not displayed */ // TableName -> RouteEntry Entries map[string]*RouteEntry `` /* 155-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RouteTablesResponse) Descriptor
deprecated
func (*RouteTablesResponse) Descriptor() ([]byte, []int)
Deprecated: Use RouteTablesResponse.ProtoReflect.Descriptor instead.
func (*RouteTablesResponse) GetClusterTopologyVersion ¶
func (x *RouteTablesResponse) GetClusterTopologyVersion() uint64
func (*RouteTablesResponse) GetEntries ¶
func (x *RouteTablesResponse) GetEntries() map[string]*RouteEntry
func (*RouteTablesResponse) GetHeader ¶
func (x *RouteTablesResponse) GetHeader() *commonpb.ResponseHeader
func (*RouteTablesResponse) ProtoMessage ¶
func (*RouteTablesResponse) ProtoMessage()
func (*RouteTablesResponse) ProtoReflect ¶
func (x *RouteTablesResponse) ProtoReflect() protoreflect.Message
func (*RouteTablesResponse) Reset ¶
func (x *RouteTablesResponse) Reset()
func (*RouteTablesResponse) String ¶
func (x *RouteTablesResponse) String() string
type ShardInfo ¶
type ShardInfo struct { Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Role clusterpb.ShardRole `protobuf:"varint,2,opt,name=role,proto3,enum=cluster.ShardRole" json:"role,omitempty"` Version uint64 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"` // When status is missing, it means Ready Status *ShardInfo_Status `protobuf:"varint,4,opt,name=status,proto3,enum=meta_service.ShardInfo_Status,oneof" json:"status,omitempty"` // contains filtered or unexported fields }
func (*ShardInfo) Descriptor
deprecated
func (*ShardInfo) GetStatus ¶
func (x *ShardInfo) GetStatus() ShardInfo_Status
func (*ShardInfo) GetVersion ¶
func (*ShardInfo) ProtoMessage ¶
func (*ShardInfo) ProtoMessage()
func (*ShardInfo) ProtoReflect ¶
func (x *ShardInfo) ProtoReflect() protoreflect.Message
type ShardInfo_Status ¶
type ShardInfo_Status int32
const ( ShardInfo_Ready ShardInfo_Status = 0 ShardInfo_PartialOpen ShardInfo_Status = 1 )
func (ShardInfo_Status) Descriptor ¶
func (ShardInfo_Status) Descriptor() protoreflect.EnumDescriptor
func (ShardInfo_Status) Enum ¶
func (x ShardInfo_Status) Enum() *ShardInfo_Status
func (ShardInfo_Status) EnumDescriptor
deprecated
func (ShardInfo_Status) EnumDescriptor() ([]byte, []int)
Deprecated: Use ShardInfo_Status.Descriptor instead.
func (ShardInfo_Status) Number ¶
func (x ShardInfo_Status) Number() protoreflect.EnumNumber
func (ShardInfo_Status) String ¶
func (x ShardInfo_Status) String() string
func (ShardInfo_Status) Type ¶
func (ShardInfo_Status) Type() protoreflect.EnumType
type TableInfo ¶
type TableInfo struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` SchemaId uint32 `protobuf:"varint,3,opt,name=schema_id,json=schemaId,proto3" json:"schema_id,omitempty"` SchemaName string `protobuf:"bytes,4,opt,name=schema_name,json=schemaName,proto3" json:"schema_name,omitempty"` PartitionInfo *clusterpb.PartitionInfo `protobuf:"bytes,5,opt,name=partition_info,json=partitionInfo,proto3" json:"partition_info,omitempty"` // contains filtered or unexported fields }
func (*TableInfo) Descriptor
deprecated
func (*TableInfo) GetPartitionInfo ¶
func (x *TableInfo) GetPartitionInfo() *clusterpb.PartitionInfo
func (*TableInfo) GetSchemaId ¶
func (*TableInfo) GetSchemaName ¶
func (*TableInfo) ProtoMessage ¶
func (*TableInfo) ProtoMessage()
func (*TableInfo) ProtoReflect ¶
func (x *TableInfo) ProtoReflect() protoreflect.Message
type TablesOfShard ¶
type TablesOfShard struct { ShardInfo *ShardInfo `protobuf:"bytes,1,opt,name=shard_info,json=shardInfo,proto3" json:"shard_info,omitempty"` Tables []*TableInfo `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"` // contains filtered or unexported fields }
func (*TablesOfShard) Descriptor
deprecated
func (*TablesOfShard) Descriptor() ([]byte, []int)
Deprecated: Use TablesOfShard.ProtoReflect.Descriptor instead.
func (*TablesOfShard) GetShardInfo ¶
func (x *TablesOfShard) GetShardInfo() *ShardInfo
func (*TablesOfShard) GetTables ¶
func (x *TablesOfShard) GetTables() []*TableInfo
func (*TablesOfShard) ProtoMessage ¶
func (*TablesOfShard) ProtoMessage()
func (*TablesOfShard) ProtoReflect ¶
func (x *TablesOfShard) ProtoReflect() protoreflect.Message
func (*TablesOfShard) Reset ¶
func (x *TablesOfShard) Reset()
func (*TablesOfShard) String ¶
func (x *TablesOfShard) String() string
type UnimplementedMetaRpcServiceServer ¶
type UnimplementedMetaRpcServiceServer struct { }
UnimplementedMetaRpcServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMetaRpcServiceServer) AllocSchemaID ¶
func (UnimplementedMetaRpcServiceServer) AllocSchemaID(context.Context, *AllocSchemaIdRequest) (*AllocSchemaIdResponse, error)
func (UnimplementedMetaRpcServiceServer) CreateTable ¶
func (UnimplementedMetaRpcServiceServer) CreateTable(context.Context, *CreateTableRequest) (*CreateTableResponse, error)
func (UnimplementedMetaRpcServiceServer) DropTable ¶
func (UnimplementedMetaRpcServiceServer) DropTable(context.Context, *DropTableRequest) (*DropTableResponse, error)
func (UnimplementedMetaRpcServiceServer) GetNodes ¶
func (UnimplementedMetaRpcServiceServer) GetNodes(context.Context, *GetNodesRequest) (*GetNodesResponse, error)
func (UnimplementedMetaRpcServiceServer) GetTablesOfShards ¶
func (UnimplementedMetaRpcServiceServer) GetTablesOfShards(context.Context, *GetTablesOfShardsRequest) (*GetTablesOfShardsResponse, error)
func (UnimplementedMetaRpcServiceServer) NodeHeartbeat ¶
func (UnimplementedMetaRpcServiceServer) NodeHeartbeat(context.Context, *NodeHeartbeatRequest) (*NodeHeartbeatResponse, error)
func (UnimplementedMetaRpcServiceServer) RouteTables ¶
func (UnimplementedMetaRpcServiceServer) RouteTables(context.Context, *RouteTablesRequest) (*RouteTablesResponse, error)
type UnsafeMetaRpcServiceServer ¶
type UnsafeMetaRpcServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMetaRpcServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetaRpcServiceServer will result in compilation errors.