clusterpb

package

Go to main page

Versions in this module

v1

v1.0.2

May 14, 2024

v1.0.1

May 14, 2024

Changes in this version

type MemberClient

+ SessionCreated func(ctx context.Context, in *SessionCreatedRequest, opts ...grpc.CallOption) (*SessionCreatedResponse, error)

type MemberServer

+ SessionCreated func(context.Context, *SessionCreatedRequest) (*SessionCreatedResponse, error)

type NotifyMessage

+ DataType uint32

+ func (x *NotifyMessage) GetDataType() uint32

type PushMessage

+ DataType uint32

+ func (x *PushMessage) GetDataType() uint32

type RequestMessage

+ DataType uint32

+ func (x *RequestMessage) GetDataType() uint32

type ResponseMessage

+ DataType uint32

+ func (x *ResponseMessage) GetDataType() uint32

+ type SessionCreatedRequest struct

+ Addr string

+ SessionID uint64

+ func (*SessionCreatedRequest) Descriptor() ([]byte, []int)

+ func (*SessionCreatedRequest) ProtoMessage()

+ func (x *SessionCreatedRequest) GetAddr() string

+ func (x *SessionCreatedRequest) GetSessionID() uint64

+ func (x *SessionCreatedRequest) ProtoReflect() protoreflect.Message

+ func (x *SessionCreatedRequest) Reset()

+ func (x *SessionCreatedRequest) String() string

+ type SessionCreatedResponse struct

+ func (*SessionCreatedResponse) Descriptor() ([]byte, []int)

+ func (*SessionCreatedResponse) ProtoMessage()

+ func (x *SessionCreatedResponse) ProtoReflect() protoreflect.Message

+ func (x *SessionCreatedResponse) Reset()

+ func (x *SessionCreatedResponse) String() string

type UnimplementedMemberServer

+ func (*UnimplementedMemberServer) SessionCreated(context.Context, *SessionCreatedRequest) (*SessionCreatedResponse, error)

v1.0.0

Apr 28, 2024

Changes in this version

+ var File_cluster_proto protoreflect.FileDescriptor

+ func RegisterMasterServer(s *grpc.Server, srv MasterServer)

+ func RegisterMemberServer(s *grpc.Server, 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 DictionaryItem struct

+ Code uint32

+ Route string

+ Serializer uint32

+ Type string

+ func (*DictionaryItem) Descriptor() ([]byte, []int)

+ func (*DictionaryItem) ProtoMessage()

+ func (x *DictionaryItem) GetCode() uint32

+ func (x *DictionaryItem) GetRoute() string

+ func (x *DictionaryItem) GetSerializer() uint32

+ func (x *DictionaryItem) GetType() string

+ func (x *DictionaryItem) ProtoReflect() protoreflect.Message

+ func (x *DictionaryItem) Reset()

+ func (x *DictionaryItem) String() string

+ type MasterClient interface

+ 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

+ 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)

+ PerformConvention func(ctx context.Context, in *PerformConventionRequest, opts ...grpc.CallOption) (*PerformConventionResponse, 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

+ Dictionary []*DictionaryItem

+ Label string

+ ServiceAddr string

+ Services []string

+ Version string

+ func (*MemberInfo) Descriptor() ([]byte, []int)

+ func (*MemberInfo) ProtoMessage()

+ func (x *MemberInfo) GetDictionary() []*DictionaryItem

+ func (x *MemberInfo) GetLabel() string

+ func (x *MemberInfo) GetServiceAddr() string

+ func (x *MemberInfo) GetServices() []string

+ func (x *MemberInfo) GetVersion() 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)

+ PerformConvention func(context.Context, *PerformConventionRequest) (*PerformConventionResponse, error)

+ SessionClosed func(context.Context, *SessionClosedRequest) (*SessionClosedResponse, error)

+ type NetAddr struct

+ Addr string

+ Network string

+ func (*NetAddr) Descriptor() ([]byte, []int)

+ func (*NetAddr) ProtoMessage()

+ func (x *NetAddr) GetAddr() string

+ func (x *NetAddr) GetNetwork() string

