metaeventpb

package
v0.0.0-...-29cb0c6 Latest Latest
Warning

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

 Go to latest Published: Oct 19, 2022 License: Apache-2.0 Imports: 10 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_meta_event_proto protoreflect.FileDescriptor
View Source 
var MetaEventService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "meta_event.MetaEventService",
	HandlerType: (*MetaEventServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "OpenShard",
			Handler:    _MetaEventService_OpenShard_Handler,
		},
		{
			MethodName: "CloseShard",
			Handler:    _MetaEventService_CloseShard_Handler,
		},
		{
			MethodName: "CreateTableOnShard",
			Handler:    _MetaEventService_CreateTableOnShard_Handler,
		},
		{
			MethodName: "DropTableOnShard",
			Handler:    _MetaEventService_DropTableOnShard_Handler,
		},
		{
			MethodName: "SplitShard",
			Handler:    _MetaEventService_SplitShard_Handler,
		},
		{
			MethodName: "MergeShards",
			Handler:    _MetaEventService_MergeShards_Handler,
		},
		{
			MethodName: "ChangeShardRole",
			Handler:    _MetaEventService_ChangeShardRole_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "meta_event.proto",
}

MetaEventService_ServiceDesc is the grpc.ServiceDesc for MetaEventService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMetaEventServiceServer 

func RegisterMetaEventServiceServer(s grpc.ServiceRegistrar, srv MetaEventServiceServer)

Types

type ChangeShardRoleRequest 

type ChangeShardRoleRequest struct {
	// contains filtered or unexported fields
}

func (*ChangeShardRoleRequest) Descriptor deprecated 

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

Deprecated: Use ChangeShardRoleRequest.ProtoReflect.Descriptor instead.

func (*ChangeShardRoleRequest) ProtoMessage 

func (*ChangeShardRoleRequest) ProtoMessage()

func (*ChangeShardRoleRequest) ProtoReflect 

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

func (*ChangeShardRoleRequest) Reset 

func (x *ChangeShardRoleRequest) Reset()

func (*ChangeShardRoleRequest) String 

func (x *ChangeShardRoleRequest) String() string

type ChangeShardRoleResponse 

type ChangeShardRoleResponse struct {
	Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeShardRoleResponse) Descriptor deprecated 

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

Deprecated: Use ChangeShardRoleResponse.ProtoReflect.Descriptor instead.

func (*ChangeShardRoleResponse) GetHeader 

func (x *ChangeShardRoleResponse) GetHeader() *commonpb.ResponseHeader

func (*ChangeShardRoleResponse) ProtoMessage 

func (*ChangeShardRoleResponse) ProtoMessage()

func (*ChangeShardRoleResponse) ProtoReflect 

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

func (*ChangeShardRoleResponse) Reset 

func (x *ChangeShardRoleResponse) Reset()

func (*ChangeShardRoleResponse) String 

func (x *ChangeShardRoleResponse) String() string

type CloseShardRequest 

type CloseShardRequest struct {
	ShardId uint32 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseShardRequest) Descriptor deprecated 

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

Deprecated: Use CloseShardRequest.ProtoReflect.Descriptor instead.

func (*CloseShardRequest) GetShardId 

func (x *CloseShardRequest) GetShardId() uint32

func (*CloseShardRequest) ProtoMessage 

func (*CloseShardRequest) ProtoMessage()

func (*CloseShardRequest) ProtoReflect 

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

func (*CloseShardRequest) Reset 

func (x *CloseShardRequest) Reset()

func (*CloseShardRequest) String 

func (x *CloseShardRequest) String() string

type CloseShardResponse 

type CloseShardResponse struct {
	Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseShardResponse) Descriptor deprecated 

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

Deprecated: Use CloseShardResponse.ProtoReflect.Descriptor instead.

func (*CloseShardResponse) GetHeader 

func (x *CloseShardResponse) GetHeader() *commonpb.ResponseHeader

func (*CloseShardResponse) ProtoMessage 

func (*CloseShardResponse) ProtoMessage()

func (*CloseShardResponse) ProtoReflect 

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

func (*CloseShardResponse) Reset 

func (x *CloseShardResponse) Reset()

func (*CloseShardResponse) String 

func (x *CloseShardResponse) String() string

type CreateTableOnShardRequest 

