proto

package
v0.0.0-...-3d1347b Latest Latest
Warning

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

 Go to latest Published: May 5, 2023 License: Apache-2.0 Imports: 11 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	ClusterMetaService_GetClusterInfo_FullMethodName = "/cluster.ClusterMetaService/GetClusterInfo"
	ClusterMetaService_GetShardInfo_FullMethodName   = "/cluster.ClusterMetaService/GetShardInfo"
)

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ClusterMetaService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cluster.ClusterMetaService",
	HandlerType: (*ClusterMetaServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetClusterInfo",
			Handler:    _ClusterMetaService_GetClusterInfo_Handler,
		},
		{
			MethodName: "GetShardInfo",
			Handler:    _ClusterMetaService_GetShardInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cluster.proto",
}

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

View Source 
var File_cluster_proto protoreflect.FileDescriptor

Functions

func RegisterClusterMetaServiceServer 

func RegisterClusterMetaServiceServer(s grpc.ServiceRegistrar, srv ClusterMetaServiceServer)

Types

type ClusterInfo 

type ClusterInfo struct {
	ShardMap map[string]*ShardInfo `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ClusterInfo) Descriptor deprecated 

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

Deprecated: Use ClusterInfo.ProtoReflect.Descriptor instead.

func (*ClusterInfo) GetShardMap 

func (x *ClusterInfo) GetShardMap() map[string]*ShardInfo

func (*ClusterInfo) MarshalToSizedBufferVT 

func (m *ClusterInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ClusterInfo) MarshalToVT 

func (m *ClusterInfo) MarshalToVT(dAtA []byte) (int, error)

func (*ClusterInfo) MarshalVT 

func (m *ClusterInfo) MarshalVT() (dAtA []byte, err error)

func (*ClusterInfo) ProtoMessage 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) ProtoReflect 

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

func (*ClusterInfo) Reset 

func (x *ClusterInfo) Reset()

func (*ClusterInfo) SizeVT 

func (m *ClusterInfo) SizeVT() (n int)

func (*ClusterInfo) String 

func (x *ClusterInfo) String() string

func (*ClusterInfo) UnmarshalVT 

func (m *ClusterInfo) UnmarshalVT(dAtA []byte) error

type ClusterMetaServiceClient 

type ClusterMetaServiceClient interface {
	GetClusterInfo(ctx context.Context, in *GetClusterInfoRequest, opts ...grpc.CallOption) (*GetClusterInfoResponse, error)
	GetShardInfo(ctx context.Context, in *GetShardInfoRequest, opts ...grpc.CallOption) (*GetShardInfoResponse, error)
}

ClusterMetaServiceClient is the client API for ClusterMetaService 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 NewClusterMetaServiceClient 

func NewClusterMetaServiceClient(cc grpc.ClientConnInterface) ClusterMetaServiceClient

type ClusterMetaServiceServer 

type ClusterMetaServiceServer interface {
	GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)
	GetShardInfo(context.Context, *GetShardInfoRequest) (*GetShardInfoResponse, error)
	// contains filtered or unexported methods
}

ClusterMetaServiceServer is the server API for ClusterMetaService service. All implementations must embed UnimplementedClusterMetaServiceServer for forward compatibility

type GetClusterInfoRequest 

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

func (*GetClusterInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetClusterInfoRequest.ProtoReflect.Descriptor instead.

func (*GetClusterInfoRequest) MarshalToSizedBufferVT 

func (m *GetClusterInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetClusterInfoRequest) MarshalToVT 

func (m *GetClusterInfoRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetClusterInfoRequest) MarshalVT 

func (m *GetClusterInfoRequest) MarshalVT() (dAtA []byte, err error)

func (*GetClusterInfoRequest) ProtoMessage 

func (*GetClusterInfoRequest) ProtoMessage()

func (*GetClusterInfoRequest) ProtoReflect 

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

func (*GetClusterInfoRequest) Reset 

func (x *GetClusterInfoRequest) Reset()

func (*GetClusterInfoRequest) SizeVT 

func (m *GetClusterInfoRequest) SizeVT() (n int)

func (*GetClusterInfoRequest) String 

func (x *GetClusterInfoRequest) String() string

func (*GetClusterInfoRequest) UnmarshalVT 

func (m *GetClusterInfoRequest) UnmarshalVT(dAtA []byte) error

type GetClusterInfoResponse 

type GetClusterInfoResponse struct {
	Info *ClusterInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetClusterInfoResponse.ProtoReflect.Descriptor instead.

func (*GetClusterInfoResponse) GetInfo 

func (x *GetClusterInfoResponse) GetInfo() *ClusterInfo

func (*GetClusterInfoResponse) MarshalToSizedBufferVT 

func (m *GetClusterInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetClusterInfoResponse) MarshalToVT 

func (m *GetClusterInfoResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetClusterInfoResponse) MarshalVT 

func (m *GetClusterInfoResponse) MarshalVT() (dAtA []byte, err error)

func (*GetClusterInfoResponse) ProtoMessage 

func (*GetClusterInfoResponse) ProtoMessage()

func (*GetClusterInfoResponse) ProtoReflect 

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

func (*GetClusterInfoResponse) Reset 

func (x *GetClusterInfoResponse) Reset()

func (*GetClusterInfoResponse) SizeVT 

func (m *GetClusterInfoResponse) SizeVT() (n int)

func (*GetClusterInfoResponse) String 

func (x *GetClusterInfoResponse) String() string

func (*GetClusterInfoResponse) UnmarshalVT 

func (m *GetClusterInfoResponse) UnmarshalVT(dAtA []byte) error

type GetShardInfoRequest 

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

func (*GetShardInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetShardInfoRequest.ProtoReflect.Descriptor instead.

func (*GetShardInfoRequest) MarshalToSizedBufferVT 

func (m *GetShardInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetShardInfoRequest) MarshalToVT 

func (m *GetShardInfoRequest) MarshalToVT(dAtA []byte) (int, error)

func (*GetShardInfoRequest) MarshalVT 

func (m *GetShardInfoRequest) MarshalVT() (dAtA []byte, err error)

func (*GetShardInfoRequest) ProtoMessage 

func (*GetShardInfoRequest) ProtoMessage()

func (*GetShardInfoRequest) ProtoReflect 

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

func (*GetShardInfoRequest) Reset 

func (x *GetShardInfoRequest) Reset()

func (*GetShardInfoRequest) SizeVT 

func (m *GetShardInfoRequest) SizeVT() (n int)

func (*GetShardInfoRequest) String 

func (x *GetShardInfoRequest) String() string

func (*GetShardInfoRequest) UnmarshalVT 

func (m *GetShardInfoRequest) UnmarshalVT(dAtA []byte) error

type GetShardInfoResponse 

type GetShardInfoResponse struct {
	Info *ShardInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*GetShardInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetShardInfoResponse.ProtoReflect.Descriptor instead.

func (*GetShardInfoResponse) GetInfo 

func (x *GetShardInfoResponse) GetInfo() *ShardInfo

func (*GetShardInfoResponse) MarshalToSizedBufferVT 

func (m *GetShardInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GetShardInfoResponse) MarshalToVT 

func (m *GetShardInfoResponse) MarshalToVT(dAtA []byte) (int, error)

func (*GetShardInfoResponse) MarshalVT 

func (m *GetShardInfoResponse) MarshalVT() (dAtA []byte, err error)

func (*GetShardInfoResponse) ProtoMessage 

func (*GetShardInfoResponse) ProtoMessage()

func (*GetShardInfoResponse) ProtoReflect 

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

func (*GetShardInfoResponse) Reset 

func (x *GetShardInfoResponse) Reset()

func (*GetShardInfoResponse) SizeVT 

func (m *GetShardInfoResponse) SizeVT() (n int)

func (*GetShardInfoResponse) String 

func (x *GetShardInfoResponse) String() string

func (*GetShardInfoResponse) UnmarshalVT 

func (m *GetShardInfoResponse) UnmarshalVT(dAtA []byte) error

type GossipMeta 

type GossipMeta struct {
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

func (*GossipMeta) Descriptor deprecated 

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

Deprecated: Use GossipMeta.ProtoReflect.Descriptor instead.

func (*GossipMeta) GetUrl 

func (x *GossipMeta) GetUrl() string

func (*GossipMeta) MarshalToSizedBufferVT 

func (m *GossipMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*GossipMeta) MarshalToVT 

func (m *GossipMeta) MarshalToVT(dAtA []byte) (int, error)

func (*GossipMeta) MarshalVT 

func (m *GossipMeta) MarshalVT() (dAtA []byte, err error)

func (*GossipMeta) ProtoMessage 

func (*GossipMeta) ProtoMessage()

func (*GossipMeta) ProtoReflect 

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

func (*GossipMeta) Reset 

func (x *GossipMeta) Reset()

func (*GossipMeta) SizeVT 

func (m *GossipMeta) SizeVT() (n int)

func (*GossipMeta) String 

func (x *GossipMeta) String() string

func (*GossipMeta) UnmarshalVT 

func (m *GossipMeta) UnmarshalVT(dAtA []byte) error

type MemberInfo 

type MemberInfo struct {
	NodeId  string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberInfo) Descriptor deprecated 

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

Deprecated: Use MemberInfo.ProtoReflect.Descriptor instead.

func (*MemberInfo) GetAddress 

func (x *MemberInfo) GetAddress() string

func (*MemberInfo) GetNodeId 

func (x *MemberInfo) GetNodeId() string

func (*MemberInfo) MarshalToSizedBufferVT 

func (m *MemberInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MemberInfo) MarshalToVT 

func (m *MemberInfo) MarshalToVT(dAtA []byte) (int, error)

func (*MemberInfo) MarshalVT 

func (m *MemberInfo) MarshalVT() (dAtA []byte, err error)

func (*MemberInfo) ProtoMessage 

func (*MemberInfo) ProtoMessage()

func (*MemberInfo) ProtoReflect 

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

func (*MemberInfo) Reset 

func (x *MemberInfo) Reset()

func (*MemberInfo) SizeVT 

func (m *MemberInfo) SizeVT() (n int)

func (*MemberInfo) String 

func (x *MemberInfo) String() string

func (*MemberInfo) UnmarshalVT 

func (m *MemberInfo) UnmarshalVT(dAtA []byte) error

type ShardInfo 

type ShardInfo struct {
	MemberAddressMap map[string]*MemberInfo `` /* 173-byte string literal not displayed */
	LeaderId         string                 `protobuf:"bytes,2,opt,name=leaderId,proto3" json:"leaderId,omitempty"`
	NodeId           string                 `protobuf:"bytes,3,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	ShardId          string                 `protobuf:"bytes,4,opt,name=shardId,proto3" json:"shardId,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardInfo) Descriptor deprecated 

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

Deprecated: Use ShardInfo.ProtoReflect.Descriptor instead.

func (*ShardInfo) GetLeaderId 

func (x *ShardInfo) GetLeaderId() string

func (*ShardInfo) GetMemberAddressMap 

func (x *ShardInfo) GetMemberAddressMap() map[string]*MemberInfo

func (*ShardInfo) GetNodeId 

func (x *ShardInfo) GetNodeId() string

func (*ShardInfo) GetShardId 

func (x *ShardInfo) GetShardId() string

func (*ShardInfo) MarshalToSizedBufferVT 

func (m *ShardInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ShardInfo) MarshalToVT 

func (m *ShardInfo) MarshalToVT(dAtA []byte) (int, error)

func (*ShardInfo) MarshalVT 

func (m *ShardInfo) MarshalVT() (dAtA []byte, err error)

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) ProtoReflect 

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

func (*ShardInfo) Reset 

func (x *ShardInfo) Reset()

func (*ShardInfo) SizeVT 

func (m *ShardInfo) SizeVT() (n int)

func (*ShardInfo) String 

func (x *ShardInfo) String() string

func (*ShardInfo) UnmarshalVT 

func (m *ShardInfo) UnmarshalVT(dAtA []byte) error

type UnimplementedClusterMetaServiceServer 

type UnimplementedClusterMetaServiceServer struct {
}

UnimplementedClusterMetaServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedClusterMetaServiceServer) GetClusterInfo 

func (UnimplementedClusterMetaServiceServer) GetClusterInfo(context.Context, *GetClusterInfoRequest) (*GetClusterInfoResponse, error)

func (UnimplementedClusterMetaServiceServer) GetShardInfo 

func (UnimplementedClusterMetaServiceServer) GetShardInfo(context.Context, *GetShardInfoRequest) (*GetShardInfoResponse, error)

type UnsafeClusterMetaServiceServer 

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

UnsafeClusterMetaServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterMetaServiceServer 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.