clusterpb

package
v1.1.13 Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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 uint64 `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() uint64

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 DictionaryItem 

type DictionaryItem struct {
	Route      string `protobuf:"bytes,1,opt,name=route,proto3" json:"route,omitempty"`
	Code       uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	Type       string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Serializer uint32 `protobuf:"varint,4,opt,name=serializer,proto3" json:"serializer,omitempty"`
	// contains filtered or unexported fields
}

func (*DictionaryItem) Descriptor deprecated 

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

Deprecated: Use DictionaryItem.ProtoReflect.Descriptor instead.

func (*DictionaryItem) GetCode 

func (x *DictionaryItem) GetCode() uint32

func (*DictionaryItem) GetRoute 

func (x *DictionaryItem) GetRoute() string

func (*DictionaryItem) GetSerializer 

func (x *DictionaryItem) GetSerializer() uint32

func (*DictionaryItem) GetType 

func (x *DictionaryItem) GetType() string

func (*DictionaryItem) ProtoMessage 

func (*DictionaryItem) ProtoMessage()

func (*DictionaryItem) ProtoReflect 

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

func (*DictionaryItem) Reset 

func (x *DictionaryItem) Reset()

func (*DictionaryItem) String 

func (x *DictionaryItem) 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)
	SessionCreated(ctx context.Context, in *SessionCreatedRequest, opts ...grpc.CallOption) (*SessionCreatedResponse, error)
	PerformConvention(ctx context.Context, in *PerformConventionRequest, opts ...grpc.CallOption) (*PerformConventionResponse, 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"`
	Version     string            `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Services    []string          `protobuf:"bytes,4,rep,name=services,proto3" json:"services,omitempty"`
	Dictionary  []*DictionaryItem `protobuf:"bytes,5,rep,name=dictionary,proto3" json:"dictionary,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberInfo) Descriptor deprecated 

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

Deprecated: Use MemberInfo.ProtoReflect.Descriptor instead.

func (*MemberInfo) GetDictionary 

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

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

func (x *MemberInfo) GetVersion() 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)
	SessionCreated(context.Context, *SessionCreatedRequest) (*SessionCreatedResponse, error)
	PerformConvention(context.Context, *PerformConventionRequest) (*PerformConventionResponse, error)
}

MemberServer is the server API for Member service.

type NetAddr 

type NetAddr struct {
	Network string `protobuf:"bytes,1,opt,name=Network,proto3" json:"Network,omitempty"`
	Addr    string `protobuf:"bytes,2,opt,name=Addr,proto3" json:"Addr,omitempty"`
	// contains filtered or unexported fields
}

func (*NetAddr) Descriptor deprecated 

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

Deprecated: Use NetAddr.ProtoReflect.Descriptor instead.

func (*NetAddr) GetAddr 

func (x *NetAddr) GetAddr() string

func (*NetAddr) GetNetwork 

func (x *NetAddr) GetNetwork() string

func (*NetAddr) ProtoMessage 

func (*NetAddr) ProtoMessage()

func (*NetAddr) ProtoReflect 

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

func (*NetAddr) Reset 

func (x *NetAddr) Reset()

func (*NetAddr) String 

func (x *NetAddr) String() string

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  uint64   `protobuf:"varint,2,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	ShortVer   uint32   `protobuf:"varint,3,opt,name=shortVer,proto3" json:"shortVer,omitempty"`
	ID         uint64   `protobuf:"varint,4,opt,name=ID,proto3" json:"ID,omitempty"`
	UID        int64    `protobuf:"varint,5,opt,name=UID,proto3" json:"UID,omitempty"`
	Route      string   `protobuf:"bytes,6,opt,name=route,proto3" json:"route,omitempty"`
	Data       []byte   `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	RemoteAddr *NetAddr `protobuf:"bytes,8,opt,name=remoteAddr,proto3" json:"remoteAddr,omitempty"`
	Branch     uint32   `protobuf:"varint,9,opt,name=branch,proto3" json:"branch,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyMessage) Descriptor deprecated 

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

Deprecated: Use NotifyMessage.ProtoReflect.Descriptor instead.

func (*NotifyMessage) GetBranch added in v1.0.1 

func (x *NotifyMessage) GetBranch() uint32

func (*NotifyMessage) GetData 

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

func (*NotifyMessage) GetGateAddr 

func (x *NotifyMessage) GetGateAddr() string

func (*NotifyMessage) GetID 

func (x *NotifyMessage) GetID() uint64

func (*NotifyMessage) GetRemoteAddr 

func (x *NotifyMessage) GetRemoteAddr() *NetAddr

func (*NotifyMessage) GetRoute 

func (x *NotifyMessage) GetRoute() string

func (*NotifyMessage) GetSessionID 

func (x *NotifyMessage) GetSessionID() uint64

func (*NotifyMessage) GetShortVer 

func (x *NotifyMessage) GetShortVer() uint32

func (*NotifyMessage) GetUID 

func (x *NotifyMessage) GetUID() 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 PerformConventionRequest 

type PerformConventionRequest struct {
	Sig  int64  `protobuf:"varint,1,opt,name=sig,proto3" json:"sig,omitempty"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PerformConventionRequest) Descriptor deprecated 

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

Deprecated: Use PerformConventionRequest.ProtoReflect.Descriptor instead.

func (*PerformConventionRequest) GetData 

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

func (*PerformConventionRequest) GetSig 

func (x *PerformConventionRequest) GetSig() int64