type CreateTableOnShardRequest struct {
	UpdateShardInfo  *UpdateShardInfo         `protobuf:"bytes,1,opt,name=update_shard_info,json=updateShardInfo,proto3" json:"update_shard_info,omitempty"`
	TableInfo        *metaservicepb.TableInfo `protobuf:"bytes,2,opt,name=table_info,json=tableInfo,proto3" json:"table_info,omitempty"`
	EncodedSchema    []byte                   `protobuf:"bytes,3,opt,name=encoded_schema,json=encodedSchema,proto3" json:"encoded_schema,omitempty"`
	Engine           string                   `protobuf:"bytes,4,opt,name=engine,proto3" json:"engine,omitempty"`
	CreateIfNotExist bool                     `protobuf:"varint,5,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 */
	// contains filtered or unexported fields
}

func (*CreateTableOnShardRequest) Descriptor deprecated 

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

Deprecated: Use CreateTableOnShardRequest.ProtoReflect.Descriptor instead.

func (*CreateTableOnShardRequest) GetCreateIfNotExist 

func (x *CreateTableOnShardRequest) GetCreateIfNotExist() bool

func (*CreateTableOnShardRequest) GetEncodedSchema 

func (x *CreateTableOnShardRequest) GetEncodedSchema() []byte

func (*CreateTableOnShardRequest) GetEngine 

func (x *CreateTableOnShardRequest) GetEngine() string

func (*CreateTableOnShardRequest) GetOptions 

func (x *CreateTableOnShardRequest) GetOptions() map[string]string

func (*CreateTableOnShardRequest) GetTableInfo 

func (x *CreateTableOnShardRequest) GetTableInfo() *metaservicepb.TableInfo

func (*CreateTableOnShardRequest) GetUpdateShardInfo 

func (x *CreateTableOnShardRequest) GetUpdateShardInfo() *UpdateShardInfo

func (*CreateTableOnShardRequest) ProtoMessage 

func (*CreateTableOnShardRequest) ProtoMessage()

func (*CreateTableOnShardRequest) ProtoReflect 

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

func (*CreateTableOnShardRequest) Reset 

func (x *CreateTableOnShardRequest) Reset()

func (*CreateTableOnShardRequest) String 

func (x *CreateTableOnShardRequest) String() string

type CreateTableOnShardResponse 

type CreateTableOnShardResponse struct {
	Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTableOnShardResponse) Descriptor deprecated 

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

Deprecated: Use CreateTableOnShardResponse.ProtoReflect.Descriptor instead.

func (*CreateTableOnShardResponse) GetHeader 

func (x *CreateTableOnShardResponse) GetHeader() *commonpb.ResponseHeader

func (*CreateTableOnShardResponse) ProtoMessage 

func (*CreateTableOnShardResponse) ProtoMessage()

func (*CreateTableOnShardResponse) ProtoReflect 

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

func (*CreateTableOnShardResponse) Reset 

func (x *CreateTableOnShardResponse) Reset()

func (*CreateTableOnShardResponse) String 

func (x *CreateTableOnShardResponse) String() string

type DropTableOnShardRequest 

type DropTableOnShardRequest struct {
	UpdateShardInfo *UpdateShardInfo         `protobuf:"bytes,1,opt,name=update_shard_info,json=updateShardInfo,proto3" json:"update_shard_info,omitempty"`
	TableInfo       *metaservicepb.TableInfo `protobuf:"bytes,2,opt,name=table_info,json=tableInfo,proto3" json:"table_info,omitempty"`
	// contains filtered or unexported fields
}

func (*DropTableOnShardRequest) Descriptor deprecated 

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

Deprecated: Use DropTableOnShardRequest.ProtoReflect.Descriptor instead.

func (*DropTableOnShardRequest) GetTableInfo 

func (x *DropTableOnShardRequest) GetTableInfo() *metaservicepb.TableInfo

func (*DropTableOnShardRequest) GetUpdateShardInfo 

func (x *DropTableOnShardRequest) GetUpdateShardInfo() *UpdateShardInfo

func (*DropTableOnShardRequest) ProtoMessage 

func (*DropTableOnShardRequest) ProtoMessage()

func (*DropTableOnShardRequest) ProtoReflect 

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

func (*DropTableOnShardRequest) Reset 

func (x *DropTableOnShardRequest) Reset()

func (*DropTableOnShardRequest) String 

func (x *DropTableOnShardRequest) String() string

type DropTableOnShardResponse 

type DropTableOnShardResponse struct {
	Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*DropTableOnShardResponse) Descriptor deprecated 

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

Deprecated: Use DropTableOnShardResponse.ProtoReflect.Descriptor instead.

func (*DropTableOnShardResponse) GetHeader 

func (x *DropTableOnShardResponse) GetHeader() *commonpb.ResponseHeader

func (*DropTableOnShardResponse) ProtoMessage 

func (*DropTableOnShardResponse) ProtoMessage()

func (*DropTableOnShardResponse) ProtoReflect 

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

func (*DropTableOnShardResponse) Reset 

func (x *DropTableOnShardResponse) Reset()

func (*DropTableOnShardResponse) String 

func (x *DropTableOnShardResponse) String() string

type MergeShardsRequest 

type MergeShardsRequest struct {
	// contains filtered or unexported fields
}

func (*MergeShardsRequest) Descriptor deprecated 

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

Deprecated: Use MergeShardsRequest.ProtoReflect.Descriptor instead.

func (*MergeShardsRequest) ProtoMessage 

func (*MergeShardsRequest) ProtoMessage()

func (*MergeShardsRequest) ProtoReflect 

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

func (*MergeShardsRequest) Reset 

func (x *MergeShardsRequest) Reset()

func (*MergeShardsRequest) String 

func (x *MergeShardsRequest) String() string

type MergeShardsResponse 

type MergeShardsResponse struct {
	Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*MergeShardsResponse) Descriptor deprecated 

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

Deprecated: Use MergeShardsResponse.ProtoReflect.Descriptor instead.

func (*MergeShardsResponse) GetHeader 

func (x *MergeShardsResponse) GetHeader() *commonpb.ResponseHeader

func (*MergeShardsResponse) ProtoMessage 

func (*MergeShardsResponse) ProtoMessage()

func (*MergeShardsResponse) ProtoReflect 

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

func (*MergeShardsResponse) Reset 

func (x *MergeShardsResponse) Reset()

func (*MergeShardsResponse) String 

func (x *MergeShardsResponse) String() string

type MetaEventServiceClient 

type MetaEventServiceClient interface {
	OpenShard(ctx context.Context, in *OpenShardRequest, opts ...grpc.CallOption) (*OpenShardResponse, error)
	CloseShard(ctx context.Context, in *CloseShardRequest, opts ...grpc.CallOption) (*CloseShardResponse, error)
	CreateTableOnShard(ctx context.Context, in *CreateTableOnShardRequest, opts ...grpc.CallOption) (*CreateTableOnShardResponse, error)
	DropTableOnShard(ctx context.Context, in *DropTableOnShardRequest, opts ...grpc.CallOption) (*DropTableOnShardResponse, error)
	SplitShard(ctx context.Context, in *SplitShardRequest, opts ...grpc.CallOption) (*SplitShardResponse, error)
	MergeShards(ctx context.Context, in *MergeShardsRequest, opts ...grpc.CallOption) (*MergeShardsResponse, error)
	ChangeShardRole(ctx context.Context, in *ChangeShardRoleRequest, opts ...grpc.CallOption) (*ChangeShardRoleResponse, error)
}

MetaEventServiceClient is the client API for MetaEventService 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 NewMetaEventServiceClient 

func NewMetaEventServiceClient(cc grpc.ClientConnInterface) MetaEventServiceClient

type MetaEventServiceServer 

type MetaEventServiceServer interface {
	OpenShard(context.Context, *OpenShardRequest) (*OpenShardResponse, error)
	CloseShard(context.Context, *CloseShardRequest) (*CloseShardResponse, error)
	CreateTableOnShard(context.Context, *CreateTableOnShardRequest) (*CreateTableOnShardResponse, error)
	DropTableOnShard(context.Context, *DropTableOnShardRequest) (*DropTableOnShardResponse, error)
	SplitShard(context.Context, *SplitShardRequest) (*SplitShardResponse, error)
	MergeShards(context.Context, *MergeShardsRequest) (*MergeShardsResponse, error)
	ChangeShardRole(context.Context, *ChangeShardRoleRequest) (*ChangeShardRoleResponse, error)
	// contains filtered or unexported methods
}

MetaEventServiceServer is the server API for MetaEventService service. All implementations must embed UnimplementedMetaEventServiceServer for forward compatibility

type OpenShardRequest 

type OpenShardRequest struct {
	Shard *metaservicepb.ShardInfo `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenShardRequest) Descriptor deprecated 

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

