nano: github.com/lonnng/nano/cluster/clusterpb Index | Files

package clusterpb

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

Index

Package Files

cluster.pb.go

func RegisterMasterServer Uses

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

func RegisterMemberServer Uses

func RegisterMemberServer(s *grpc.Server, srv MemberServer)

type CloseSessionRequest Uses

type CloseSessionRequest struct {
    SessionId int64 `protobuf:"varint,1,opt,name=sessionId" json:"sessionId"`
}

func (*CloseSessionRequest) Descriptor Uses

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

func (*CloseSessionRequest) GetSessionId Uses

func (m *CloseSessionRequest) GetSessionId() int64

func (*CloseSessionRequest) ProtoMessage Uses

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset Uses

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) String Uses

func (m *CloseSessionRequest) String() string

type CloseSessionResponse Uses

type CloseSessionResponse struct {
}

func (*CloseSessionResponse) Descriptor Uses

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

func (*CloseSessionResponse) ProtoMessage Uses

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset Uses

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) String Uses

func (m *CloseSessionResponse) String() string

type DelMemberRequest Uses

type DelMemberRequest struct {
    ServiceAddr string `protobuf:"bytes,1,opt,name=serviceAddr" json:"serviceAddr"`
}

func (*DelMemberRequest) Descriptor Uses

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

func (*DelMemberRequest) GetServiceAddr Uses

func (m *DelMemberRequest) GetServiceAddr() string

func (*DelMemberRequest) ProtoMessage Uses

func (*DelMemberRequest) ProtoMessage()

func (*DelMemberRequest) Reset Uses

func (m *DelMemberRequest) Reset()

func (*DelMemberRequest) String Uses

func (m *DelMemberRequest) String() string

type DelMemberResponse Uses

type DelMemberResponse struct {
}

func (*DelMemberResponse) Descriptor Uses

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

func (*DelMemberResponse) ProtoMessage Uses

func (*DelMemberResponse) ProtoMessage()

func (*DelMemberResponse) Reset Uses

func (m *DelMemberResponse) Reset()

func (*DelMemberResponse) String Uses

func (m *DelMemberResponse) String() string

type MasterClient Uses

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 Uses

func NewMasterClient(cc *grpc.ClientConn) MasterClient

type MasterServer Uses

type MasterServer interface {
    Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
    Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, error)
}

type MemberClient Uses

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 Uses

func NewMemberClient(cc *grpc.ClientConn) MemberClient

type MemberHandleResponse Uses

type MemberHandleResponse struct {
}

func (*MemberHandleResponse) Descriptor Uses

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

func (*MemberHandleResponse) ProtoMessage Uses

func (*MemberHandleResponse) ProtoMessage()

func (*MemberHandleResponse) Reset Uses

func (m *MemberHandleResponse) Reset()

func (*MemberHandleResponse) String Uses

func (m *MemberHandleResponse) String() string

type MemberInfo Uses

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 Uses

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

func (*MemberInfo) GetLabel Uses

func (m *MemberInfo) GetLabel() string

func (*MemberInfo) GetServiceAddr Uses

func (m *MemberInfo) GetServiceAddr() string

func (*MemberInfo) GetServices Uses

func (m *MemberInfo) GetServices() []string

func (*MemberInfo) ProtoMessage Uses

func (*MemberInfo) ProtoMessage()

func (*MemberInfo) Reset Uses

func (m *MemberInfo) Reset()

func (*MemberInfo) String Uses

func (m *MemberInfo) String() string

type MemberServer Uses

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 Uses

type NewMemberRequest struct {
    MemberInfo *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo" json:"memberInfo"`
}

func (*NewMemberRequest) Descriptor Uses

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

func (*NewMemberRequest) GetMemberInfo Uses

func (m *NewMemberRequest) GetMemberInfo() *MemberInfo

func (*NewMemberRequest) ProtoMessage Uses

func (*NewMemberRequest) ProtoMessage()

func (*NewMemberRequest) Reset Uses

func (m *NewMemberRequest) Reset()

func (*NewMemberRequest) String Uses

func (m *NewMemberRequest) String() string

type NewMemberResponse Uses

type NewMemberResponse struct {
}

func (*NewMemberResponse) Descriptor Uses

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

func (*NewMemberResponse) ProtoMessage Uses

func (*NewMemberResponse) ProtoMessage()

func (*NewMemberResponse) Reset Uses

func (m *NewMemberResponse) Reset()

func (*NewMemberResponse) String Uses

func (m *NewMemberResponse) String() string

type NotifyMessage Uses

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 Uses

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

func (*NotifyMessage) GetData Uses

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

func (*NotifyMessage) GetGateAddr Uses

func (m *NotifyMessage) GetGateAddr() string

func (*NotifyMessage) GetRoute Uses

func (m *NotifyMessage) GetRoute() string

func (*NotifyMessage) GetSessionId Uses

func (m *NotifyMessage) GetSessionId() int64

func (*NotifyMessage) ProtoMessage Uses

func (*NotifyMessage) ProtoMessage()

func (*NotifyMessage) Reset Uses

func (m *NotifyMessage) Reset()

func (*NotifyMessage) String Uses

