Documentation ¶
Index ¶
- Variables
- func RegisterMessageServer(s grpc.ServiceRegistrar, srv MessageServer)
- type ControllerVote
- func (*ControllerVote) Descriptor() ([]byte, []int)deprecated
- func (x *ControllerVote) GetControllerNodeId() int32
- func (x *ControllerVote) GetVoteRound() int32
- func (x *ControllerVote) GetVoterNodeId() int32
- func (*ControllerVote) ProtoMessage()
- func (x *ControllerVote) ProtoReflect() protoreflect.Message
- func (x *ControllerVote) Reset()
- func (x *ControllerVote) String() string
- type FetchServerAddressesResponse
- func (*FetchServerAddressesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchServerAddressesResponse) GetServerAddresses() []string
- func (*FetchServerAddressesResponse) ProtoMessage()
- func (x *FetchServerAddressesResponse) ProtoReflect() protoreflect.Message
- func (x *FetchServerAddressesResponse) Reset()
- func (x *FetchServerAddressesResponse) String() string
- type FetchServerNodeIdResponse
- func (*FetchServerNodeIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchServerNodeIdResponse) GetServerNodeId() int32
- func (*FetchServerNodeIdResponse) ProtoMessage()
- func (x *FetchServerNodeIdResponse) ProtoReflect() protoreflect.Message
- func (x *FetchServerNodeIdResponse) Reset()
- func (x *FetchServerNodeIdResponse) String() string
- type FetchServiceRegisterInfo
- func (*FetchServiceRegisterInfo) Descriptor() ([]byte, []int)deprecated
- func (x *FetchServiceRegisterInfo) GetLatestHeartbeatTime() int64
- func (x *FetchServiceRegisterInfo) GetServiceInstanceIp() string
- func (x *FetchServiceRegisterInfo) GetServiceInstancePort() int32
- func (x *FetchServiceRegisterInfo) GetServiceName() string
- func (*FetchServiceRegisterInfo) ProtoMessage()
- func (x *FetchServiceRegisterInfo) ProtoReflect() protoreflect.Message
- func (x *FetchServiceRegisterInfo) Reset()
- func (x *FetchServiceRegisterInfo) String() string
- type FetchServiceRegisterInfoRequest
- func (*FetchServiceRegisterInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchServiceRegisterInfoRequest) GetServiceName() string
- func (*FetchServiceRegisterInfoRequest) ProtoMessage()
- func (x *FetchServiceRegisterInfoRequest) ProtoReflect() protoreflect.Message
- func (x *FetchServiceRegisterInfoRequest) Reset()
- func (x *FetchServiceRegisterInfoRequest) String() string
- type FetchServiceRegisterInfoResponse
- func (*FetchServiceRegisterInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchServiceRegisterInfoResponse) GetInfo() []*FetchServiceRegisterInfo
- func (*FetchServiceRegisterInfoResponse) ProtoMessage()
- func (x *FetchServiceRegisterInfoResponse) ProtoReflect() protoreflect.Message
- func (x *FetchServiceRegisterInfoResponse) Reset()
- func (x *FetchServiceRegisterInfoResponse) String() string
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatRequest) GetServiceInstanceIp() string
- func (x *HeartbeatRequest) GetServiceInstancePort() int32
- func (x *HeartbeatRequest) GetServiceName() string
- func (*HeartbeatRequest) ProtoMessage()
- func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *HeartbeatRequest) Reset()
- func (x *HeartbeatRequest) String() string
- type MessageClient
- type MessageEntity
- func (*MessageEntity) Descriptor() ([]byte, []int)deprecated
- func (x *MessageEntity) GetData() []byte
- func (x *MessageEntity) GetRequestId() string
- func (x *MessageEntity) GetType() MessageEntity_MessageType
- func (*MessageEntity) ProtoMessage()
- func (x *MessageEntity) ProtoReflect() protoreflect.Message
- func (x *MessageEntity) Reset()
- func (x *MessageEntity) String() string
- type MessageEntity_MessageType
- func (MessageEntity_MessageType) Descriptor() protoreflect.EnumDescriptor
- func (x MessageEntity_MessageType) Enum() *MessageEntity_MessageType
- func (MessageEntity_MessageType) EnumDescriptor() ([]byte, []int)deprecated
- func (x MessageEntity_MessageType) Number() protoreflect.EnumNumber
- func (x MessageEntity_MessageType) String() string
- func (MessageEntity_MessageType) Type() protoreflect.EnumType
- type MessageResponse
- func (*MessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MessageResponse) GetCode() MessageResponse_ResponseCode
- func (x *MessageResponse) GetMessage() string
- func (x *MessageResponse) GetResult() *MessageEntity
- func (x *MessageResponse) GetSuccess() bool
- func (*MessageResponse) ProtoMessage()
- func (x *MessageResponse) ProtoReflect() protoreflect.Message
- func (x *MessageResponse) Reset()
- func (x *MessageResponse) String() string
- type MessageResponse_ResponseCode
- func (MessageResponse_ResponseCode) Descriptor() protoreflect.EnumDescriptor
- func (x MessageResponse_ResponseCode) Enum() *MessageResponse_ResponseCode
- func (MessageResponse_ResponseCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x MessageResponse_ResponseCode) Number() protoreflect.EnumNumber
- func (x MessageResponse_ResponseCode) String() string
- func (MessageResponse_ResponseCode) Type() protoreflect.EnumType
- type MessageServer
- type Message_SendClient
- type Message_SendServer
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterRequest) GetServiceInstanceIp() string
- func (x *RegisterRequest) GetServiceInstancePort() int32
- func (x *RegisterRequest) GetServiceName() string
- func (*RegisterRequest) ProtoMessage()
- func (x *RegisterRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterRequest) Reset()
- func (x *RegisterRequest) String() string
- type RemoteServerNode
- func (*RemoteServerNode) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteServerNode) GetClientPort() int32
- func (x *RemoteServerNode) GetInternPort() int32
- func (x *RemoteServerNode) GetIp() string
- func (x *RemoteServerNode) GetIsController() bool
- func (x *RemoteServerNode) GetIsControllerCandidate() bool
- func (x *RemoteServerNode) GetNodeId() int32
- func (*RemoteServerNode) ProtoMessage()
- func (x *RemoteServerNode) ProtoReflect() protoreflect.Message
- func (x *RemoteServerNode) Reset()
- func (x *RemoteServerNode) String() string
- type RemoteServerNodeResponse
- func (*RemoteServerNodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoteServerNodeResponse) GetCode() int32
- func (x *RemoteServerNodeResponse) GetData() *RemoteServerNode
- func (x *RemoteServerNodeResponse) GetMessage() string
- func (x *RemoteServerNodeResponse) GetSuccess() bool
- func (*RemoteServerNodeResponse) ProtoMessage()
- func (x *RemoteServerNodeResponse) ProtoReflect() protoreflect.Message
- func (x *RemoteServerNodeResponse) Reset()
- func (x *RemoteServerNodeResponse) String() string
- type ServiceChangedRequest
- func (*ServiceChangedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceChangedRequest) GetServiceInstanceAddresses() []string
- func (x *ServiceChangedRequest) GetServiceName() string
- func (*ServiceChangedRequest) ProtoMessage()
- func (x *ServiceChangedRequest) ProtoReflect() protoreflect.Message
- func (x *ServiceChangedRequest) Reset()
- func (x *ServiceChangedRequest) String() string
- type SubscribeRequest
- type SubscribeResponse
- func (*SubscribeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeResponse) GetServiceInstanceAddresses() []string
- func (*SubscribeResponse) ProtoMessage()
- func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeResponse) Reset()
- func (x *SubscribeResponse) String() string
- type TransferSlotsRequest
- func (*TransferSlotsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TransferSlotsRequest) GetSlots() string
- func (x *TransferSlotsRequest) GetTargetNodeId() int32
- func (*TransferSlotsRequest) ProtoMessage()
- func (x *TransferSlotsRequest) ProtoReflect() protoreflect.Message
- func (x *TransferSlotsRequest) Reset()
- func (x *TransferSlotsRequest) String() string
- type UnimplementedMessageServer
- type UnsafeMessageServer
- type UpdateSlotsRequest
- func (*UpdateSlotsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateSlotsRequest) GetSlotData() []byte
- func (x *UpdateSlotsRequest) GetSlotNo() int32
- func (*UpdateSlotsRequest) ProtoMessage()
- func (x *UpdateSlotsRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateSlotsRequest) Reset()
- func (x *UpdateSlotsRequest) String() string
Constants ¶
This section is empty.
Variables ¶
var ( MessageEntity_MessageType_name = map[int32]string{ 0: "TERMINATE_MESSAGE", 1: "VOTE", 2: "SLOTS_ALLOCATION", 3: "NODE_SLOTS", 4: "SLOTS_REPLICA_ALLOCATION", 5: "NODE_SLOTS_REPLICAS", 6: "REPLICA_NODE_ID", 7: "REPLICA_REGISTER", 8: "REPLICA_HEARTBEAT", 9: "REPLICA_NODE_IDS", 10: "CONTROLLER_NODE_ID", 11: "CHANGE_REPLICA_TO_SLOTS", 12: "REFRESH_REPLICA_NODE_ID", 13: "REFRESH_REPLICA_SLOTS", 14: "REQUEST_SLOTS_DATA", 15: "UPDATE_NODE_SLOTS", 16: "UPDATE_REPLICA_NODE_ID", 17: "TRANSFER_SLOTS", 18: "UPDATE_SLOTS", 101: "CLIENT_FETCH_SLOTS_ALLOCATION", 102: "CLIENT_FETCH_SERVER_ADDRESSES", 103: "CLIENT_REGISTER", 104: "CLIENT_HEARTBEAT", 105: "CLIENT_FETCH_SERVER_NODE_ID", 106: "CLIENT_SUBSCRIBE", 107: "CLIENT_SERVICE_CHANGED", 108: "CLIENT_FETCH_SERVICE_REGISTER_ADDRESSES", } MessageEntity_MessageType_value = map[string]int32{ "TERMINATE_MESSAGE": 0, "VOTE": 1, "SLOTS_ALLOCATION": 2, "NODE_SLOTS": 3, "SLOTS_REPLICA_ALLOCATION": 4, "NODE_SLOTS_REPLICAS": 5, "REPLICA_NODE_ID": 6, "REPLICA_REGISTER": 7, "REPLICA_HEARTBEAT": 8, "REPLICA_NODE_IDS": 9, "CONTROLLER_NODE_ID": 10, "CHANGE_REPLICA_TO_SLOTS": 11, "REFRESH_REPLICA_NODE_ID": 12, "REFRESH_REPLICA_SLOTS": 13, "REQUEST_SLOTS_DATA": 14, "UPDATE_NODE_SLOTS": 15, "UPDATE_REPLICA_NODE_ID": 16, "TRANSFER_SLOTS": 17, "UPDATE_SLOTS": 18, "CLIENT_FETCH_SLOTS_ALLOCATION": 101, "CLIENT_FETCH_SERVER_ADDRESSES": 102, "CLIENT_REGISTER": 103, "CLIENT_HEARTBEAT": 104, "CLIENT_FETCH_SERVER_NODE_ID": 105, "CLIENT_SUBSCRIBE": 106, "CLIENT_SERVICE_CHANGED": 107, "CLIENT_FETCH_SERVICE_REGISTER_ADDRESSES": 108, } )
Enum value maps for MessageEntity_MessageType.
var ( MessageResponse_ResponseCode_name = map[int32]string{ 0: "SUCCESS", 100001: "SYSTEM_FAIL", 100100: "REGISTER_SUCCESS", 100101: "REGISTER_FAILURE", } MessageResponse_ResponseCode_value = map[string]int32{ "SUCCESS": 0, "SYSTEM_FAIL": 100001, "REGISTER_SUCCESS": 100100, "REGISTER_FAILURE": 100101, } )
Enum value maps for MessageResponse_ResponseCode.
var File_message_proto protoreflect.FileDescriptor
var Message_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.Message", HandlerType: (*MessageServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RemoteNodeInfo", Handler: _Message_RemoteNodeInfo_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "send", Handler: _Message_Send_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "message.proto", }
Message_ServiceDesc is the grpc.ServiceDesc for Message service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMessageServer ¶
func RegisterMessageServer(s grpc.ServiceRegistrar, srv MessageServer)
Types ¶
type ControllerVote ¶
type ControllerVote struct { VoterNodeId int32 `protobuf:"varint,1,opt,name=voterNodeId,proto3" json:"voterNodeId,omitempty"` // Voting node id ControllerNodeId int32 `protobuf:"varint,2,opt,name=controllerNodeId,proto3" json:"controllerNodeId,omitempty"` // id of the controller voted for VoteRound int32 `protobuf:"varint,3,opt,name=voteRound,proto3" json:"voteRound,omitempty"` // The rotation of the vote // contains filtered or unexported fields }
func (*ControllerVote) Descriptor
deprecated
func (*ControllerVote) Descriptor() ([]byte, []int)
Deprecated: Use ControllerVote.ProtoReflect.Descriptor instead.
func (*ControllerVote) GetControllerNodeId ¶
func (x *ControllerVote) GetControllerNodeId() int32
func (*ControllerVote) GetVoteRound ¶
func (x *ControllerVote) GetVoteRound() int32
func (*ControllerVote) GetVoterNodeId ¶
func (x *ControllerVote) GetVoterNodeId() int32
func (*ControllerVote) ProtoMessage ¶
func (*ControllerVote) ProtoMessage()
func (*ControllerVote) ProtoReflect ¶
func (x *ControllerVote) ProtoReflect() protoreflect.Message
func (*ControllerVote) Reset ¶
func (x *ControllerVote) Reset()
func (*ControllerVote) String ¶
func (x *ControllerVote) String() string
type FetchServerAddressesResponse ¶
type FetchServerAddressesResponse struct { ServerAddresses []string `protobuf:"bytes,1,rep,name=serverAddresses,proto3" json:"serverAddresses,omitempty"` // contains filtered or unexported fields }
func (*FetchServerAddressesResponse) Descriptor
deprecated
func (*FetchServerAddressesResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchServerAddressesResponse.ProtoReflect.Descriptor instead.
func (*FetchServerAddressesResponse) GetServerAddresses ¶
func (x *FetchServerAddressesResponse) GetServerAddresses() []string
func (*FetchServerAddressesResponse) ProtoMessage ¶
func (*FetchServerAddressesResponse) ProtoMessage()
func (*FetchServerAddressesResponse) ProtoReflect ¶
func (x *FetchServerAddressesResponse) ProtoReflect() protoreflect.Message
func (*FetchServerAddressesResponse) Reset ¶
func (x *FetchServerAddressesResponse) Reset()
func (*FetchServerAddressesResponse) String ¶
func (x *FetchServerAddressesResponse) String() string
type FetchServerNodeIdResponse ¶
type FetchServerNodeIdResponse struct { ServerNodeId int32 `protobuf:"varint,1,opt,name=serverNodeId,proto3" json:"serverNodeId,omitempty"` // contains filtered or unexported fields }
func (*FetchServerNodeIdResponse) Descriptor
deprecated
func (*FetchServerNodeIdResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchServerNodeIdResponse.ProtoReflect.Descriptor instead.
func (*FetchServerNodeIdResponse) GetServerNodeId ¶
func (x *FetchServerNodeIdResponse) GetServerNodeId() int32
func (*FetchServerNodeIdResponse) ProtoMessage ¶
func (*FetchServerNodeIdResponse) ProtoMessage()
func (*FetchServerNodeIdResponse) ProtoReflect ¶
func (x *FetchServerNodeIdResponse) ProtoReflect() protoreflect.Message
func (*FetchServerNodeIdResponse) Reset ¶
func (x *FetchServerNodeIdResponse) Reset()
func (*FetchServerNodeIdResponse) String ¶
func (x *FetchServerNodeIdResponse) String() string
type FetchServiceRegisterInfo ¶
type FetchServiceRegisterInfo struct { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"` ServiceInstanceIp string `protobuf:"bytes,2,opt,name=serviceInstanceIp,proto3" json:"serviceInstanceIp,omitempty"` ServiceInstancePort int32 `protobuf:"varint,3,opt,name=serviceInstancePort,proto3" json:"serviceInstancePort,omitempty"` LatestHeartbeatTime int64 `protobuf:"varint,4,opt,name=latestHeartbeatTime,proto3" json:"latestHeartbeatTime,omitempty"` // contains filtered or unexported fields }
func (*FetchServiceRegisterInfo) Descriptor
deprecated
func (*FetchServiceRegisterInfo) Descriptor() ([]byte, []int)
Deprecated: Use FetchServiceRegisterInfo.ProtoReflect.Descriptor instead.
func (*FetchServiceRegisterInfo) GetLatestHeartbeatTime ¶
func (x *FetchServiceRegisterInfo) GetLatestHeartbeatTime() int64
func (*FetchServiceRegisterInfo) GetServiceInstanceIp ¶
func (x *FetchServiceRegisterInfo) GetServiceInstanceIp() string
func (*FetchServiceRegisterInfo) GetServiceInstancePort ¶
func (x *FetchServiceRegisterInfo) GetServiceInstancePort() int32
func (*FetchServiceRegisterInfo) GetServiceName ¶
func (x *FetchServiceRegisterInfo) GetServiceName() string
func (*FetchServiceRegisterInfo) ProtoMessage ¶
func (*FetchServiceRegisterInfo) ProtoMessage()
func (*FetchServiceRegisterInfo) ProtoReflect ¶
func (x *FetchServiceRegisterInfo) ProtoReflect() protoreflect.Message
func (*FetchServiceRegisterInfo) Reset ¶
func (x *FetchServiceRegisterInfo) Reset()
func (*FetchServiceRegisterInfo) String ¶
func (x *FetchServiceRegisterInfo) String() string
type FetchServiceRegisterInfoRequest ¶
type FetchServiceRegisterInfoRequest struct { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"` // contains filtered or unexported fields }
func (*FetchServiceRegisterInfoRequest) Descriptor
deprecated
func (*FetchServiceRegisterInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchServiceRegisterInfoRequest.ProtoReflect.Descriptor instead.
func (*FetchServiceRegisterInfoRequest) GetServiceName ¶
func (x *FetchServiceRegisterInfoRequest) GetServiceName() string
func (*FetchServiceRegisterInfoRequest) ProtoMessage ¶
func (*FetchServiceRegisterInfoRequest) ProtoMessage()
func (*FetchServiceRegisterInfoRequest) ProtoReflect ¶
func (x *FetchServiceRegisterInfoRequest) ProtoReflect() protoreflect.Message
func (*FetchServiceRegisterInfoRequest) Reset ¶
func (x *FetchServiceRegisterInfoRequest) Reset()
func (*FetchServiceRegisterInfoRequest) String ¶
func (x *FetchServiceRegisterInfoRequest) String() string
type FetchServiceRegisterInfoResponse ¶
type FetchServiceRegisterInfoResponse struct { Info []*FetchServiceRegisterInfo `protobuf:"bytes,1,rep,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*FetchServiceRegisterInfoResponse) Descriptor
deprecated
func (*FetchServiceRegisterInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchServiceRegisterInfoResponse.ProtoReflect.Descriptor instead.
func (*FetchServiceRegisterInfoResponse) GetInfo ¶
func (x *FetchServiceRegisterInfoResponse) GetInfo() []*FetchServiceRegisterInfo
func (*FetchServiceRegisterInfoResponse) ProtoMessage ¶
func (*FetchServiceRegisterInfoResponse) ProtoMessage()
func (*FetchServiceRegisterInfoResponse) ProtoReflect ¶
func (x *FetchServiceRegisterInfoResponse) ProtoReflect() protoreflect.Message
func (*FetchServiceRegisterInfoResponse) Reset ¶
func (x *FetchServiceRegisterInfoResponse) Reset()
func (*FetchServiceRegisterInfoResponse) String ¶
func (x *FetchServiceRegisterInfoResponse) String() string
type HeartbeatRequest ¶
type HeartbeatRequest struct { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"` ServiceInstanceIp string `protobuf:"bytes,2,opt,name=serviceInstanceIp,proto3" json:"serviceInstanceIp,omitempty"` ServiceInstancePort int32 `protobuf:"varint,3,opt,name=serviceInstancePort,proto3" json:"serviceInstancePort,omitempty"` // contains filtered or unexported fields }
func (*HeartbeatRequest) Descriptor
deprecated
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.
func (*HeartbeatRequest) GetServiceInstanceIp ¶
func (x *HeartbeatRequest) GetServiceInstanceIp() string
func (*HeartbeatRequest) GetServiceInstancePort ¶
func (x *HeartbeatRequest) GetServiceInstancePort() int32
func (*HeartbeatRequest) GetServiceName ¶
func (x *HeartbeatRequest) GetServiceName() string
func (*HeartbeatRequest) ProtoMessage ¶
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) ProtoReflect ¶
func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
func (*HeartbeatRequest) Reset ¶
func (x *HeartbeatRequest) Reset()
func (*HeartbeatRequest) String ¶
func (x *HeartbeatRequest) String() string
type MessageClient ¶
type MessageClient interface { RemoteNodeInfo(ctx context.Context, in *RemoteServerNode, opts ...grpc.CallOption) (*RemoteServerNodeResponse, error) Send(ctx context.Context, opts ...grpc.CallOption) (Message_SendClient, error) }
MessageClient is the client API for Message 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 NewMessageClient ¶
func NewMessageClient(cc grpc.ClientConnInterface) MessageClient
type MessageEntity ¶
type MessageEntity struct { RequestId string `protobuf:"bytes,1,opt,name=requestId,proto3" json:"requestId,omitempty"` Type MessageEntity_MessageType `protobuf:"varint,2,opt,name=type,proto3,enum=proto.MessageEntity_MessageType" json:"type,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*MessageEntity) Descriptor
deprecated
func (*MessageEntity) Descriptor() ([]byte, []int)
Deprecated: Use MessageEntity.ProtoReflect.Descriptor instead.
func (*MessageEntity) GetData ¶
func (x *MessageEntity) GetData() []byte
func (*MessageEntity) GetRequestId ¶
func (x *MessageEntity) GetRequestId() string
func (*MessageEntity) GetType ¶
func (x *MessageEntity) GetType() MessageEntity_MessageType
func (*MessageEntity) ProtoMessage ¶
func (*MessageEntity) ProtoMessage()
func (*MessageEntity) ProtoReflect ¶
func (x *MessageEntity) ProtoReflect() protoreflect.Message
func (*MessageEntity) Reset ¶
func (x *MessageEntity) Reset()
func (*MessageEntity) String ¶
func (x *MessageEntity) String() string
type MessageEntity_MessageType ¶
type MessageEntity_MessageType int32
const ( MessageEntity_TERMINATE_MESSAGE MessageEntity_MessageType = 0 // Terminating run message MessageEntity_VOTE MessageEntity_MessageType = 1 // Voting message type MessageEntity_SLOTS_ALLOCATION MessageEntity_MessageType = 2 // Slot assignment message type MessageEntity_NODE_SLOTS MessageEntity_MessageType = 3 // Slots for which the node is responsible MessageEntity_SLOTS_REPLICA_ALLOCATION MessageEntity_MessageType = 4 // Slot copy assignment message type MessageEntity_NODE_SLOTS_REPLICAS MessageEntity_MessageType = 5 // A copy of the slot for which the node is responsible MessageEntity_REPLICA_NODE_ID MessageEntity_MessageType = 6 // Replica node id MessageEntity_REPLICA_REGISTER MessageEntity_MessageType = 7 // Register to request a forward copy MessageEntity_REPLICA_HEARTBEAT MessageEntity_MessageType = 8 // Heartbeat request forward replica MessageEntity_REPLICA_NODE_IDS MessageEntity_MessageType = 9 // Replica node id collection MessageEntity_CONTROLLER_NODE_ID MessageEntity_MessageType = 10 // Replica node id MessageEntity_CHANGE_REPLICA_TO_SLOTS MessageEntity_MessageType = 11 MessageEntity_REFRESH_REPLICA_NODE_ID MessageEntity_MessageType = 12 // Refresh the replica node id MessageEntity_REFRESH_REPLICA_SLOTS MessageEntity_MessageType = 13 // Refresh the slot copy data MessageEntity_REQUEST_SLOTS_DATA MessageEntity_MessageType = 14 // Request slot data synchronization MessageEntity_UPDATE_NODE_SLOTS MessageEntity_MessageType = 15 // Slots for which the node is responsible MessageEntity_UPDATE_REPLICA_NODE_ID MessageEntity_MessageType = 16 // Update the replica node id MessageEntity_TRANSFER_SLOTS MessageEntity_MessageType = 17 // Transfer slot data to slots MessageEntity_UPDATE_SLOTS MessageEntity_MessageType = 18 // Transfer slot data to slots MessageEntity_CLIENT_FETCH_SLOTS_ALLOCATION MessageEntity_MessageType = 101 // Pull the slots allocation data request MessageEntity_CLIENT_FETCH_SERVER_ADDRESSES MessageEntity_MessageType = 102 // Pull the server node address list request MessageEntity_CLIENT_REGISTER MessageEntity_MessageType = 103 // Client registration request MessageEntity_CLIENT_HEARTBEAT MessageEntity_MessageType = 104 // Client heartbeat request MessageEntity_CLIENT_FETCH_SERVER_NODE_ID MessageEntity_MessageType = 105 // Pull server node id MessageEntity_CLIENT_SUBSCRIBE MessageEntity_MessageType = 106 // Subscribe service MessageEntity_CLIENT_SERVICE_CHANGED MessageEntity_MessageType = 107 // Service instance changed MessageEntity_CLIENT_FETCH_SERVICE_REGISTER_ADDRESSES MessageEntity_MessageType = 108 // Fetch all service register addresses )
func (MessageEntity_MessageType) Descriptor ¶
func (MessageEntity_MessageType) Descriptor() protoreflect.EnumDescriptor
func (MessageEntity_MessageType) Enum ¶
func (x MessageEntity_MessageType) Enum() *MessageEntity_MessageType
func (MessageEntity_MessageType) EnumDescriptor
deprecated
func (MessageEntity_MessageType) EnumDescriptor() ([]byte, []int)
Deprecated: Use MessageEntity_MessageType.Descriptor instead.
func (MessageEntity_MessageType) Number ¶
func (x MessageEntity_MessageType) Number() protoreflect.EnumNumber
func (MessageEntity_MessageType) String ¶
func (x MessageEntity_MessageType) String() string
func (MessageEntity_MessageType) Type ¶
func (MessageEntity_MessageType) Type() protoreflect.EnumType
type MessageResponse ¶
type MessageResponse struct { Code MessageResponse_ResponseCode `protobuf:"varint,1,opt,name=code,proto3,enum=proto.MessageResponse_ResponseCode" json:"code,omitempty"` Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` Result *MessageEntity `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*MessageResponse) Descriptor
deprecated
func (*MessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use MessageResponse.ProtoReflect.Descriptor instead.
func (*MessageResponse) GetCode ¶
func (x *MessageResponse) GetCode() MessageResponse_ResponseCode
func (*MessageResponse) GetMessage ¶
func (x *MessageResponse) GetMessage() string
func (*MessageResponse) GetResult ¶
func (x *MessageResponse) GetResult() *MessageEntity
func (*MessageResponse) GetSuccess ¶
func (x *MessageResponse) GetSuccess() bool
func (*MessageResponse) ProtoMessage ¶
func (*MessageResponse) ProtoMessage()
func (*MessageResponse) ProtoReflect ¶
func (x *MessageResponse) ProtoReflect() protoreflect.Message
func (*MessageResponse) Reset ¶
func (x *MessageResponse) Reset()
func (*MessageResponse) String ¶
func (x *MessageResponse) String() string
type MessageResponse_ResponseCode ¶
type MessageResponse_ResponseCode int32
const ( MessageResponse_SUCCESS MessageResponse_ResponseCode = 0 MessageResponse_SYSTEM_FAIL MessageResponse_ResponseCode = 100001 MessageResponse_REGISTER_SUCCESS MessageResponse_ResponseCode = 100100 MessageResponse_REGISTER_FAILURE MessageResponse_ResponseCode = 100101 )
func (MessageResponse_ResponseCode) Descriptor ¶
func (MessageResponse_ResponseCode) Descriptor() protoreflect.EnumDescriptor
func (MessageResponse_ResponseCode) Enum ¶
func (x MessageResponse_ResponseCode) Enum() *MessageResponse_ResponseCode
func (MessageResponse_ResponseCode) EnumDescriptor
deprecated
func (MessageResponse_ResponseCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use MessageResponse_ResponseCode.Descriptor instead.
func (MessageResponse_ResponseCode) Number ¶
func (x MessageResponse_ResponseCode) Number() protoreflect.EnumNumber
func (MessageResponse_ResponseCode) String ¶
func (x MessageResponse_ResponseCode) String() string
func (MessageResponse_ResponseCode) Type ¶
func (MessageResponse_ResponseCode) Type() protoreflect.EnumType
type MessageServer ¶
type MessageServer interface { RemoteNodeInfo(context.Context, *RemoteServerNode) (*RemoteServerNodeResponse, error) Send(Message_SendServer) error // contains filtered or unexported methods }
MessageServer is the server API for Message service. All implementations must embed UnimplementedMessageServer for forward compatibility
type Message_SendClient ¶
type Message_SendClient interface { Send(*MessageEntity) error Recv() (*MessageResponse, error) grpc.ClientStream }
type Message_SendServer ¶
type Message_SendServer interface { Send(*MessageResponse) error Recv() (*MessageEntity, error) grpc.ServerStream }
type RegisterRequest ¶
type RegisterRequest struct { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"` ServiceInstanceIp string `protobuf:"bytes,2,opt,name=serviceInstanceIp,proto3" json:"serviceInstanceIp,omitempty"` ServiceInstancePort int32 `protobuf:"varint,3,opt,name=serviceInstancePort,proto3" json:"serviceInstancePort,omitempty"` // contains filtered or unexported fields }
func (*RegisterRequest) Descriptor
deprecated
func (*RegisterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.
func (*RegisterRequest) GetServiceInstanceIp ¶
func (x *RegisterRequest) GetServiceInstanceIp() string
func (*RegisterRequest) GetServiceInstancePort ¶
func (x *RegisterRequest) GetServiceInstancePort() int32
func (*RegisterRequest) GetServiceName ¶
func (x *RegisterRequest) GetServiceName() string
func (*RegisterRequest) ProtoMessage ¶
func (*RegisterRequest) ProtoMessage()
func (*RegisterRequest) ProtoReflect ¶
func (x *RegisterRequest) ProtoReflect() protoreflect.Message
func (*RegisterRequest) Reset ¶
func (x *RegisterRequest) Reset()
func (*RegisterRequest) String ¶
func (x *RegisterRequest) String() string
type RemoteServerNode ¶
type RemoteServerNode struct { NodeId int32 `protobuf:"varint,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` // node id IsControllerCandidate bool `protobuf:"varint,2,opt,name=isControllerCandidate,proto3" json:"isControllerCandidate,omitempty"` // Whether it is a controller candidate node IsController bool `protobuf:"varint,3,opt,name=isController,proto3" json:"isController,omitempty"` // Whether you are a controller Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"` // ip address of the node ClientPort int32 `protobuf:"varint,5,opt,name=clientPort,proto3" json:"clientPort,omitempty"` // Port number of the client InternPort int32 `protobuf:"varint,6,opt,name=InternPort,proto3" json:"InternPort,omitempty"` // TCP port number for intra-node communication // contains filtered or unexported fields }
remote server node data
func (*RemoteServerNode) Descriptor
deprecated
func (*RemoteServerNode) Descriptor() ([]byte, []int)
Deprecated: Use RemoteServerNode.ProtoReflect.Descriptor instead.
func (*RemoteServerNode) GetClientPort ¶
func (x *RemoteServerNode) GetClientPort() int32
func (*RemoteServerNode) GetInternPort ¶
func (x *RemoteServerNode) GetInternPort() int32
func (*RemoteServerNode) GetIp ¶
func (x *RemoteServerNode) GetIp() string
func (*RemoteServerNode) GetIsController ¶
func (x *RemoteServerNode) GetIsController() bool
func (*RemoteServerNode) GetIsControllerCandidate ¶
func (x *RemoteServerNode) GetIsControllerCandidate() bool
func (*RemoteServerNode) GetNodeId ¶
func (x *RemoteServerNode) GetNodeId() int32
func (*RemoteServerNode) ProtoMessage ¶
func (*RemoteServerNode) ProtoMessage()
func (*RemoteServerNode) ProtoReflect ¶
func (x *RemoteServerNode) ProtoReflect() protoreflect.Message
func (*RemoteServerNode) Reset ¶
func (x *RemoteServerNode) Reset()
func (*RemoteServerNode) String ¶
func (x *RemoteServerNode) String() string
type RemoteServerNodeResponse ¶
type RemoteServerNodeResponse struct { Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"` Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` Data *RemoteServerNode `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*RemoteServerNodeResponse) Descriptor
deprecated
func (*RemoteServerNodeResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoteServerNodeResponse.ProtoReflect.Descriptor instead.
func (*RemoteServerNodeResponse) GetCode ¶
func (x *RemoteServerNodeResponse) GetCode() int32
func (*RemoteServerNodeResponse) GetData ¶
func (x *RemoteServerNodeResponse) GetData() *RemoteServerNode
func (*RemoteServerNodeResponse) GetMessage ¶
func (x *RemoteServerNodeResponse) GetMessage() string
func (*RemoteServerNodeResponse) GetSuccess ¶
func (x *RemoteServerNodeResponse) GetSuccess() bool
func (*RemoteServerNodeResponse) ProtoMessage ¶
func (*RemoteServerNodeResponse) ProtoMessage()
func (*RemoteServerNodeResponse) ProtoReflect ¶
func (x *RemoteServerNodeResponse) ProtoReflect() protoreflect.Message
func (*RemoteServerNodeResponse) Reset ¶
func (x *RemoteServerNodeResponse) Reset()
func (*RemoteServerNodeResponse) String ¶
func (x *RemoteServerNodeResponse) String() string
type ServiceChangedRequest ¶
type ServiceChangedRequest struct { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"` ServiceInstanceAddresses []string `protobuf:"bytes,2,rep,name=serviceInstanceAddresses,proto3" json:"serviceInstanceAddresses,omitempty"` // contains filtered or unexported fields }
func (*ServiceChangedRequest) Descriptor
deprecated
func (*ServiceChangedRequest) Descriptor() ([]byte, []int)
Deprecated: Use ServiceChangedRequest.ProtoReflect.Descriptor instead.
func (*ServiceChangedRequest) GetServiceInstanceAddresses ¶
func (x *ServiceChangedRequest) GetServiceInstanceAddresses() []string
func (*ServiceChangedRequest) GetServiceName ¶
func (x *ServiceChangedRequest) GetServiceName() string
func (*ServiceChangedRequest) ProtoMessage ¶
func (*ServiceChangedRequest) ProtoMessage()
func (*ServiceChangedRequest) ProtoReflect ¶
func (x *ServiceChangedRequest) ProtoReflect() protoreflect.Message
func (*ServiceChangedRequest) Reset ¶
func (x *ServiceChangedRequest) Reset()
func (*ServiceChangedRequest) String ¶
func (x *ServiceChangedRequest) String() string
type SubscribeRequest ¶
type SubscribeRequest struct { ServiceName string `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"` // contains filtered or unexported fields }
func (*SubscribeRequest) Descriptor
deprecated
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) GetServiceName ¶
func (x *SubscribeRequest) GetServiceName() string
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (x *SubscribeRequest) String() string
type SubscribeResponse ¶
type SubscribeResponse struct { ServiceInstanceAddresses []string `protobuf:"bytes,1,rep,name=serviceInstanceAddresses,proto3" json:"serviceInstanceAddresses,omitempty"` // contains filtered or unexported fields }
func (*SubscribeResponse) Descriptor
deprecated
func (*SubscribeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.
func (*SubscribeResponse) GetServiceInstanceAddresses ¶
func (x *SubscribeResponse) GetServiceInstanceAddresses() []string
func (*SubscribeResponse) ProtoMessage ¶
func (*SubscribeResponse) ProtoMessage()
func (*SubscribeResponse) ProtoReflect ¶
func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
func (*SubscribeResponse) Reset ¶
func (x *SubscribeResponse) Reset()
func (*SubscribeResponse) String ¶
func (x *SubscribeResponse) String() string
type TransferSlotsRequest ¶
type TransferSlotsRequest struct { TargetNodeId int32 `protobuf:"varint,1,opt,name=targetNodeId,proto3" json:"targetNodeId,omitempty"` Slots string `protobuf:"bytes,2,opt,name=slots,proto3" json:"slots,omitempty"` // contains filtered or unexported fields }
func (*TransferSlotsRequest) Descriptor
deprecated
func (*TransferSlotsRequest) Descriptor() ([]byte, []int)
Deprecated: Use TransferSlotsRequest.ProtoReflect.Descriptor instead.
func (*TransferSlotsRequest) GetSlots ¶
func (x *TransferSlotsRequest) GetSlots() string
func (*TransferSlotsRequest) GetTargetNodeId ¶
func (x *TransferSlotsRequest) GetTargetNodeId() int32
func (*TransferSlotsRequest) ProtoMessage ¶
func (*TransferSlotsRequest) ProtoMessage()
func (*TransferSlotsRequest) ProtoReflect ¶
func (x *TransferSlotsRequest) ProtoReflect() protoreflect.Message
func (*TransferSlotsRequest) Reset ¶
func (x *TransferSlotsRequest) Reset()
func (*TransferSlotsRequest) String ¶
func (x *TransferSlotsRequest) String() string
type UnimplementedMessageServer ¶
type UnimplementedMessageServer struct { }
UnimplementedMessageServer must be embedded to have forward compatible implementations.
func (UnimplementedMessageServer) RemoteNodeInfo ¶
func (UnimplementedMessageServer) RemoteNodeInfo(context.Context, *RemoteServerNode) (*RemoteServerNodeResponse, error)
func (UnimplementedMessageServer) Send ¶
func (UnimplementedMessageServer) Send(Message_SendServer) error
type UnsafeMessageServer ¶
type UnsafeMessageServer interface {
// contains filtered or unexported methods
}
UnsafeMessageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MessageServer will result in compilation errors.
type UpdateSlotsRequest ¶
type UpdateSlotsRequest struct { SlotNo int32 `protobuf:"varint,1,opt,name=slotNo,proto3" json:"slotNo,omitempty"` SlotData []byte `protobuf:"bytes,2,opt,name=slotData,proto3" json:"slotData,omitempty"` // contains filtered or unexported fields }
func (*UpdateSlotsRequest) Descriptor
deprecated
func (*UpdateSlotsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateSlotsRequest.ProtoReflect.Descriptor instead.
func (*UpdateSlotsRequest) GetSlotData ¶
func (x *UpdateSlotsRequest) GetSlotData() []byte
func (*UpdateSlotsRequest) GetSlotNo ¶
func (x *UpdateSlotsRequest) GetSlotNo() int32
func (*UpdateSlotsRequest) ProtoMessage ¶
func (*UpdateSlotsRequest) ProtoMessage()
func (*UpdateSlotsRequest) ProtoReflect ¶
func (x *UpdateSlotsRequest) ProtoReflect() protoreflect.Message
func (*UpdateSlotsRequest) Reset ¶
func (x *UpdateSlotsRequest) Reset()
func (*UpdateSlotsRequest) String ¶
func (x *UpdateSlotsRequest) String() string