Deprecated: Use OpenShardRequest.ProtoReflect.Descriptor instead.

func (*OpenShardRequest) GetShard 

func (x *OpenShardRequest) GetShard() *metaservicepb.ShardInfo

func (*OpenShardRequest) ProtoMessage 

func (*OpenShardRequest) ProtoMessage()

func (*OpenShardRequest) ProtoReflect 

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

func (*OpenShardRequest) Reset 

func (x *OpenShardRequest) Reset()

func (*OpenShardRequest) String 

func (x *OpenShardRequest) String() string

type OpenShardResponse 

type OpenShardResponse struct {
	Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*OpenShardResponse) Descriptor deprecated 

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

Deprecated: Use OpenShardResponse.ProtoReflect.Descriptor instead.

func (*OpenShardResponse) GetHeader 

func (x *OpenShardResponse) GetHeader() *commonpb.ResponseHeader

func (*OpenShardResponse) ProtoMessage 

func (*OpenShardResponse) ProtoMessage()

func (*OpenShardResponse) ProtoReflect 

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

func (*OpenShardResponse) Reset 

func (x *OpenShardResponse) Reset()

func (*OpenShardResponse) String 

func (x *OpenShardResponse) String() string

type SplitShardRequest 

type SplitShardRequest struct {
	// contains filtered or unexported fields
}

