grpc

package
v0.0.0-...-a7402c0 Latest Latest
Warning

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

 Go to latest Published: Apr 24, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
var File_message_proto protoreflect.FileDescriptor
View Source 
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

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.