func (*PerformConventionRequest) ProtoMessage 

func (*PerformConventionRequest) ProtoMessage()

func (*PerformConventionRequest) ProtoReflect 

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

func (*PerformConventionRequest) Reset 

func (x *PerformConventionRequest) Reset()

func (*PerformConventionRequest) String 

func (x *PerformConventionRequest) String() string

type PerformConventionResponse 

type PerformConventionResponse struct {
	Label string `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PerformConventionResponse) Descriptor deprecated 

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

Deprecated: Use PerformConventionResponse.ProtoReflect.Descriptor instead.

func (*PerformConventionResponse) GetData 

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

func (*PerformConventionResponse) GetLabel 

func (x *PerformConventionResponse) GetLabel() string

func (*PerformConventionResponse) ProtoMessage 

func (*PerformConventionResponse) ProtoMessage()

func (*PerformConventionResponse) ProtoReflect 

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

func (*PerformConventionResponse) Reset 

func (x *PerformConventionResponse) Reset()

func (*PerformConventionResponse) String 

func (x *PerformConventionResponse) String() string

type PushMessage 

type PushMessage struct {
	SessionID uint64 `protobuf:"varint,1,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	ShortVer  uint32 `protobuf:"varint,2,opt,name=shortVer,proto3" json:"shortVer,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 (*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() uint64

func (*PushMessage) GetShortVer 

func (x *PushMessage) GetShortVer() uint32

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 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  uint64   `protobuf:"varint,2,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	ShortVer   uint32   `protobuf:"varint,3,opt,name=shortVer,proto3" json:"shortVer,omitempty"`
	ID         uint64   `protobuf:"varint,4,opt,name=ID,proto3" json:"ID,omitempty"`
	UID        int64    `protobuf:"varint,5,opt,name=UID,proto3" json:"UID,omitempty"`
	Route      string   `protobuf:"bytes,6,opt,name=route,proto3" json:"route,omitempty"`
	Data       []byte   `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	RemoteAddr *NetAddr `protobuf:"bytes,8,opt,name=remoteAddr,proto3" json:"remoteAddr,omitempty"`
	Branch     uint32   `protobuf:"varint,9,opt,name=branch,proto3" json:"branch,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestMessage) Descriptor deprecated 

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

Deprecated: Use RequestMessage.ProtoReflect.Descriptor instead.

func (*RequestMessage) GetBranch added in v1.0.1 

func (x *RequestMessage) GetBranch() uint32

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

func (x *RequestMessage) GetRemoteAddr() *NetAddr

func (*RequestMessage) GetRoute 

func (x *RequestMessage) GetRoute() string

func (*RequestMessage) GetSessionID 

func (x *RequestMessage) GetSessionID() uint64

func (*RequestMessage) GetShortVer 

func (x *RequestMessage) GetShortVer() uint32

func (*RequestMessage) GetUID 

func (x *RequestMessage) GetUID() 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 uint64 `protobuf:"varint,1,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	ShortVer  uint32 `protobuf:"varint,2,opt,name=shortVer,proto3" json:"shortVer,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 (*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) GetRoute 

func (x *ResponseMessage) GetRoute() string

func (*ResponseMessage) GetSessionID 

func (x *ResponseMessage) GetSessionID() uint64

func (*ResponseMessage) GetShortVer 

func (x *ResponseMessage) GetShortVer() uint32

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 uint64 `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() uint64

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 SessionCreatedRequest added in v1.1.1 

type SessionCreatedRequest struct {
	Addr      string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	SessionID uint64 `protobuf:"varint,2,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionCreatedRequest) Descriptor deprecated added in v1.1.1 

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

Deprecated: Use SessionCreatedRequest.ProtoReflect.Descriptor instead.

func (*SessionCreatedRequest) GetAddr added in v1.1.1 

func (x *SessionCreatedRequest) GetAddr() string

func (*SessionCreatedRequest) GetSessionID added in v1.1.1 

func (x *SessionCreatedRequest) GetSessionID() uint64

func (*SessionCreatedRequest) ProtoMessage added in v1.1.1 

func (*SessionCreatedRequest) ProtoMessage()

func (*SessionCreatedRequest) ProtoReflect added in v1.1.1 

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

func (*SessionCreatedRequest) Reset added in v1.1.1 

func (x *SessionCreatedRequest) Reset()

func (*SessionCreatedRequest) String added in v1.1.1 

func (x *SessionCreatedRequest) String() string

type SessionCreatedResponse added in v1.1.1 

type SessionCreatedResponse struct {
	// contains filtered or unexported fields
}

func (*SessionCreatedResponse) Descriptor deprecated added in v1.1.1 

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

Deprecated: Use SessionCreatedResponse.ProtoReflect.Descriptor instead.

func (*SessionCreatedResponse) ProtoMessage added in v1.1.1 

func (*SessionCreatedResponse) ProtoMessage()

func (*SessionCreatedResponse) ProtoReflect added in v1.1.1 

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

func (*SessionCreatedResponse) Reset added in v1.1.1 

func (x *SessionCreatedResponse) Reset()

func (*SessionCreatedResponse) String added in v1.1.1 

func (x *SessionCreatedResponse) 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) 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) PerformConvention 

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

func (*UnimplementedMemberServer) SessionClosed 

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

func (*UnimplementedMemberServer) SessionCreated added in v1.1.1 

func (*UnimplementedMemberServer) SessionCreated(context.Context, *SessionCreatedRequest) (*SessionCreatedResponse, 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

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.