+ func (x *NetAddr) ProtoReflect() protoreflect.Message

+ func (x *NetAddr) Reset()

+ func (x *NetAddr) String() string

+ 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

+ Branch uint32

+ Data []byte

+ GateAddr string

+ ID uint64

+ RemoteAddr *NetAddr

+ Route string

+ SessionID int64

+ ShortVer uint32

+ UID int64

+ func (*NotifyMessage) Descriptor() ([]byte, []int)

+ func (*NotifyMessage) ProtoMessage()

+ func (x *NotifyMessage) GetBranch() uint32

+ func (x *NotifyMessage) GetData() []byte

+ func (x *NotifyMessage) GetGateAddr() string

+ func (x *NotifyMessage) GetID() uint64

+ func (x *NotifyMessage) GetRemoteAddr() *NetAddr

+ func (x *NotifyMessage) GetRoute() string

+ func (x *NotifyMessage) GetSessionID() int64

+ func (x *NotifyMessage) GetShortVer() uint32

+ func (x *NotifyMessage) GetUID() int64

+ func (x *NotifyMessage) ProtoReflect() protoreflect.Message

+ func (x *NotifyMessage) Reset()

+ func (x *NotifyMessage) String() string

+ type PerformConventionRequest struct

+ Data []byte

+ Sig int64

+ func (*PerformConventionRequest) Descriptor() ([]byte, []int)

+ func (*PerformConventionRequest) ProtoMessage()

+ func (x *PerformConventionRequest) GetData() []byte

+ func (x *PerformConventionRequest) GetSig() int64

+ func (x *PerformConventionRequest) ProtoReflect() protoreflect.Message

+ func (x *PerformConventionRequest) Reset()

+ func (x *PerformConventionRequest) String() string

+ type PerformConventionResponse struct

+ Data []byte

+ Label string

+ func (*PerformConventionResponse) Descriptor() ([]byte, []int)

+ func (*PerformConventionResponse) ProtoMessage()

+ func (x *PerformConventionResponse) GetData() []byte

+ func (x *PerformConventionResponse) GetLabel() string

+ func (x *PerformConventionResponse) ProtoReflect() protoreflect.Message

+ func (x *PerformConventionResponse) Reset()

+ func (x *PerformConventionResponse) String() string

+ type PushMessage struct

+ Data []byte

+ Route string

+ SessionID int64

+ ShortVer uint32

+ 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) GetShortVer() uint32

+ 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

+ Branch uint32

+ Data []byte

+ GateAddr string

+ ID uint64

+ RemoteAddr *NetAddr

+ Route string

+ SessionID int64

+ ShortVer uint32

+ UID int64

+ func (*RequestMessage) Descriptor() ([]byte, []int)

+ func (*RequestMessage) ProtoMessage()

+ func (x *RequestMessage) GetBranch() uint32

+ func (x *RequestMessage) GetData() []byte

+ func (x *RequestMessage) GetGateAddr() string

+ func (x *RequestMessage) GetID() uint64

+ func (x *RequestMessage) GetRemoteAddr() *NetAddr

+ func (x *RequestMessage) GetRoute() string

+ func (x *RequestMessage) GetSessionID() int64

+ func (x *RequestMessage) GetShortVer() uint32

+ func (x *RequestMessage) GetUID() int64

+ func (x *RequestMessage) ProtoReflect() protoreflect.Message

+ func (x *RequestMessage) Reset()

+ func (x *RequestMessage) String() string

+ type ResponseMessage struct

+ Data []byte

+ ID uint64

+ Route string

+ SessionID int64

+ ShortVer uint32

+ func (*ResponseMessage) Descriptor() ([]byte, []int)

+ func (*ResponseMessage) ProtoMessage()

+ func (x *ResponseMessage) GetData() []byte

+ func (x *ResponseMessage) GetID() uint64

+ func (x *ResponseMessage) GetRoute() string

+ func (x *ResponseMessage) GetSessionID() int64

+ func (x *ResponseMessage) GetShortVer() uint32

+ 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) 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) PerformConvention(context.Context, *PerformConventionRequest) (*PerformConventionResponse, 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL