metaservicepb

package
v0.0.0-...-d9b1a57 Latest Latest
Warning

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

Go to latest
Published: Aug 18, 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 (
	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.

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 (*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 (*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 (*GetTablesOfShardsResponse) GetTablesByShard

func (x *GetTablesOfShardsResponse) GetTablesByShard() map[uint32]*TablesOfShard

func (*GetTablesOfShardsResponse) ProtoMessage

func (*GetTablesOfShardsResponse) ProtoMessage()

func (*GetTablesOfShardsResponse) ProtoReflect

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.

type MetaRpcServiceServer

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetBinaryVersion

func (x *NodeInfo) GetBinaryVersion() string

func (*NodeInfo) GetClusterType

func (x *NodeInfo) GetClusterType() NodeInfo_ClusterType

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 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) Enum

func (NodeInfo_ClusterType) EnumDescriptor deprecated

func (NodeInfo_ClusterType) EnumDescriptor() ([]byte, []int)

Deprecated: Use NodeInfo_ClusterType.Descriptor instead.

func (NodeInfo_ClusterType) Number

func (NodeInfo_ClusterType) String

func (x NodeInfo_ClusterType) String() string

func (NodeInfo_ClusterType) Type

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 (*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) Enum

func (ShardInfo_Status) EnumDescriptor deprecated

func (ShardInfo_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use ShardInfo_Status.Descriptor instead.

func (ShardInfo_Status) Number

func (ShardInfo_Status) String

func (x ShardInfo_Status) String() string

func (ShardInfo_Status) Type

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) CreateTable

func (UnimplementedMetaRpcServiceServer) DropTable

func (UnimplementedMetaRpcServiceServer) GetNodes

func (UnimplementedMetaRpcServiceServer) GetTablesOfShards

func (UnimplementedMetaRpcServiceServer) NodeHeartbeat

func (UnimplementedMetaRpcServiceServer) RouteTables

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.

Jump to

Keyboard shortcuts

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