metaservicepb

package
v0.0.0-...-b5a6581 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 20, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
var File_meta_service_proto protoreflect.FileDescriptor
View Source 
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"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

func (*NodeInfo) Descriptor() ([]byte, []int)

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetBinaryVersion 

func (x *NodeInfo) GetBinaryVersion() string

func (*NodeInfo) GetEndpoint 

func (x *NodeInfo) GetEndpoint() string

func (*NodeInfo) GetLease 

func (x *NodeInfo) GetLease() uint32

func (*NodeInfo) GetShardInfos 

func (x *NodeInfo) GetShardInfos() []*ShardInfo

func (*NodeInfo) GetZone 

func (x *NodeInfo) GetZone() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

func (x *NodeInfo) ProtoReflect() protoreflect.Message

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use NodeShard.ProtoReflect.Descriptor instead.

func (*NodeShard) GetEndpoint 

func (x *NodeShard) GetEndpoint() string

func (*NodeShard) GetShardInfo 

func (x *NodeShard) GetShardInfo() *ShardInfo

func (*NodeShard) ProtoMessage 

func (*NodeShard) ProtoMessage()

func (*NodeShard) ProtoReflect 

func (x *NodeShard) ProtoReflect() protoreflect.Message

func (*NodeShard) Reset 

func (x *NodeShard) Reset()

func (*NodeShard) String 

func (x *NodeShard) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use ShardInfo.ProtoReflect.Descriptor instead.

func (*ShardInfo) GetId 

func (x *ShardInfo) GetId() uint32

func (*ShardInfo) GetRole 

func (x *ShardInfo) GetRole() clusterpb.ShardRole

func (*ShardInfo) GetStatus 

func (x *ShardInfo) GetStatus() ShardInfo_Status

func (*ShardInfo) GetVersion 

func (x *ShardInfo) GetVersion() uint64

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) ProtoReflect 

func (x *ShardInfo) ProtoReflect() protoreflect.Message

func (*ShardInfo) Reset 

func (x *ShardInfo) Reset()

func (*ShardInfo) String 

func (x *ShardInfo) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use TableInfo.ProtoReflect.Descriptor instead.

func (*TableInfo) GetId 

func (x *TableInfo) GetId() uint64

func (*TableInfo) GetName 

func (x *TableInfo) GetName() string

func (*TableInfo) GetPartitionInfo 

func (x *TableInfo) GetPartitionInfo() *clusterpb.PartitionInfo

func (*TableInfo) GetSchemaId 

func (x *TableInfo) GetSchemaId() uint32

func (*TableInfo) GetSchemaName 

func (x *TableInfo) GetSchemaName() string

func (*TableInfo) ProtoMessage 

func (*TableInfo) ProtoMessage()

func (*TableInfo) ProtoReflect 

func (x *TableInfo) ProtoReflect() protoreflect.Message

func (*TableInfo) Reset 

func (x *TableInfo) Reset()

func (*TableInfo) String 

func (x *TableInfo) String() string

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.