import "github.com/lonnng/nano/cluster/clusterpb"
Package clusterpb is a generated protocol buffer package.
It is generated from these files:
cluster.proto
It has these top-level messages:
MemberInfo RegisterRequest RegisterResponse UnregisterRequest UnregisterResponse RequestMessage NotifyMessage ResponseMessage PushMessage MemberHandleResponse NewMemberRequest NewMemberResponse DelMemberRequest DelMemberResponse SessionClosedRequest SessionClosedResponse CloseSessionRequest CloseSessionResponse
func RegisterMasterServer(s *grpc.Server, srv MasterServer)
func RegisterMemberServer(s *grpc.Server, srv MemberServer)
type CloseSessionRequest struct {
SessionId int64 `protobuf:"varint,1,opt,name=sessionId" json:"sessionId"`
}func (*CloseSessionRequest) Descriptor() ([]byte, []int)
func (m *CloseSessionRequest) GetSessionId() int64
func (*CloseSessionRequest) ProtoMessage()
func (m *CloseSessionRequest) Reset()
func (m *CloseSessionRequest) String() string
type CloseSessionResponse struct {
}func (*CloseSessionResponse) Descriptor() ([]byte, []int)
func (*CloseSessionResponse) ProtoMessage()
func (m *CloseSessionResponse) Reset()
func (m *CloseSessionResponse) String() string
type DelMemberRequest struct {
ServiceAddr string `protobuf:"bytes,1,opt,name=serviceAddr" json:"serviceAddr"`
}func (*DelMemberRequest) Descriptor() ([]byte, []int)
func (m *DelMemberRequest) GetServiceAddr() string
func (*DelMemberRequest) ProtoMessage()
func (m *DelMemberRequest) Reset()
func (m *DelMemberRequest) String() string
type DelMemberResponse struct {
}func (*DelMemberResponse) Descriptor() ([]byte, []int)
func (*DelMemberResponse) ProtoMessage()
func (m *DelMemberResponse) Reset()
func (m *DelMemberResponse) String() string
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)
}func NewMasterClient(cc *grpc.ClientConn) MasterClient
type MasterServer interface {
Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, error)
}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)
}func NewMemberClient(cc *grpc.ClientConn) MemberClient
type MemberHandleResponse struct {
}func (*MemberHandleResponse) Descriptor() ([]byte, []int)
func (*MemberHandleResponse) ProtoMessage()
func (m *MemberHandleResponse) Reset()
func (m *MemberHandleResponse) String() string
type MemberInfo struct {
Label string `protobuf:"bytes,1,opt,name=label" json:"label"`
ServiceAddr string `protobuf:"bytes,2,opt,name=serviceAddr" json:"serviceAddr"`
Services []string `protobuf:"bytes,3,rep,name=services" json:"services"`
}func (*MemberInfo) Descriptor() ([]byte, []int)
func (m *MemberInfo) GetLabel() string
func (m *MemberInfo) GetServiceAddr() string
func (m *MemberInfo) GetServices() []string
func (*MemberInfo) ProtoMessage()
func (m *MemberInfo) Reset()
func (m *MemberInfo) String() string
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)
}type NewMemberRequest struct {
MemberInfo *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo" json:"memberInfo"`
}func (*NewMemberRequest) Descriptor() ([]byte, []int)
func (m *NewMemberRequest) GetMemberInfo() *MemberInfo
func (*NewMemberRequest) ProtoMessage()
func (m *NewMemberRequest) Reset()
func (m *NewMemberRequest) String() string
type NewMemberResponse struct {
}func (*NewMemberResponse) Descriptor() ([]byte, []int)
func (*NewMemberResponse) ProtoMessage()
func (m *NewMemberResponse) Reset()
func (m *NewMemberResponse) String() string
type NotifyMessage struct {
GateAddr string `protobuf:"bytes,1,opt,name=gateAddr" json:"gateAddr"`
SessionId int64 `protobuf:"varint,2,opt,name=sessionId" json:"sessionId"`
Route string `protobuf:"bytes,3,opt,name=route" json:"route"`
Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data"`
}func (*NotifyMessage) Descriptor() ([]byte, []int)
func (m *NotifyMessage) GetData() []byte
func (m *NotifyMessage) GetGateAddr() string
func (m *NotifyMessage) GetRoute() string
func (m *NotifyMessage) GetSessionId() int64
func (*NotifyMessage) ProtoMessage()
func (m *NotifyMessage) Reset()
func (m *NotifyMessage) String() string
type PushMessage struct {
SessionId int64 `protobuf:"varint,1,opt,name=sessionId" json:"sessionId"`
Route string `protobuf:"bytes,2,opt,name=route" json:"route"`
Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data"`
}func (*PushMessage) Descriptor() ([]byte, []int)
func (m *PushMessage) GetData() []byte
func (m *PushMessage) GetRoute() string
func (m *PushMessage) GetSessionId() int64
func (*PushMessage) ProtoMessage()
func (m *PushMessage) Reset()
func (m *PushMessage) String() string
type RegisterRequest struct {
MemberInfo *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo" json:"memberInfo"`
}func (*RegisterRequest) Descriptor() ([]byte, []int)
func (m *RegisterRequest) GetMemberInfo() *MemberInfo
func (*RegisterRequest) ProtoMessage()
func (m *RegisterRequest) Reset()
func (m *RegisterRequest) String() string
type RegisterResponse struct {
Members []*MemberInfo `protobuf:"bytes,1,rep,name=members" json:"members"`
}func (*RegisterResponse) Descriptor() ([]byte, []int)
func (m *RegisterResponse) GetMembers() []*MemberInfo
func (*RegisterResponse) ProtoMessage()
func (m *RegisterResponse) Reset()
func (m *RegisterResponse) String() string
type RequestMessage struct {
GateAddr string `protobuf:"bytes,1,opt,name=gateAddr" json:"gateAddr"`
SessionId int64 `protobuf:"varint,2,opt,name=sessionId" json:"sessionId"`
Id uint64 `protobuf:"varint,3,opt,name=id" json:"id"`
Route string `protobuf:"bytes,4,opt,name=route" json:"route"`
Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data"`
}func (*RequestMessage) Descriptor() ([]byte, []int)
func (m *RequestMessage) GetData() []byte
func (m *RequestMessage) GetGateAddr() string
func (m *RequestMessage) GetId() uint64
func (m *RequestMessage) GetRoute() string
func (m *RequestMessage) GetSessionId() int64
func (*RequestMessage) ProtoMessage()
func (m *RequestMessage) Reset()
func (m *RequestMessage) String() string
type ResponseMessage struct {
SessionId int64 `protobuf:"varint,1,opt,name=sessionId" json:"sessionId"`
Id uint64 `protobuf:"varint,2,opt,name=id" json:"id"`
Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data"`
}func (*ResponseMessage) Descriptor() ([]byte, []int)
func (m *ResponseMessage) GetData() []byte
func (m *ResponseMessage) GetId() uint64
func (m *ResponseMessage) GetSessionId() int64
func (*ResponseMessage) ProtoMessage()
func (m *ResponseMessage) Reset()
func (m *ResponseMessage) String() string
type SessionClosedRequest struct {
SessionId int64 `protobuf:"varint,1,opt,name=sessionId" json:"sessionId"`
}func (*SessionClosedRequest) Descriptor() ([]byte, []int)
func (m *SessionClosedRequest) GetSessionId() int64
func (*SessionClosedRequest) ProtoMessage()
func (m *SessionClosedRequest) Reset()
func (m *SessionClosedRequest) String() string
type SessionClosedResponse struct {
}func (*SessionClosedResponse) Descriptor() ([]byte, []int)
func (*SessionClosedResponse) ProtoMessage()
func (m *SessionClosedResponse) Reset()
func (m *SessionClosedResponse) String() string
type UnregisterRequest struct {
ServiceAddr string `protobuf:"bytes,1,opt,name=serviceAddr" json:"serviceAddr"`
}func (*UnregisterRequest) Descriptor() ([]byte, []int)
func (m *UnregisterRequest) GetServiceAddr() string
func (*UnregisterRequest) ProtoMessage()
func (m *UnregisterRequest) Reset()
func (m *UnregisterRequest) String() string
type UnregisterResponse struct {
}func (*UnregisterResponse) Descriptor() ([]byte, []int)
func (*UnregisterResponse) ProtoMessage()
func (m *UnregisterResponse) Reset()
func (m *UnregisterResponse) String() string
Package clusterpb imports 5 packages (graph). Updated 2019-07-05. Refresh now. Tools for package owners.