Versions in this module Expand all Collapse all v0 v0.5.0 Apr 6, 2023 Changes in this version + var File_cluster_proto protoreflect.FileDescriptor + var Master_ServiceDesc = grpc.ServiceDesc + var Member_ServiceDesc = grpc.ServiceDesc + func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer) + func RegisterMemberServer(s grpc.ServiceRegistrar, srv MemberServer) + type CloseSessionRequest struct + SessionId int64 + func (*CloseSessionRequest) Descriptor() ([]byte, []int) + func (*CloseSessionRequest) ProtoMessage() + func (x *CloseSessionRequest) GetSessionId() int64 + func (x *CloseSessionRequest) ProtoReflect() protoreflect.Message + func (x *CloseSessionRequest) Reset() + func (x *CloseSessionRequest) String() string + type CloseSessionResponse struct + func (*CloseSessionResponse) Descriptor() ([]byte, []int) + func (*CloseSessionResponse) ProtoMessage() + func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message + func (x *CloseSessionResponse) Reset() + func (x *CloseSessionResponse) String() string + type DelMemberRequest struct + ServiceAddr string + func (*DelMemberRequest) Descriptor() ([]byte, []int) + func (*DelMemberRequest) ProtoMessage() + func (x *DelMemberRequest) GetServiceAddr() string + func (x *DelMemberRequest) ProtoReflect() protoreflect.Message + func (x *DelMemberRequest) Reset() + func (x *DelMemberRequest) String() string + type DelMemberResponse struct + func (*DelMemberResponse) Descriptor() ([]byte, []int) + func (*DelMemberResponse) ProtoMessage() + func (x *DelMemberResponse) ProtoReflect() protoreflect.Message + func (x *DelMemberResponse) Reset() + func (x *DelMemberResponse) String() string + type HeartbeatRequest struct + MemberInfo *MemberInfo + func (*HeartbeatRequest) Descriptor() ([]byte, []int) + func (*HeartbeatRequest) ProtoMessage() + func (x *HeartbeatRequest) GetMemberInfo() *MemberInfo + func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message + func (x *HeartbeatRequest) Reset() + func (x *HeartbeatRequest) String() string + type HeartbeatResponse struct + func (*HeartbeatResponse) Descriptor() ([]byte, []int) + func (*HeartbeatResponse) ProtoMessage() + func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message + func (x *HeartbeatResponse) Reset() + func (x *HeartbeatResponse) String() string + type MasterClient interface + Heartbeat func(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error) + Register func(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error) + Unregister func(ctx context.Context, in *UnregisterRequest, opts ...grpc.CallOption) (*UnregisterResponse, error) + func NewMasterClient(cc grpc.ClientConnInterface) MasterClient + type MasterServer interface + Heartbeat func(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error) + Register func(context.Context, *RegisterRequest) (*RegisterResponse, error) + Unregister func(context.Context, *UnregisterRequest) (*UnregisterResponse, error) + type MemberClient interface + CloseSession func(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error) + DelMember func(ctx context.Context, in *DelMemberRequest, opts ...grpc.CallOption) (*DelMemberResponse, error) + HandleNotify func(ctx context.Context, in *NotifyMessage, opts ...grpc.CallOption) (*MemberHandleResponse, error) + HandlePush func(ctx context.Context, in *PushMessage, opts ...grpc.CallOption) (*MemberHandleResponse, error) + HandleRequest func(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*MemberHandleResponse, error) + HandleResponse func(ctx context.Context, in *ResponseMessage, opts ...grpc.CallOption) (*MemberHandleResponse, error) + NewMember func(ctx context.Context, in *NewMemberRequest, opts ...grpc.CallOption) (*NewMemberResponse, error) + SessionClosed func(ctx context.Context, in *SessionClosedRequest, opts ...grpc.CallOption) (*SessionClosedResponse, error) + func NewMemberClient(cc grpc.ClientConnInterface) MemberClient + type MemberHandleResponse struct + func (*MemberHandleResponse) Descriptor() ([]byte, []int) + func (*MemberHandleResponse) ProtoMessage() + func (x *MemberHandleResponse) ProtoReflect() protoreflect.Message + func (x *MemberHandleResponse) Reset() + func (x *MemberHandleResponse) String() string + type MemberInfo struct + Label string + ServiceAddr string + Services []string + func (*MemberInfo) Descriptor() ([]byte, []int) + func (*MemberInfo) ProtoMessage() + func (x *MemberInfo) GetLabel() string + func (x *MemberInfo) GetServiceAddr() string + func (x *MemberInfo) GetServices() []string + func (x *MemberInfo) ProtoReflect() protoreflect.Message + func (x *MemberInfo) Reset() + func (x *MemberInfo) String() string + type MemberServer interface + CloseSession func(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error) + DelMember func(context.Context, *DelMemberRequest) (*DelMemberResponse, error) + HandleNotify func(context.Context, *NotifyMessage) (*MemberHandleResponse, error) + HandlePush func(context.Context, *PushMessage) (*MemberHandleResponse, error) + HandleRequest func(context.Context, *RequestMessage) (*MemberHandleResponse, error) + HandleResponse func(context.Context, *ResponseMessage) (*MemberHandleResponse, error) + NewMember func(context.Context, *NewMemberRequest) (*NewMemberResponse, error) + SessionClosed func(context.Context, *SessionClosedRequest) (*SessionClosedResponse, error) + type NewMemberRequest struct + MemberInfo *MemberInfo + func (*NewMemberRequest) Descriptor() ([]byte, []int) + func (*NewMemberRequest) ProtoMessage() + func (x *NewMemberRequest) GetMemberInfo() *MemberInfo + func (x *NewMemberRequest) ProtoReflect() protoreflect.Message + func (x *NewMemberRequest) Reset() + func (x *NewMemberRequest) String() string + type NewMemberResponse struct + func (*NewMemberResponse) Descriptor() ([]byte, []int) + func (*NewMemberResponse) ProtoMessage() + func (x *NewMemberResponse) ProtoReflect() protoreflect.Message + func (x *NewMemberResponse) Reset() + func (x *NewMemberResponse) String() string + type NotifyMessage struct + Data []byte + GateAddr string + Route string + SessionId int64 + func (*NotifyMessage) Descriptor() ([]byte, []int) + func (*NotifyMessage) ProtoMessage() + func (x *NotifyMessage) GetData() []byte + func (x *NotifyMessage) GetGateAddr() string + func (x *NotifyMessage) GetRoute() string + func (x *NotifyMessage) GetSessionId() int64 + func (x *NotifyMessage) ProtoReflect() protoreflect.Message + func (x *NotifyMessage) Reset() + func (x *NotifyMessage) String() string + type PushMessage struct + Data []byte + Route string + SessionId int64 + func (*PushMessage) Descriptor() ([]byte, []int) + func (*PushMessage) ProtoMessage() + func (x *PushMessage) GetData() []byte + func (x *PushMessage) GetRoute() string + func (x *PushMessage) GetSessionId() int64 + func (x *PushMessage) ProtoReflect() protoreflect.Message + func (x *PushMessage) Reset() + func (x *PushMessage) String() string + type RegisterRequest struct + MemberInfo *MemberInfo + func (*RegisterRequest) Descriptor() ([]byte, []int) + func (*RegisterRequest) ProtoMessage() + func (x *RegisterRequest) GetMemberInfo() *MemberInfo + func (x *RegisterRequest) ProtoReflect() protoreflect.Message + func (x *RegisterRequest) Reset() + func (x *RegisterRequest) String() string + type RegisterResponse struct + Members []*MemberInfo + func (*RegisterResponse) Descriptor() ([]byte, []int) + func (*RegisterResponse) ProtoMessage() + func (x *RegisterResponse) GetMembers() []*MemberInfo + func (x *RegisterResponse) ProtoReflect() protoreflect.Message + func (x *RegisterResponse) Reset() + func (x *RegisterResponse) String() string + type RequestMessage struct + Data []byte + GateAddr string + Id uint64 + Route string + SessionId int64 + func (*RequestMessage) Descriptor() ([]byte, []int) + func (*RequestMessage) ProtoMessage() + 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 (x *RequestMessage) ProtoReflect() protoreflect.Message + func (x *RequestMessage) Reset() + func (x *RequestMessage) String() string + type ResponseMessage struct + Data []byte + Id uint64 + SessionId int64 + func (*ResponseMessage) Descriptor() ([]byte, []int) + func (*ResponseMessage) ProtoMessage() + func (x *ResponseMessage) GetData() []byte + func (x *ResponseMessage) GetId() uint64 + func (x *ResponseMessage) GetSessionId() int64 + func (x *ResponseMessage) ProtoReflect() protoreflect.Message + func (x *ResponseMessage) Reset() + func (x *ResponseMessage) String() string + type SessionClosedRequest struct + SessionId int64 + func (*SessionClosedRequest) Descriptor() ([]byte, []int) + func (*SessionClosedRequest) ProtoMessage() + func (x *SessionClosedRequest) GetSessionId() int64 + func (x *SessionClosedRequest) ProtoReflect() protoreflect.Message + func (x *SessionClosedRequest) Reset() + func (x *SessionClosedRequest) String() string + type SessionClosedResponse struct + func (*SessionClosedResponse) Descriptor() ([]byte, []int) + func (*SessionClosedResponse) ProtoMessage() + func (x *SessionClosedResponse) ProtoReflect() protoreflect.Message + func (x *SessionClosedResponse) Reset() + func (x *SessionClosedResponse) String() string + type UnimplementedMasterServer struct + 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 struct + 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 struct + ServiceAddr string + func (*UnregisterRequest) Descriptor() ([]byte, []int) + func (*UnregisterRequest) ProtoMessage() + func (x *UnregisterRequest) GetServiceAddr() string + func (x *UnregisterRequest) ProtoReflect() protoreflect.Message + func (x *UnregisterRequest) Reset() + func (x *UnregisterRequest) String() string + type UnregisterResponse struct + func (*UnregisterResponse) Descriptor() ([]byte, []int) + func (*UnregisterResponse) ProtoMessage() + func (x *UnregisterResponse) ProtoReflect() protoreflect.Message + func (x *UnregisterResponse) Reset() + func (x *UnregisterResponse) String() string + type UnsafeMasterServer interface + type UnsafeMemberServer interface
Go to main page