func (m *NotifyMessage) String() string

type PushMessage Uses

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 Uses

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

func (*PushMessage) GetData Uses

func (m *PushMessage) GetData() []byte

func (*PushMessage) GetRoute Uses

func (m *PushMessage) GetRoute() string

func (*PushMessage) GetSessionId Uses

func (m *PushMessage) GetSessionId() int64

func (*PushMessage) ProtoMessage Uses

func (*PushMessage) ProtoMessage()

func (*PushMessage) Reset Uses

func (m *PushMessage) Reset()

func (*PushMessage) String Uses

func (m *PushMessage) String() string

type RegisterRequest Uses

type RegisterRequest struct {
    MemberInfo *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo" json:"memberInfo"`
}

func (*RegisterRequest) Descriptor Uses

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

func (*RegisterRequest) GetMemberInfo Uses

func (m *RegisterRequest) GetMemberInfo() *MemberInfo

func (*RegisterRequest) ProtoMessage Uses

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset Uses

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String Uses

func (m *RegisterRequest) String() string

type RegisterResponse Uses

type RegisterResponse struct {
    Members []*MemberInfo `protobuf:"bytes,1,rep,name=members" json:"members"`
}

func (*RegisterResponse) Descriptor Uses

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

func (*RegisterResponse) GetMembers Uses

func (m *RegisterResponse) GetMembers() []*MemberInfo

func (*RegisterResponse) ProtoMessage Uses

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset Uses

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String Uses

func (m *RegisterResponse) String() string

type RequestMessage Uses

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 Uses

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

func (*RequestMessage) GetData Uses

func (m *RequestMessage) GetData() []byte

func (*RequestMessage) GetGateAddr Uses

func (m *RequestMessage) GetGateAddr() string

func (*RequestMessage) GetId Uses

func (m *RequestMessage) GetId() uint64

func (*RequestMessage) GetRoute Uses

func (m *RequestMessage) GetRoute() string

func (*RequestMessage) GetSessionId Uses

func (m *RequestMessage) GetSessionId() int64

func (*RequestMessage) ProtoMessage Uses

func (*RequestMessage) ProtoMessage()

func (*RequestMessage) Reset Uses

func (m *RequestMessage) Reset()

func (*RequestMessage) String Uses

func (m *RequestMessage) String() string

type ResponseMessage Uses

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 Uses

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

func (*ResponseMessage) GetData Uses

func (m *ResponseMessage) GetData() []byte

func (*ResponseMessage) GetId Uses

func (m *ResponseMessage) GetId() uint64

func (*ResponseMessage) GetSessionId Uses

func (m *ResponseMessage) GetSessionId() int64

func (*ResponseMessage) ProtoMessage Uses

func (*ResponseMessage) ProtoMessage()

func (*ResponseMessage) Reset Uses

func (m *ResponseMessage) Reset()

func (*ResponseMessage) String Uses

func (m *ResponseMessage) String() string

type SessionClosedRequest Uses

type SessionClosedRequest struct {
    SessionId int64 `protobuf:"varint,1,opt,name=sessionId" json:"sessionId"`
}

func (*SessionClosedRequest) Descriptor Uses

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

func (*SessionClosedRequest) GetSessionId Uses

func (m *SessionClosedRequest) GetSessionId() int64

func (*SessionClosedRequest) ProtoMessage Uses

func (*SessionClosedRequest) ProtoMessage()

func (*SessionClosedRequest) Reset Uses

func (m *SessionClosedRequest) Reset()

func (*SessionClosedRequest) String Uses

func (m *SessionClosedRequest) String() string

type SessionClosedResponse Uses

type SessionClosedResponse struct {
}

func (*SessionClosedResponse) Descriptor Uses

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

func (*SessionClosedResponse) ProtoMessage Uses

func (*SessionClosedResponse) ProtoMessage()

func (*SessionClosedResponse) Reset Uses

func (m *SessionClosedResponse) Reset()

func (*SessionClosedResponse) String Uses

func (m *SessionClosedResponse) String() string

type UnregisterRequest Uses

type UnregisterRequest struct {
    ServiceAddr string `protobuf:"bytes,1,opt,name=serviceAddr" json:"serviceAddr"`
}

func (*UnregisterRequest) Descriptor Uses

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

func (*UnregisterRequest) GetServiceAddr Uses

func (m *UnregisterRequest) GetServiceAddr() string

func (*UnregisterRequest) ProtoMessage Uses

func (*UnregisterRequest) ProtoMessage()

func (*UnregisterRequest) Reset Uses

func (m *UnregisterRequest) Reset()

func (*UnregisterRequest) String Uses

func (m *UnregisterRequest) String() string

type UnregisterResponse Uses

type UnregisterResponse struct {
}

func (*UnregisterResponse) Descriptor Uses

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

func (*UnregisterResponse) ProtoMessage Uses

func (*UnregisterResponse) ProtoMessage()

func (*UnregisterResponse) Reset Uses

func (m *UnregisterResponse) Reset()

func (*UnregisterResponse) String Uses

func (m *UnregisterResponse) String() string

Package clusterpb imports 5 packages (graph). Updated 2019-07-05. Refresh now. Tools for package owners.