Documentation ¶
Index ¶
- Variables
- func RegisterMasterServer(s *grpc.Server, srv MasterServer)
- func RegisterMemberServer(s *grpc.Server, 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 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 RPCRequestMessage
- func (*RPCRequestMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RPCRequestMessage) GetData() []byte
- func (x *RPCRequestMessage) GetRoute() string
- func (*RPCRequestMessage) ProtoMessage()
- func (x *RPCRequestMessage) ProtoReflect() protoreflect.Message
- func (x *RPCRequestMessage) Reset()
- func (x *RPCRequestMessage) String() string
- type RPCResponseMessage
- func (*RPCResponseMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RPCResponseMessage) GetData() []byte
- func (*RPCResponseMessage) ProtoMessage()
- func (x *RPCResponseMessage) ProtoReflect() protoreflect.Message
- func (x *RPCResponseMessage) Reset()
- func (x *RPCResponseMessage) 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
- 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) HandleRemote(context.Context, *RPCRequestMessage) (*RPCResponseMessage, 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
Constants ¶
This section is empty.
Variables ¶
var File_cluster_proto protoreflect.FileDescriptor
Functions ¶
func RegisterMasterServer ¶
func RegisterMasterServer(s *grpc.Server, srv MasterServer)
func RegisterMemberServer ¶
func RegisterMemberServer(s *grpc.Server, 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 ¶
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 ¶
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 ¶
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 ¶
func (x *DelMemberResponse) ProtoReflect() protoreflect.Message
func (*DelMemberResponse) Reset ¶
func (x *DelMemberResponse) Reset()
func (*DelMemberResponse) String ¶
func (x *DelMemberResponse) 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) }
MasterClient is the client API for Master service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#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) }
MasterServer is the server API for Master service.
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) HandleRemote(ctx context.Context, in *RPCRequestMessage, opts ...grpc.CallOption) (*RPCResponseMessage, error) }
MemberClient is the client API for Member service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#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 ¶
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 ¶
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) HandleRemote(context.Context, *RPCRequestMessage) (*RPCResponseMessage, error) }
MemberServer is the server API for Member service.
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 ¶
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 ¶
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 ¶
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 ¶
func (x *PushMessage) ProtoReflect() protoreflect.Message
func (*PushMessage) Reset ¶
func (x *PushMessage) Reset()
func (*PushMessage) String ¶
func (x *PushMessage) String() string
type RPCRequestMessage ¶ added in v0.5.4
type RPCRequestMessage struct { Route string `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*RPCRequestMessage) Descriptor
deprecated
added in
v0.5.4
func (*RPCRequestMessage) Descriptor() ([]byte, []int)
Deprecated: Use RPCRequestMessage.ProtoReflect.Descriptor instead.
func (*RPCRequestMessage) GetData ¶ added in v0.5.4
func (x *RPCRequestMessage) GetData() []byte
func (*RPCRequestMessage) GetRoute ¶ added in v0.5.4
func (x *RPCRequestMessage) GetRoute() string
func (*RPCRequestMessage) ProtoMessage ¶ added in v0.5.4
func (*RPCRequestMessage) ProtoMessage()
func (*RPCRequestMessage) ProtoReflect ¶ added in v0.5.4
func (x *RPCRequestMessage) ProtoReflect() protoreflect.Message
func (*RPCRequestMessage) Reset ¶ added in v0.5.4
func (x *RPCRequestMessage) Reset()
func (*RPCRequestMessage) String ¶ added in v0.5.4
func (x *RPCRequestMessage) String() string
type RPCResponseMessage ¶ added in v0.5.4
type RPCResponseMessage struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*RPCResponseMessage) Descriptor
deprecated
added in
v0.5.4
func (*RPCResponseMessage) Descriptor() ([]byte, []int)
Deprecated: Use RPCResponseMessage.ProtoReflect.Descriptor instead.
func (*RPCResponseMessage) GetData ¶ added in v0.5.4
func (x *RPCResponseMessage) GetData() []byte
func (*RPCResponseMessage) ProtoMessage ¶ added in v0.5.4
func (*RPCResponseMessage) ProtoMessage()
func (*RPCResponseMessage) ProtoReflect ¶ added in v0.5.4
func (x *RPCResponseMessage) ProtoReflect() protoreflect.Message
func (*RPCResponseMessage) Reset ¶ added in v0.5.4
func (x *RPCResponseMessage) Reset()
func (*RPCResponseMessage) String ¶ added in v0.5.4
func (x *RPCResponseMessage) 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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
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 ¶
func (x *SessionClosedResponse) ProtoReflect() protoreflect.Message
func (*SessionClosedResponse) Reset ¶
func (x *SessionClosedResponse) Reset()
func (*SessionClosedResponse) String ¶
func (x *SessionClosedResponse) String() string
type UnimplementedMasterServer ¶
type UnimplementedMasterServer struct { }
UnimplementedMasterServer can be embedded to have forward compatible implementations.
func (*UnimplementedMasterServer) Register ¶
func (*UnimplementedMasterServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
func (*UnimplementedMasterServer) Unregister ¶
func (*UnimplementedMasterServer) Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, error)
type UnimplementedMemberServer ¶
type UnimplementedMemberServer struct { }
UnimplementedMemberServer can be embedded to have forward compatible implementations.
func (*UnimplementedMemberServer) CloseSession ¶
func (*UnimplementedMemberServer) CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
func (*UnimplementedMemberServer) DelMember ¶
func (*UnimplementedMemberServer) DelMember(context.Context, *DelMemberRequest) (*DelMemberResponse, error)
func (*UnimplementedMemberServer) HandleNotify ¶
func (*UnimplementedMemberServer) HandleNotify(context.Context, *NotifyMessage) (*MemberHandleResponse, error)
func (*UnimplementedMemberServer) HandlePush ¶
func (*UnimplementedMemberServer) HandlePush(context.Context, *PushMessage) (*MemberHandleResponse, error)
func (*UnimplementedMemberServer) HandleRemote ¶ added in v0.5.4
func (*UnimplementedMemberServer) HandleRemote(context.Context, *RPCRequestMessage) (*RPCResponseMessage, error)
func (*UnimplementedMemberServer) HandleRequest ¶
func (*UnimplementedMemberServer) HandleRequest(context.Context, *RequestMessage) (*MemberHandleResponse, error)
func (*UnimplementedMemberServer) HandleResponse ¶
func (*UnimplementedMemberServer) HandleResponse(context.Context, *ResponseMessage) (*MemberHandleResponse, error)
func (*UnimplementedMemberServer) NewMember ¶
func (*UnimplementedMemberServer) NewMember(context.Context, *NewMemberRequest) (*NewMemberResponse, error)
func (*UnimplementedMemberServer) SessionClosed ¶
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 ¶
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 ¶
func (x *UnregisterResponse) ProtoReflect() protoreflect.Message
func (*UnregisterResponse) Reset ¶
func (x *UnregisterResponse) Reset()
func (*UnregisterResponse) String ¶
func (x *UnregisterResponse) String() string