Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterClusterMetaServiceServer(s grpc.ServiceRegistrar, srv ClusterMetaServiceServer)
- type ClusterInfo
- func (*ClusterInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ClusterInfo) GetShardMap() map[string]*ShardInfo
- func (m *ClusterInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ClusterInfo) MarshalToVT(dAtA []byte) (int, error)
- func (m *ClusterInfo) MarshalVT() (dAtA []byte, err error)
- func (*ClusterInfo) ProtoMessage()
- func (x *ClusterInfo) ProtoReflect() protoreflect.Message
- func (x *ClusterInfo) Reset()
- func (m *ClusterInfo) SizeVT() (n int)
- func (x *ClusterInfo) String() string
- func (m *ClusterInfo) UnmarshalVT(dAtA []byte) error
- type ClusterMetaServiceClient
- type ClusterMetaServiceServer
- type GetClusterInfoRequest
- func (*GetClusterInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (m *GetClusterInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetClusterInfoRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetClusterInfoRequest) MarshalVT() (dAtA []byte, err error)
- func (*GetClusterInfoRequest) ProtoMessage()
- func (x *GetClusterInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetClusterInfoRequest) Reset()
- func (m *GetClusterInfoRequest) SizeVT() (n int)
- func (x *GetClusterInfoRequest) String() string
- func (m *GetClusterInfoRequest) UnmarshalVT(dAtA []byte) error
- type GetClusterInfoResponse
- func (*GetClusterInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetClusterInfoResponse) GetInfo() *ClusterInfo
- func (m *GetClusterInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetClusterInfoResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetClusterInfoResponse) MarshalVT() (dAtA []byte, err error)
- func (*GetClusterInfoResponse) ProtoMessage()
- func (x *GetClusterInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetClusterInfoResponse) Reset()
- func (m *GetClusterInfoResponse) SizeVT() (n int)
- func (x *GetClusterInfoResponse) String() string
- func (m *GetClusterInfoResponse) UnmarshalVT(dAtA []byte) error
- type GetShardInfoRequest
- func (*GetShardInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (m *GetShardInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetShardInfoRequest) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetShardInfoRequest) MarshalVT() (dAtA []byte, err error)
- func (*GetShardInfoRequest) ProtoMessage()
- func (x *GetShardInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetShardInfoRequest) Reset()
- func (m *GetShardInfoRequest) SizeVT() (n int)
- func (x *GetShardInfoRequest) String() string
- func (m *GetShardInfoRequest) UnmarshalVT(dAtA []byte) error
- type GetShardInfoResponse
- func (*GetShardInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetShardInfoResponse) GetInfo() *ShardInfo
- func (m *GetShardInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GetShardInfoResponse) MarshalToVT(dAtA []byte) (int, error)
- func (m *GetShardInfoResponse) MarshalVT() (dAtA []byte, err error)
- func (*GetShardInfoResponse) ProtoMessage()
- func (x *GetShardInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetShardInfoResponse) Reset()
- func (m *GetShardInfoResponse) SizeVT() (n int)
- func (x *GetShardInfoResponse) String() string
- func (m *GetShardInfoResponse) UnmarshalVT(dAtA []byte) error
- type GossipMeta
- func (*GossipMeta) Descriptor() ([]byte, []int)deprecated
- func (x *GossipMeta) GetUrl() string
- func (m *GossipMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *GossipMeta) MarshalToVT(dAtA []byte) (int, error)
- func (m *GossipMeta) MarshalVT() (dAtA []byte, err error)
- func (*GossipMeta) ProtoMessage()
- func (x *GossipMeta) ProtoReflect() protoreflect.Message
- func (x *GossipMeta) Reset()
- func (m *GossipMeta) SizeVT() (n int)
- func (x *GossipMeta) String() string
- func (m *GossipMeta) UnmarshalVT(dAtA []byte) error
- type MemberInfo
- func (*MemberInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MemberInfo) GetAddress() string
- func (x *MemberInfo) GetNodeId() string
- func (m *MemberInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *MemberInfo) MarshalToVT(dAtA []byte) (int, error)
- func (m *MemberInfo) MarshalVT() (dAtA []byte, err error)
- func (*MemberInfo) ProtoMessage()
- func (x *MemberInfo) ProtoReflect() protoreflect.Message
- func (x *MemberInfo) Reset()
- func (m *MemberInfo) SizeVT() (n int)
- func (x *MemberInfo) String() string
- func (m *MemberInfo) UnmarshalVT(dAtA []byte) error
- type ShardInfo
- func (*ShardInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ShardInfo) GetLeaderId() string
- func (x *ShardInfo) GetMemberAddressMap() map[string]*MemberInfo
- func (x *ShardInfo) GetNodeId() string
- func (x *ShardInfo) GetShardId() string
- func (m *ShardInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ShardInfo) MarshalToVT(dAtA []byte) (int, error)
- func (m *ShardInfo) MarshalVT() (dAtA []byte, err error)
- func (*ShardInfo) ProtoMessage()
- func (x *ShardInfo) ProtoReflect() protoreflect.Message
- func (x *ShardInfo) Reset()
- func (m *ShardInfo) SizeVT() (n int)
- func (x *ShardInfo) String() string
- func (m *ShardInfo) UnmarshalVT(dAtA []byte) error
- type UnimplementedClusterMetaServiceServer
- type UnsafeClusterMetaServiceServer
Constants ¶
const ( ClusterMetaService_GetClusterInfo_FullMethodName = "/cluster.ClusterMetaService/GetClusterInfo" ClusterMetaService_GetShardInfo_FullMethodName = "/cluster.ClusterMetaService/GetShardInfo" )
Variables ¶
var ( ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflow = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") )
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)
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) GetLeaderId ¶
func (*ShardInfo) GetMemberAddressMap ¶
func (x *ShardInfo) GetMemberAddressMap() map[string]*MemberInfo
func (*ShardInfo) GetShardId ¶
func (*ShardInfo) MarshalToSizedBufferVT ¶
func (*ShardInfo) ProtoMessage ¶
func (*ShardInfo) ProtoMessage()
func (*ShardInfo) ProtoReflect ¶
func (x *ShardInfo) ProtoReflect() protoreflect.Message
func (*ShardInfo) UnmarshalVT ¶
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.