func (*SplitShardRequest) Descriptor deprecated 

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

Deprecated: Use SplitShardRequest.ProtoReflect.Descriptor instead.

func (*SplitShardRequest) ProtoMessage 

func (*SplitShardRequest) ProtoMessage()

func (*SplitShardRequest) ProtoReflect 

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

func (*SplitShardRequest) Reset 

func (x *SplitShardRequest) Reset()

func (*SplitShardRequest) String 

func (x *SplitShardRequest) String() string

type SplitShardResponse 

type SplitShardResponse struct {
	Header *commonpb.ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// contains filtered or unexported fields
}

func (*SplitShardResponse) Descriptor deprecated 

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

Deprecated: Use SplitShardResponse.ProtoReflect.Descriptor instead.

func (*SplitShardResponse) GetHeader 

func (x *SplitShardResponse) GetHeader() *commonpb.ResponseHeader

func (*SplitShardResponse) ProtoMessage 

func (*SplitShardResponse) ProtoMessage()

func (*SplitShardResponse) ProtoReflect 

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

func (*SplitShardResponse) Reset 

func (x *SplitShardResponse) Reset()

func (*SplitShardResponse) String 

func (x *SplitShardResponse) String() string

type UnimplementedMetaEventServiceServer 

type UnimplementedMetaEventServiceServer struct {
}

UnimplementedMetaEventServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMetaEventServiceServer) ChangeShardRole 

func (UnimplementedMetaEventServiceServer) ChangeShardRole(context.Context, *ChangeShardRoleRequest) (*ChangeShardRoleResponse, error)

func (UnimplementedMetaEventServiceServer) CloseShard 

func (UnimplementedMetaEventServiceServer) CloseShard(context.Context, *CloseShardRequest) (*CloseShardResponse, error)

func (UnimplementedMetaEventServiceServer) CreateTableOnShard 

func (UnimplementedMetaEventServiceServer) CreateTableOnShard(context.Context, *CreateTableOnShardRequest) (*CreateTableOnShardResponse, error)

func (UnimplementedMetaEventServiceServer) DropTableOnShard 

func (UnimplementedMetaEventServiceServer) DropTableOnShard(context.Context, *DropTableOnShardRequest) (*DropTableOnShardResponse, error)

func (UnimplementedMetaEventServiceServer) MergeShards 

func (UnimplementedMetaEventServiceServer) MergeShards(context.Context, *MergeShardsRequest) (*MergeShardsResponse, error)

func (UnimplementedMetaEventServiceServer) OpenShard 

func (UnimplementedMetaEventServiceServer) OpenShard(context.Context, *OpenShardRequest) (*OpenShardResponse, error)

func (UnimplementedMetaEventServiceServer) SplitShard 

func (UnimplementedMetaEventServiceServer) SplitShard(context.Context, *SplitShardRequest) (*SplitShardResponse, error)

type UnsafeMetaEventServiceServer 

type UnsafeMetaEventServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeMetaEventServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MetaEventServiceServer will result in compilation errors.

type UpdateShardInfo 

type UpdateShardInfo struct {
	CurrShardInfo *metaservicepb.ShardInfo `protobuf:"bytes,1,opt,name=curr_shard_info,json=currShardInfo,proto3" json:"curr_shard_info,omitempty"`
	PrevVersion   uint64                   `protobuf:"varint,2,opt,name=prev_version,json=prevVersion,proto3" json:"prev_version,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateShardInfo) Descriptor deprecated 

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

Deprecated: Use UpdateShardInfo.ProtoReflect.Descriptor instead.

func (*UpdateShardInfo) GetCurrShardInfo 

func (x *UpdateShardInfo) GetCurrShardInfo() *metaservicepb.ShardInfo

func (*UpdateShardInfo) GetPrevVersion 

func (x *UpdateShardInfo) GetPrevVersion() uint64

func (*UpdateShardInfo) ProtoMessage 

func (*UpdateShardInfo) ProtoMessage()

func (*UpdateShardInfo) ProtoReflect 

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

func (*UpdateShardInfo) Reset 

func (x *UpdateShardInfo) Reset()

func (*UpdateShardInfo) String 

func (x *UpdateShardInfo) String() string

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.