Documentation
¶
Index ¶
- Variables
- func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)
- func RegisterMemberServer(s grpc.ServiceRegistrar, srv MemberServer)
- type CloseSessionRequest
- func (*CloseSessionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSessionRequest) GetSessionId() int64
- func (*CloseSessionRequest) ProtoMessage()
- func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
- func (x *CloseSessionRequest) Reset()
- func (x *CloseSessionRequest) String() string
- type CloseSessionResponse
- type DelMemberRequest
- type DelMemberResponse
- type HeartbeatRequest
- type HeartbeatResponse
- type MasterClient
- type MasterServer
- type MemberClient
- type MemberHandleResponse
- type MemberInfo
- func (*MemberInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MemberInfo) GetLabel() string
- func (x *MemberInfo) GetServiceAddr() string
- func (x *MemberInfo) GetServices() []string
- func (*MemberInfo) ProtoMessage()
- func (x *MemberInfo) ProtoReflect() protoreflect.Message
- func (x *MemberInfo) Reset()
- func (x *MemberInfo) String() string
- type MemberServer
- type NewMemberRequest
- type NewMemberResponse
- type NotifyMessage
- func (*NotifyMessage) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyMessage) GetData() []byte
- func (x *NotifyMessage) GetGateAddr() string
- func (x *NotifyMessage) GetRoute() string
- func (x *NotifyMessage) GetSessionId() int64
- func (*NotifyMessage) ProtoMessage()
- func (x *NotifyMessage) ProtoReflect() protoreflect.Message
- func (x *NotifyMessage) Reset()
- func (x *NotifyMessage) String() string
- type PushMessage
- func (*PushMessage) Descriptor() ([]byte, []int)deprecated
- func (x *PushMessage) GetData() []byte
- func (x *PushMessage) GetRoute() string
- func (x *PushMessage) GetSessionId() int64
- func (*PushMessage) ProtoMessage()
- func (x *PushMessage) ProtoReflect() protoreflect.Message
- func (x *PushMessage) Reset()
- func (x *PushMessage) String() string
- type RegisterRequest
- type RegisterResponse
- type RequestMessage
- func (*RequestMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RequestMessage) GetData() []byte
- func (x *RequestMessage) GetGateAddr() string
- func (x *RequestMessage) GetId() uint64
- func (x *RequestMessage) GetRoute() string
- func (x *RequestMessage) GetSessionId() int64
- func (*RequestMessage) ProtoMessage()
- func (x *RequestMessage) ProtoReflect() protoreflect.Message
- func (x *RequestMessage) Reset()
- func (x *RequestMessage) String() string
- type ResponseMessage
- func (*ResponseMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ResponseMessage) GetData() []byte
- func (x *ResponseMessage) GetId() uint64
- func (x *ResponseMessage) GetSessionId() int64
- func (*ResponseMessage) ProtoMessage()
- func (x *ResponseMessage) ProtoReflect() protoreflect.Message
- func (x *ResponseMessage) Reset()
- func (x *ResponseMessage) String() string
- type SessionClosedRequest
- func (*SessionClosedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SessionClosedRequest) GetSessionId() int64
- func (*SessionClosedRequest) ProtoMessage()
- func (x *SessionClosedRequest) ProtoReflect() protoreflect.Message
- func (x *SessionClosedRequest) Reset()
- func (x *SessionClosedRequest) String() string
- type SessionClosedResponse
- type UnimplementedMasterServer
- func (UnimplementedMasterServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
- func (UnimplementedMasterServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
- func (UnimplementedMasterServer) Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, error)
- type UnimplementedMemberServer
- func (UnimplementedMemberServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
- func (UnimplementedMemberServer) DelMember(context.Context, *DelMemberRequest) (*DelMemberResponse, error)
- func (UnimplementedMemberServer) HandleNotify(context.Context, *NotifyMessage) (*MemberHandleResponse, error)
- func (UnimplementedMemberServer) HandlePush(context.Context, *PushMessage) (*MemberHandleResponse, error)
- func (UnimplementedMemberServer) HandleRequest(context.Context, *RequestMessage) (*MemberHandleResponse, error)
- func (UnimplementedMemberServer) HandleResponse(context.Context, *ResponseMessage) (*MemberHandleResponse, error)
- func (UnimplementedMemberServer) NewMember(context.Context, *NewMemberRequest) (*NewMemberResponse, error)
- func (UnimplementedMemberServer) SessionClosed(context.Context, *SessionClosedRequest) (*SessionClosedResponse, error)
- type UnregisterRequest
- func (*UnregisterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnregisterRequest) GetServiceAddr() string
- func (*UnregisterRequest) ProtoMessage()
- func (x *UnregisterRequest) ProtoReflect() protoreflect.Message
- func (x *UnregisterRequest) Reset()
- func (x *UnregisterRequest) String() string
- type UnregisterResponse
- type UnsafeMasterServer
- type UnsafeMemberServer
Constants ¶
This section is empty.
Variables ¶
var File_cluster_proto protoreflect.FileDescriptor
var Master_ServiceDesc = grpc.ServiceDesc{ ServiceName: "clusterpb.Master", HandlerType: (*MasterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Register", Handler: _Master_Register_Handler, }, { MethodName: "Unregister", Handler: _Master_Unregister_Handler, }, { MethodName: "Heartbeat", Handler: _Master_Heartbeat_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cluster.proto", }
Master_ServiceDesc is the grpc.ServiceDesc for Master service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Member_ServiceDesc = grpc.ServiceDesc{ ServiceName: "clusterpb.Member", HandlerType: (*MemberServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "HandleRequest", Handler: _Member_HandleRequest_Handler, }, { MethodName: "HandleNotify", Handler: _Member_HandleNotify_Handler, }, { MethodName: "HandlePush", Handler: _Member_HandlePush_Handler, }, { MethodName: "HandleResponse", Handler: _Member_HandleResponse_Handler, }, { MethodName: "NewMember", Handler: _Member_NewMember_Handler, }, { MethodName: "DelMember", Handler: _Member_DelMember_Handler, }, { MethodName: "SessionClosed", Handler: _Member_SessionClosed_Handler, }, { MethodName: "CloseSession", Handler: _Member_CloseSession_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cluster.proto", }
Member_ServiceDesc is the grpc.ServiceDesc for Member service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMasterServer ¶
func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)
func RegisterMemberServer ¶
func RegisterMemberServer(s grpc.ServiceRegistrar, srv MemberServer)
Types ¶
type CloseSessionRequest ¶
type CloseSessionRequest struct { SessionId int64 `protobuf:"varint,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"` // contains filtered or unexported fields }
func (*CloseSessionRequest) Descriptor
deprecated
func (*CloseSessionRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionRequest.ProtoReflect.Descriptor instead.
func (*CloseSessionRequest) GetSessionId ¶
func (x *CloseSessionRequest) GetSessionId() int64
func (*CloseSessionRequest) ProtoMessage ¶
func (*CloseSessionRequest) ProtoMessage()
func (*CloseSessionRequest) ProtoReflect ¶ added in v0.5.1
func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message
func (*CloseSessionRequest) Reset ¶
func (x *CloseSessionRequest) Reset()
func (*CloseSessionRequest) String ¶
func (x *CloseSessionRequest) String() string
type CloseSessionResponse ¶
type CloseSessionResponse struct {
// contains filtered or unexported fields
}
func (*CloseSessionResponse) Descriptor
deprecated
func (*CloseSessionResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.
func (*CloseSessionResponse) ProtoMessage ¶
func (*CloseSessionResponse) ProtoMessage()
func (*CloseSessionResponse) ProtoReflect ¶ added in v0.5.1
func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message
func (*CloseSessionResponse) Reset ¶
func (x *CloseSessionResponse) Reset()
func (*CloseSessionResponse) String ¶
func (x *CloseSessionResponse) String() string
type DelMemberRequest ¶
type DelMemberRequest struct { ServiceAddr string `protobuf:"bytes,1,opt,name=serviceAddr,proto3" json:"serviceAddr,omitempty"` // contains filtered or unexported fields }
func (*DelMemberRequest) Descriptor
deprecated
func (*DelMemberRequest) Descriptor() ([]byte, []int)
Deprecated: Use DelMemberRequest.ProtoReflect.Descriptor instead.
func (*DelMemberRequest) GetServiceAddr ¶
func (x *DelMemberRequest) GetServiceAddr() string
func (*DelMemberRequest) ProtoMessage ¶
func (*DelMemberRequest) ProtoMessage()
func (*DelMemberRequest) ProtoReflect ¶ added in v0.5.1
func (x *DelMemberRequest) ProtoReflect() protoreflect.Message
func (*DelMemberRequest) Reset ¶
func (x *DelMemberRequest) Reset()
func (*DelMemberRequest) String ¶
func (x *DelMemberRequest) String() string
type DelMemberResponse ¶
type DelMemberResponse struct {
// contains filtered or unexported fields
}
func (*DelMemberResponse) Descriptor
deprecated
func (*DelMemberResponse) Descriptor() ([]byte, []int)
Deprecated: Use DelMemberResponse.ProtoReflect.Descriptor instead.
func (*DelMemberResponse) ProtoMessage ¶
func (*DelMemberResponse) ProtoMessage()
func (*DelMemberResponse) ProtoReflect ¶ added in v0.5.1
func (x *DelMemberResponse) ProtoReflect() protoreflect.Message
func (*DelMemberResponse) Reset ¶
func (x *DelMemberResponse) Reset()
func (*DelMemberResponse) String ¶
func (x *DelMemberResponse) String() string
type HeartbeatRequest ¶ added in v0.5.1
type HeartbeatRequest struct { MemberInfo *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo,proto3" json:"memberInfo,omitempty"` // contains filtered or unexported fields }
func (*HeartbeatRequest) Descriptor
deprecated
added in
v0.5.1
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.
func (*HeartbeatRequest) GetMemberInfo ¶ added in v0.5.1
func (x *HeartbeatRequest) GetMemberInfo() *MemberInfo
func (*HeartbeatRequest) ProtoMessage ¶ added in v0.5.1
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) ProtoReflect ¶ added in v0.5.1
func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
func (*HeartbeatRequest) Reset ¶ added in v0.5.1
func (x *HeartbeatRequest) Reset()
func (*HeartbeatRequest) String ¶ added in v0.5.1
func (x *HeartbeatRequest) String() string
type HeartbeatResponse ¶ added in v0.5.1
type HeartbeatResponse struct {
// contains filtered or unexported fields
}
func (*HeartbeatResponse) Descriptor
deprecated
added in
v0.5.1
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.
func (*HeartbeatResponse) ProtoMessage ¶ added in v0.5.1
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) ProtoReflect ¶ added in v0.5.1
func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
func (*HeartbeatResponse) Reset ¶ added in v0.5.1
func (x *HeartbeatResponse) Reset()
func (*HeartbeatResponse) String ¶ added in v0.5.1
func (x *HeartbeatResponse) String() string
type MasterClient ¶
type MasterClient interface { Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error) Unregister(ctx context.Context, in *UnregisterRequest, opts ...grpc.CallOption) (*UnregisterResponse, error) Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error) }
MasterClient is the client API for Master 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 NewMasterClient ¶
func NewMasterClient(cc grpc.ClientConnInterface) MasterClient
type MasterServer ¶
type MasterServer interface { Register(context.Context, *RegisterRequest) (*RegisterResponse, error) Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, error) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error) }
MasterServer is the server API for Master service. All implementations should embed UnimplementedMasterServer for forward compatibility
type MemberClient ¶
type MemberClient interface { HandleRequest(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*MemberHandleResponse, error) HandleNotify(ctx context.Context, in *NotifyMessage, opts ...grpc.CallOption) (*MemberHandleResponse, error) HandlePush(ctx context.Context, in *PushMessage, opts ...grpc.CallOption) (*MemberHandleResponse, error) HandleResponse(ctx context.Context, in *ResponseMessage, opts ...grpc.CallOption) (*MemberHandleResponse, error) NewMember(ctx context.Context, in *NewMemberRequest, opts ...grpc.CallOption) (*NewMemberResponse, error) DelMember(ctx context.Context, in *DelMemberRequest, opts ...grpc.CallOption) (*DelMemberResponse, error) SessionClosed(ctx context.Context, in *SessionClosedRequest, opts ...grpc.CallOption) (*SessionClosedResponse, error) CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) }
MemberClient is the client API for Member 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 NewMemberClient ¶
func NewMemberClient(cc grpc.ClientConnInterface) MemberClient
type MemberHandleResponse ¶
type MemberHandleResponse struct {
// contains filtered or unexported fields
}
func (*MemberHandleResponse) Descriptor
deprecated
func (*MemberHandleResponse) Descriptor() ([]byte, []int)
Deprecated: Use MemberHandleResponse.ProtoReflect.Descriptor instead.
func (*MemberHandleResponse) ProtoMessage ¶
func (*MemberHandleResponse) ProtoMessage()
func (*MemberHandleResponse) ProtoReflect ¶ added in v0.5.1
func (x *MemberHandleResponse) ProtoReflect() protoreflect.Message
func (*MemberHandleResponse) Reset ¶
func (x *MemberHandleResponse) Reset()
func (*MemberHandleResponse) String ¶
func (x *MemberHandleResponse) String() string
type MemberInfo ¶
type MemberInfo struct { Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"` ServiceAddr string `protobuf:"bytes,2,opt,name=serviceAddr,proto3" json:"serviceAddr,omitempty"` Services []string `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
func (*MemberInfo) Descriptor
deprecated
func (*MemberInfo) Descriptor() ([]byte, []int)
Deprecated: Use MemberInfo.ProtoReflect.Descriptor instead.
func (*MemberInfo) GetLabel ¶
func (x *MemberInfo) GetLabel() string
func (*MemberInfo) GetServiceAddr ¶
func (x *MemberInfo) GetServiceAddr() string
func (*MemberInfo) GetServices ¶
func (x *MemberInfo) GetServices() []string
func (*MemberInfo) ProtoMessage ¶
func (*MemberInfo) ProtoMessage()
func (*MemberInfo) ProtoReflect ¶ added in v0.5.1
func (x *MemberInfo) ProtoReflect() protoreflect.Message
func (*MemberInfo) Reset ¶
func (x *MemberInfo) Reset()
func (*MemberInfo) String ¶
func (x *MemberInfo) String() string
type MemberServer ¶
type MemberServer interface { HandleRequest(context.Context, *RequestMessage) (*MemberHandleResponse, error) HandleNotify(context.Context, *NotifyMessage) (*MemberHandleResponse, error) HandlePush(context.Context, *PushMessage) (*MemberHandleResponse, error) HandleResponse(context.Context, *ResponseMessage) (*MemberHandleResponse, error) NewMember(context.Context, *NewMemberRequest) (*NewMemberResponse, error) DelMember(context.Context, *DelMemberRequest) (*DelMemberResponse, error) SessionClosed(context.Context, *SessionClosedRequest) (*SessionClosedResponse, error) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) }
MemberServer is the server API for Member service. All implementations should embed UnimplementedMemberServer for forward compatibility
type NewMemberRequest ¶
type NewMemberRequest struct { MemberInfo *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo,proto3" json:"memberInfo,omitempty"` // contains filtered or unexported fields }
func (*NewMemberRequest) Descriptor
deprecated
func (*NewMemberRequest) Descriptor() ([]byte, []int)
Deprecated: Use NewMemberRequest.ProtoReflect.Descriptor instead.
func (*NewMemberRequest) GetMemberInfo ¶
func (x *NewMemberRequest) GetMemberInfo() *MemberInfo
func (*NewMemberRequest) ProtoMessage ¶
func (*NewMemberRequest) ProtoMessage()
func (*NewMemberRequest) ProtoReflect ¶ added in v0.5.1
func (x *NewMemberRequest) ProtoReflect() protoreflect.Message
func (*NewMemberRequest) Reset ¶
func (x *NewMemberRequest) Reset()
func (*NewMemberRequest) String ¶
func (x *NewMemberRequest) String() string
type NewMemberResponse ¶
type NewMemberResponse struct {
// contains filtered or unexported fields
}
func (*NewMemberResponse) Descriptor
deprecated
func (*NewMemberResponse) Descriptor() ([]byte, []int)
Deprecated: Use NewMemberResponse.ProtoReflect.Descriptor instead.
func (*NewMemberResponse) ProtoMessage ¶
func (*NewMemberResponse) ProtoMessage()
func (*NewMemberResponse) ProtoReflect ¶ added in v0.5.1
func (x *NewMemberResponse) ProtoReflect() protoreflect.Message
func (*NewMemberResponse) Reset ¶
func (x *NewMemberResponse) Reset()
func (*NewMemberResponse) String ¶
func (x *NewMemberResponse) String() string
type NotifyMessage ¶
type NotifyMessage struct { GateAddr string `protobuf:"bytes,1,opt,name=gateAddr,proto3" json:"gateAddr,omitempty"` SessionId int64 `protobuf:"varint,2,opt,name=sessionId,proto3" json:"sessionId,omitempty"` Route string `protobuf:"bytes,3,opt,name=route,proto3" json:"route,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*NotifyMessage) Descriptor
deprecated
func (*NotifyMessage) Descriptor() ([]byte, []int)
Deprecated: Use NotifyMessage.ProtoReflect.Descriptor instead.
func (*NotifyMessage) GetData ¶
func (x *NotifyMessage) GetData() []byte
func (*NotifyMessage) GetGateAddr ¶
func (x *NotifyMessage) GetGateAddr() string
func (*NotifyMessage) GetRoute ¶
func (x *NotifyMessage) GetRoute() string
func (*NotifyMessage) GetSessionId ¶
func (x *NotifyMessage) GetSessionId() int64
func (*NotifyMessage) ProtoMessage ¶
func (*NotifyMessage) ProtoMessage()
func (*NotifyMessage) ProtoReflect ¶ added in v0.5.1
func (x *NotifyMessage) ProtoReflect() protoreflect.Message
func (*NotifyMessage) Reset ¶
func (x *NotifyMessage) Reset()
func (*NotifyMessage) String ¶
func (x *NotifyMessage) String() string
type PushMessage ¶
type PushMessage struct { SessionId int64 `protobuf:"varint,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"` Route string `protobuf:"bytes,2,opt,name=route,proto3" json:"route,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*PushMessage) Descriptor
deprecated
func (*PushMessage) Descriptor() ([]byte, []int)
Deprecated: Use PushMessage.ProtoReflect.Descriptor instead.
func (*PushMessage) GetData ¶
func (x *PushMessage) GetData() []byte
func (*PushMessage) GetRoute ¶
func (x *PushMessage) GetRoute() string
func (*PushMessage) GetSessionId ¶
func (x *PushMessage) GetSessionId() int64
func (*PushMessage) ProtoMessage ¶
func (*PushMessage) ProtoMessage()
func (*PushMessage) ProtoReflect ¶ added in v0.5.1
func (x *PushMessage) ProtoReflect() protoreflect.Message
func (*PushMessage) Reset ¶
func (x *PushMessage) Reset()
func (*PushMessage) String ¶
func (x *PushMessage) String() string
type RegisterRequest ¶
type RegisterRequest struct { MemberInfo *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo,proto3" json:"memberInfo,omitempty"` // contains filtered or unexported fields }
func (*RegisterRequest) Descriptor
deprecated
func (*RegisterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.
func (*RegisterRequest) GetMemberInfo ¶
func (x *RegisterRequest) GetMemberInfo() *MemberInfo
func (*RegisterRequest) ProtoMessage ¶
func (*RegisterRequest) ProtoMessage()
func (*RegisterRequest) ProtoReflect ¶ added in v0.5.1
func (x *RegisterRequest) ProtoReflect() protoreflect.Message
func (*RegisterRequest) Reset ¶
func (x *RegisterRequest) Reset()
func (*RegisterRequest) String ¶
func (x *RegisterRequest) String() string
type RegisterResponse ¶
type RegisterResponse struct { Members []*MemberInfo `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"` // contains filtered or unexported fields }
func (*RegisterResponse) Descriptor
deprecated
func (*RegisterResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.
func (*RegisterResponse) GetMembers ¶
func (x *RegisterResponse) GetMembers() []*MemberInfo
func (*RegisterResponse) ProtoMessage ¶
func (*RegisterResponse) ProtoMessage()
func (*RegisterResponse) ProtoReflect ¶ added in v0.5.1
func (x *RegisterResponse) ProtoReflect() protoreflect.Message
func (*RegisterResponse) Reset ¶
func (x *RegisterResponse) Reset()
func (*RegisterResponse) String ¶
func (x *RegisterResponse) String() string
type RequestMessage ¶
type RequestMessage struct { GateAddr string `protobuf:"bytes,1,opt,name=gateAddr,proto3" json:"gateAddr,omitempty"` SessionId int64 `protobuf:"varint,2,opt,name=sessionId,proto3" json:"sessionId,omitempty"` Id uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` Route string `protobuf:"bytes,4,opt,name=route,proto3" json:"route,omitempty"` Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*RequestMessage) Descriptor
deprecated
func (*RequestMessage) Descriptor() ([]byte, []int)
Deprecated: Use RequestMessage.ProtoReflect.Descriptor instead.
func (*RequestMessage) GetData ¶
func (x *RequestMessage) GetData() []byte
func (*RequestMessage) GetGateAddr ¶
func (x *RequestMessage) GetGateAddr() string
func (*RequestMessage) GetId ¶
func (x *RequestMessage) GetId() uint64
func (*RequestMessage) GetRoute ¶
func (x *RequestMessage) GetRoute() string
func (*RequestMessage) GetSessionId ¶
func (x *RequestMessage) GetSessionId() int64
func (*RequestMessage) ProtoMessage ¶
func (*RequestMessage) ProtoMessage()
func (*RequestMessage) ProtoReflect ¶ added in v0.5.1
func (x *RequestMessage) ProtoReflect() protoreflect.Message
func (*RequestMessage) Reset ¶
func (x *RequestMessage) Reset()
func (*RequestMessage) String ¶
func (x *RequestMessage) String() string
type ResponseMessage ¶
type ResponseMessage struct { SessionId int64 `protobuf:"varint,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ResponseMessage) Descriptor
deprecated
func (*ResponseMessage) Descriptor() ([]byte, []int)
Deprecated: Use ResponseMessage.ProtoReflect.Descriptor instead.
func (*ResponseMessage) GetData ¶
func (x *ResponseMessage) GetData() []byte
func (*ResponseMessage) GetId ¶
func (x *ResponseMessage) GetId() uint64
func (*ResponseMessage) GetSessionId ¶
func (x *ResponseMessage) GetSessionId() int64
func (*ResponseMessage) ProtoMessage ¶
func (*ResponseMessage) ProtoMessage()
func (*ResponseMessage) ProtoReflect ¶ added in v0.5.1
func (x *ResponseMessage) ProtoReflect() protoreflect.Message
func (*ResponseMessage) Reset ¶
func (x *ResponseMessage) Reset()
func (*ResponseMessage) String ¶
func (x *ResponseMessage) String() string
type SessionClosedRequest ¶
type SessionClosedRequest struct { SessionId int64 `protobuf:"varint,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"` // contains filtered or unexported fields }
func (*SessionClosedRequest) Descriptor
deprecated
func (*SessionClosedRequest) Descriptor() ([]byte, []int)
Deprecated: Use SessionClosedRequest.ProtoReflect.Descriptor instead.
func (*SessionClosedRequest) GetSessionId ¶
func (x *SessionClosedRequest) GetSessionId() int64
func (*SessionClosedRequest) ProtoMessage ¶
func (*SessionClosedRequest) ProtoMessage()
func (*SessionClosedRequest) ProtoReflect ¶ added in v0.5.1
func (x *SessionClosedRequest) ProtoReflect() protoreflect.Message
func (*SessionClosedRequest) Reset ¶
func (x *SessionClosedRequest) Reset()
func (*SessionClosedRequest) String ¶
func (x *SessionClosedRequest) String() string
type SessionClosedResponse ¶
type SessionClosedResponse struct {
// contains filtered or unexported fields
}
func (*SessionClosedResponse) Descriptor
deprecated
func (*SessionClosedResponse) Descriptor() ([]byte, []int)
Deprecated: Use SessionClosedResponse.ProtoReflect.Descriptor instead.
func (*SessionClosedResponse) ProtoMessage ¶
func (*SessionClosedResponse) ProtoMessage()
func (*SessionClosedResponse) ProtoReflect ¶ added in v0.5.1
func (x *SessionClosedResponse) ProtoReflect() protoreflect.Message
func (*SessionClosedResponse) Reset ¶
func (x *SessionClosedResponse) Reset()
func (*SessionClosedResponse) String ¶
func (x *SessionClosedResponse) String() string
type UnimplementedMasterServer ¶ added in v0.5.1
type UnimplementedMasterServer struct { }
UnimplementedMasterServer should be embedded to have forward compatible implementations.
func (UnimplementedMasterServer) Heartbeat ¶ added in v0.5.1
func (UnimplementedMasterServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
func (UnimplementedMasterServer) Register ¶ added in v0.5.1
func (UnimplementedMasterServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
func (UnimplementedMasterServer) Unregister ¶ added in v0.5.1
func (UnimplementedMasterServer) Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, error)
type UnimplementedMemberServer ¶ added in v0.5.1
type UnimplementedMemberServer struct { }
UnimplementedMemberServer should be embedded to have forward compatible implementations.
func (UnimplementedMemberServer) CloseSession ¶ added in v0.5.1
func (UnimplementedMemberServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
func (UnimplementedMemberServer) DelMember ¶ added in v0.5.1
func (UnimplementedMemberServer) DelMember(context.Context, *DelMemberRequest) (*DelMemberResponse, error)
func (UnimplementedMemberServer) HandleNotify ¶ added in v0.5.1
func (UnimplementedMemberServer) HandleNotify(context.Context, *NotifyMessage) (*MemberHandleResponse, error)
func (UnimplementedMemberServer) HandlePush ¶ added in v0.5.1
func (UnimplementedMemberServer) HandlePush(context.Context, *PushMessage) (*MemberHandleResponse, error)
func (UnimplementedMemberServer) HandleRequest ¶ added in v0.5.1
func (UnimplementedMemberServer) HandleRequest(context.Context, *RequestMessage) (*MemberHandleResponse, error)
func (UnimplementedMemberServer) HandleResponse ¶ added in v0.5.1
func (UnimplementedMemberServer) HandleResponse(context.Context, *ResponseMessage) (*MemberHandleResponse, error)
func (UnimplementedMemberServer) NewMember ¶ added in v0.5.1
func (UnimplementedMemberServer) NewMember(context.Context, *NewMemberRequest) (*NewMemberResponse, error)
func (UnimplementedMemberServer) SessionClosed ¶ added in v0.5.1
func (UnimplementedMemberServer) SessionClosed(context.Context, *SessionClosedRequest) (*SessionClosedResponse, error)
type UnregisterRequest ¶
type UnregisterRequest struct { ServiceAddr string `protobuf:"bytes,1,opt,name=serviceAddr,proto3" json:"serviceAddr,omitempty"` // contains filtered or unexported fields }
func (*UnregisterRequest) Descriptor
deprecated
func (*UnregisterRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnregisterRequest.ProtoReflect.Descriptor instead.
func (*UnregisterRequest) GetServiceAddr ¶
func (x *UnregisterRequest) GetServiceAddr() string
func (*UnregisterRequest) ProtoMessage ¶
func (*UnregisterRequest) ProtoMessage()
func (*UnregisterRequest) ProtoReflect ¶ added in v0.5.1
func (x *UnregisterRequest) ProtoReflect() protoreflect.Message
func (*UnregisterRequest) Reset ¶
func (x *UnregisterRequest) Reset()
func (*UnregisterRequest) String ¶
func (x *UnregisterRequest) String() string
type UnregisterResponse ¶
type UnregisterResponse struct {
// contains filtered or unexported fields
}
func (*UnregisterResponse) Descriptor
deprecated
func (*UnregisterResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnregisterResponse.ProtoReflect.Descriptor instead.
func (*UnregisterResponse) ProtoMessage ¶
func (*UnregisterResponse) ProtoMessage()
func (*UnregisterResponse) ProtoReflect ¶ added in v0.5.1
func (x *UnregisterResponse) ProtoReflect() protoreflect.Message
func (*UnregisterResponse) Reset ¶
func (x *UnregisterResponse) Reset()
func (*UnregisterResponse) String ¶
func (x *UnregisterResponse) String() string
type UnsafeMasterServer ¶ added in v0.5.1
type UnsafeMasterServer interface {
// contains filtered or unexported methods
}
UnsafeMasterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MasterServer will result in compilation errors.
type UnsafeMemberServer ¶ added in v0.5.1
type UnsafeMemberServer interface {
// contains filtered or unexported methods
}
UnsafeMemberServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MemberServer will result in compilation errors.