clusterpb

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Jan 17, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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            int64    `protobuf:"varint,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseSessionRequest) Descriptor 

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

func (*CloseSessionRequest) GetSessionId 

func (m *CloseSessionRequest) GetSessionId() int64

func (*CloseSessionRequest) ProtoMessage 

func (*CloseSessionRequest) ProtoMessage()

func (*CloseSessionRequest) Reset 

func (m *CloseSessionRequest) Reset()

func (*CloseSessionRequest) String 

func (m *CloseSessionRequest) String() string

func (*CloseSessionRequest) XXX_DiscardUnknown 

func (m *CloseSessionRequest) XXX_DiscardUnknown()

func (*CloseSessionRequest) XXX_Marshal 

func (m *CloseSessionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseSessionRequest) XXX_Merge 

func (m *CloseSessionRequest) XXX_Merge(src proto.Message)

func (*CloseSessionRequest) XXX_Size 

func (m *CloseSessionRequest) XXX_Size() int

func (*CloseSessionRequest) XXX_Unmarshal 

func (m *CloseSessionRequest) XXX_Unmarshal(b []byte) error

type CloseSessionResponse 

type CloseSessionResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseSessionResponse) Descriptor 

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

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) Reset 

func (m *CloseSessionResponse) Reset()

func (*CloseSessionResponse) String 

func (m *CloseSessionResponse) String() string

func (*CloseSessionResponse) XXX_DiscardUnknown 

func (m *CloseSessionResponse) XXX_DiscardUnknown()

func (*CloseSessionResponse) XXX_Marshal 

func (m *CloseSessionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseSessionResponse) XXX_Merge 

func (m *CloseSessionResponse) XXX_Merge(src proto.Message)

func (*CloseSessionResponse) XXX_Size 

func (m *CloseSessionResponse) XXX_Size() int

func (*CloseSessionResponse) XXX_Unmarshal 

func (m *CloseSessionResponse) XXX_Unmarshal(b []byte) error

type DelMemberRequest 

type DelMemberRequest struct {
	ServiceAddr          string   `protobuf:"bytes,1,opt,name=serviceAddr,proto3" json:"serviceAddr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DelMemberRequest) Descriptor 

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

func (*DelMemberRequest) GetServiceAddr 

func (m *DelMemberRequest) GetServiceAddr() string

func (*DelMemberRequest) ProtoMessage 

func (*DelMemberRequest) ProtoMessage()

func (*DelMemberRequest) Reset 

func (m *DelMemberRequest) Reset()

func (*DelMemberRequest) String 

func (m *DelMemberRequest) String() string

func (*DelMemberRequest) XXX_DiscardUnknown 

func (m *DelMemberRequest) XXX_DiscardUnknown()

func (*DelMemberRequest) XXX_Marshal 

func (m *DelMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelMemberRequest) XXX_Merge 

func (m *DelMemberRequest) XXX_Merge(src proto.Message)

func (*DelMemberRequest) XXX_Size 

func (m *DelMemberRequest) XXX_Size() int

func (*DelMemberRequest) XXX_Unmarshal 

func (m *DelMemberRequest) XXX_Unmarshal(b []byte) error

type DelMemberResponse 

type DelMemberResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DelMemberResponse) Descriptor 

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

func (*DelMemberResponse) ProtoMessage 

func (*DelMemberResponse) ProtoMessage()

func (*DelMemberResponse) Reset 

func (m *DelMemberResponse) Reset()

func (*DelMemberResponse) String 

func (m *DelMemberResponse) String() string

func (*DelMemberResponse) XXX_DiscardUnknown 

func (m *DelMemberResponse) XXX_DiscardUnknown()

func (*DelMemberResponse) XXX_Marshal 

func (m *DelMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelMemberResponse) XXX_Merge 

func (m *DelMemberResponse) XXX_Merge(src proto.Message)

func (*DelMemberResponse) XXX_Size 

func (m *DelMemberResponse) XXX_Size() int

func (*DelMemberResponse) XXX_Unmarshal 

func (m *DelMemberResponse) XXX_Unmarshal(b []byte) error

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.ClientConn) 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)
}

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.ClientConn) MemberClient

type MemberHandleResponse 

type MemberHandleResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MemberHandleResponse) Descriptor 

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

func (*MemberHandleResponse) ProtoMessage 

func (*MemberHandleResponse) ProtoMessage()

func (*MemberHandleResponse) Reset 

func (m *MemberHandleResponse) Reset()

func (*MemberHandleResponse) String 

func (m *MemberHandleResponse) String() string

func (*MemberHandleResponse) XXX_DiscardUnknown 

func (m *MemberHandleResponse) XXX_DiscardUnknown()

func (*MemberHandleResponse) XXX_Marshal 

func (m *MemberHandleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MemberHandleResponse) XXX_Merge 

func (m *MemberHandleResponse) XXX_Merge(src proto.Message)

func (*MemberHandleResponse) XXX_Size 

func (m *MemberHandleResponse) XXX_Size() int

func (*MemberHandleResponse) XXX_Unmarshal 

func (m *MemberHandleResponse) XXX_Unmarshal(b []byte) error

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"`
	Services             []string `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MemberInfo) Descriptor 

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

func (*MemberInfo) GetLabel 

func (m *MemberInfo) GetLabel() string

func (*MemberInfo) GetServiceAddr 

func (m *MemberInfo) GetServiceAddr() string

func (*MemberInfo) GetServices 

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

func (*MemberInfo) ProtoMessage 

func (*MemberInfo) ProtoMessage()

func (*MemberInfo) Reset 

func (m *MemberInfo) Reset()

func (*MemberInfo) String 

func (m *MemberInfo) String() string

func (*MemberInfo) XXX_DiscardUnknown 

func (m *MemberInfo) XXX_DiscardUnknown()

func (*MemberInfo) XXX_Marshal 

func (m *MemberInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MemberInfo) XXX_Merge 

func (m *MemberInfo) XXX_Merge(src proto.Message)

func (*MemberInfo) XXX_Size 

func (m *MemberInfo) XXX_Size() int

func (*MemberInfo) XXX_Unmarshal 

func (m *MemberInfo) XXX_Unmarshal(b []byte) error

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

MemberServer is the server API for Member service.

type NewMemberRequest 

type NewMemberRequest struct {
	MemberInfo           *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo,proto3" json:"memberInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*NewMemberRequest) Descriptor 

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

func (*NewMemberRequest) GetMemberInfo 

func (m *NewMemberRequest) GetMemberInfo() *MemberInfo

func (*NewMemberRequest) ProtoMessage 

func (*NewMemberRequest) ProtoMessage()

func (*NewMemberRequest) Reset 

func (m *NewMemberRequest) Reset()

func (*NewMemberRequest) String 

func (m *NewMemberRequest) String() string

func (*NewMemberRequest) XXX_DiscardUnknown 

func (m *NewMemberRequest) XXX_DiscardUnknown()

func (*NewMemberRequest) XXX_Marshal 

func (m *NewMemberRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewMemberRequest) XXX_Merge 

func (m *NewMemberRequest) XXX_Merge(src proto.Message)

func (*NewMemberRequest) XXX_Size 

func (m *NewMemberRequest) XXX_Size() int

func (*NewMemberRequest) XXX_Unmarshal 

func (m *NewMemberRequest) XXX_Unmarshal(b []byte) error

type NewMemberResponse 

type NewMemberResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewMemberResponse) Descriptor 

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

func (*NewMemberResponse) ProtoMessage 

func (*NewMemberResponse) ProtoMessage()

func (*NewMemberResponse) Reset 

func (m *NewMemberResponse) Reset()

func (*NewMemberResponse) String 

func (m *NewMemberResponse) String() string

func (*NewMemberResponse) XXX_DiscardUnknown 

func (m *NewMemberResponse) XXX_DiscardUnknown()

func (*NewMemberResponse) XXX_Marshal 

func (m *NewMemberResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewMemberResponse) XXX_Merge 

func (m *NewMemberResponse) XXX_Merge(src proto.Message)

func (*NewMemberResponse) XXX_Size 

func (m *NewMemberResponse) XXX_Size() int

func (*NewMemberResponse) XXX_Unmarshal 

func (m *NewMemberResponse) XXX_Unmarshal(b []byte) error

type NotifyMessage 

type NotifyMessage struct {
	GateAddr             string   `protobuf:"bytes,1,opt,name=gateAddr,proto3" json:"gateAddr,omitempty"`
	SessionId            int64    `protobuf:"varint,2,opt,name=sessionId,proto3" json:"sessionId,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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NotifyMessage) Descriptor 

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

func (*NotifyMessage) GetData 

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

func (*NotifyMessage) GetGateAddr 

func (m *NotifyMessage) GetGateAddr() string

func (*NotifyMessage) GetRoute 

func (m *NotifyMessage) GetRoute() string

func (*NotifyMessage) GetSessionId 

func (m *NotifyMessage) GetSessionId() int64

func (*NotifyMessage) ProtoMessage 

func (*NotifyMessage) ProtoMessage()

func (*NotifyMessage) Reset 

func (m *NotifyMessage) Reset()

func (*NotifyMessage) String 

func (m *NotifyMessage) String() string

func (*NotifyMessage) XXX_DiscardUnknown 

func (m *NotifyMessage) XXX_DiscardUnknown()

func (*NotifyMessage) XXX_Marshal 

func (m *NotifyMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NotifyMessage) XXX_Merge 

func (m *NotifyMessage) XXX_Merge(src proto.Message)

func (*NotifyMessage) XXX_Size 

func (m *NotifyMessage) XXX_Size() int

func (*NotifyMessage) XXX_Unmarshal 

func (m *NotifyMessage) XXX_Unmarshal(b []byte) error

type PushMessage 

type PushMessage struct {
	SessionId            int64    `protobuf:"varint,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"`
	Route                string   `protobuf:"bytes,2,opt,name=route,proto3" json:"route,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushMessage) Descriptor 

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

func (*PushMessage) GetData 

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

func (*PushMessage) GetRoute 

func (m *PushMessage) GetRoute() string

func (*PushMessage) GetSessionId 

func (m *PushMessage) GetSessionId() int64

func (*PushMessage) ProtoMessage 

func (*PushMessage) ProtoMessage()

func (*PushMessage) Reset 

func (m *PushMessage) Reset()

func (*PushMessage) String 

func (m *PushMessage) String() string

func (*PushMessage) XXX_DiscardUnknown 

func (m *PushMessage) XXX_DiscardUnknown()

func (*PushMessage) XXX_Marshal 

func (m *PushMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushMessage) XXX_Merge 

func (m *PushMessage) XXX_Merge(src proto.Message)

func (*PushMessage) XXX_Size 

func (m *PushMessage) XXX_Size() int

func (*PushMessage) XXX_Unmarshal 

func (m *PushMessage) XXX_Unmarshal(b []byte) error

type RegisterRequest 

type RegisterRequest struct {
	MemberInfo           *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo,proto3" json:"memberInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetMemberInfo 

func (m *RegisterRequest) GetMemberInfo() *MemberInfo

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

func (*RegisterRequest) XXX_DiscardUnknown 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal 

func (m *RegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterRequest) XXX_Merge 

func (m *RegisterRequest) XXX_Merge(src proto.Message)

func (*RegisterRequest) XXX_Size 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal 

func (m *RegisterRequest) XXX_Unmarshal(b []byte) error

type RegisterResponse 

type RegisterResponse struct {
	Members              []*MemberInfo `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*RegisterResponse) Descriptor 

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

func (*RegisterResponse) GetMembers 

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

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (m *RegisterResponse) String() string

func (*RegisterResponse) XXX_DiscardUnknown 

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal 

func (m *RegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterResponse) XXX_Merge 

func (m *RegisterResponse) XXX_Merge(src proto.Message)

func (*RegisterResponse) XXX_Size 

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal 

func (m *RegisterResponse) XXX_Unmarshal(b []byte) error

type RequestMessage 

type RequestMessage struct {
	GateAddr             string   `protobuf:"bytes,1,opt,name=gateAddr,proto3" json:"gateAddr,omitempty"`
	SessionId            int64    `protobuf:"varint,2,opt,name=sessionId,proto3" json:"sessionId,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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestMessage) Descriptor 

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

func (*RequestMessage) GetData 

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

func (*RequestMessage) GetGateAddr 

func (m *RequestMessage) GetGateAddr() string

func (*RequestMessage) GetId 

func (m *RequestMessage) GetId() uint64

func (*RequestMessage) GetRoute 

func (m *RequestMessage) GetRoute() string

func (*RequestMessage) GetSessionId 

func (m *RequestMessage) GetSessionId() int64

func (*RequestMessage) ProtoMessage 

func (*RequestMessage) ProtoMessage()

func (*RequestMessage) Reset 

func (m *RequestMessage) Reset()

func (*RequestMessage) String 

func (m *RequestMessage) String() string

func (*RequestMessage) XXX_DiscardUnknown 

func (m *RequestMessage) XXX_DiscardUnknown()

func (*RequestMessage) XXX_Marshal 

func (m *RequestMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestMessage) XXX_Merge 

func (m *RequestMessage) XXX_Merge(src proto.Message)

func (*RequestMessage) XXX_Size 

func (m *RequestMessage) XXX_Size() int

func (*RequestMessage) XXX_Unmarshal 

func (m *RequestMessage) XXX_Unmarshal(b []byte) error

type ResponseMessage 

type ResponseMessage struct {
	SessionId            int64    `protobuf:"varint,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"`
	Id                   uint64   `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseMessage) Descriptor 

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

func (*ResponseMessage) GetData 

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

func (*ResponseMessage) GetId 

func (m *ResponseMessage) GetId() uint64

func (*ResponseMessage) GetSessionId 

func (m *ResponseMessage) GetSessionId() int64

func (*ResponseMessage) ProtoMessage 

func (*ResponseMessage) ProtoMessage()

func (*ResponseMessage) Reset 

func (m *ResponseMessage) Reset()

func (*ResponseMessage) String 

func (m *ResponseMessage) String() string

func (*ResponseMessage) XXX_DiscardUnknown 

func (m *ResponseMessage) XXX_DiscardUnknown()

func (*ResponseMessage) XXX_Marshal 

func (m *ResponseMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseMessage) XXX_Merge 

func (m *ResponseMessage) XXX_Merge(src proto.Message)

func (*ResponseMessage) XXX_Size 

func (m *ResponseMessage) XXX_Size() int

func (*ResponseMessage) XXX_Unmarshal 

func (m *ResponseMessage) XXX_Unmarshal(b []byte) error

type SessionClosedRequest 

type SessionClosedRequest struct {
	SessionId            int64    `protobuf:"varint,1,opt,name=sessionId,proto3" json:"sessionId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SessionClosedRequest) Descriptor 

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

func (*SessionClosedRequest) GetSessionId 

func (m *SessionClosedRequest) GetSessionId() int64

func (*SessionClosedRequest) ProtoMessage 

func (*SessionClosedRequest) ProtoMessage()

func (*SessionClosedRequest) Reset 

func (m *SessionClosedRequest) Reset()

func (*SessionClosedRequest) String 

func (m *SessionClosedRequest) String() string

func (*SessionClosedRequest) XXX_DiscardUnknown 

func (m *SessionClosedRequest) XXX_DiscardUnknown()

func (*SessionClosedRequest) XXX_Marshal 

func (m *SessionClosedRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionClosedRequest) XXX_Merge 

func (m *SessionClosedRequest) XXX_Merge(src proto.Message)

func (*SessionClosedRequest) XXX_Size 

func (m *SessionClosedRequest) XXX_Size() int

func (*SessionClosedRequest) XXX_Unmarshal 

func (m *SessionClosedRequest) XXX_Unmarshal(b []byte) error

type SessionClosedResponse 

type SessionClosedResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SessionClosedResponse) Descriptor 

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

func (*SessionClosedResponse) ProtoMessage 

func (*SessionClosedResponse) ProtoMessage()

func (*SessionClosedResponse) Reset 

func (m *SessionClosedResponse) Reset()

func (*SessionClosedResponse) String 

func (m *SessionClosedResponse) String() string

func (*SessionClosedResponse) XXX_DiscardUnknown 

func (m *SessionClosedResponse) XXX_DiscardUnknown()

func (*SessionClosedResponse) XXX_Marshal 

func (m *SessionClosedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SessionClosedResponse) XXX_Merge 

func (m *SessionClosedResponse) XXX_Merge(src proto.Message)

func (*SessionClosedResponse) XXX_Size 

func (m *SessionClosedResponse) XXX_Size() int

func (*SessionClosedResponse) XXX_Unmarshal 

func (m *SessionClosedResponse) XXX_Unmarshal(b []byte) error

type UnimplementedMasterServer 

type UnimplementedMasterServer struct {
}

UnimplementedMasterServer can be embedded to have forward compatible implementations.

func (*UnimplementedMasterServer) Register 

func (*UnimplementedMasterServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterResponse, error)

func (*UnimplementedMasterServer) Unregister 

func (*UnimplementedMasterServer) Unregister(ctx context.Context, req *UnregisterRequest) (*UnregisterResponse, error)

type UnimplementedMemberServer 

type UnimplementedMemberServer struct {
}

UnimplementedMemberServer can be embedded to have forward compatible implementations.

func (*UnimplementedMemberServer) CloseSession 

func (*UnimplementedMemberServer) CloseSession(ctx context.Context, req *CloseSessionRequest) (*CloseSessionResponse, error)

func (*UnimplementedMemberServer) DelMember 

func (*UnimplementedMemberServer) DelMember(ctx context.Context, req *DelMemberRequest) (*DelMemberResponse, error)

func (*UnimplementedMemberServer) HandleNotify 

func (*UnimplementedMemberServer) HandleNotify(ctx context.Context, req *NotifyMessage) (*MemberHandleResponse, error)

func (*UnimplementedMemberServer) HandlePush 

func (*UnimplementedMemberServer) HandlePush(ctx context.Context, req *PushMessage) (*MemberHandleResponse, error)

func (*UnimplementedMemberServer) HandleRequest 

func (*UnimplementedMemberServer) HandleRequest(ctx context.Context, req *RequestMessage) (*MemberHandleResponse, error)

func (*UnimplementedMemberServer) HandleResponse 

func (*UnimplementedMemberServer) HandleResponse(ctx context.Context, req *ResponseMessage) (*MemberHandleResponse, error)

func (*UnimplementedMemberServer) NewMember 

func (*UnimplementedMemberServer) NewMember(ctx context.Context, req *NewMemberRequest) (*NewMemberResponse, error)

func (*UnimplementedMemberServer) SessionClosed 

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

type UnregisterRequest 

type UnregisterRequest struct {
	ServiceAddr          string   `protobuf:"bytes,1,opt,name=serviceAddr,proto3" json:"serviceAddr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterRequest) Descriptor 

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

func (*UnregisterRequest) GetServiceAddr 

func (m *UnregisterRequest) GetServiceAddr() string

func (*UnregisterRequest) ProtoMessage 

func (*UnregisterRequest) ProtoMessage()

func (*UnregisterRequest) Reset 

func (m *UnregisterRequest) Reset()

func (*UnregisterRequest) String 

func (m *UnregisterRequest) String() string

func (*UnregisterRequest) XXX_DiscardUnknown 

func (m *UnregisterRequest) XXX_DiscardUnknown()

func (*UnregisterRequest) XXX_Marshal 

func (m *UnregisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnregisterRequest) XXX_Merge 

func (m *UnregisterRequest) XXX_Merge(src proto.Message)

func (*UnregisterRequest) XXX_Size 

func (m *UnregisterRequest) XXX_Size() int

func (*UnregisterRequest) XXX_Unmarshal 

func (m *UnregisterRequest) XXX_Unmarshal(b []byte) error

type UnregisterResponse 

type UnregisterResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnregisterResponse) Descriptor 

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

func (*UnregisterResponse) ProtoMessage 

func (*UnregisterResponse) ProtoMessage()

func (*UnregisterResponse) Reset 

func (m *UnregisterResponse) Reset()

func (*UnregisterResponse) String 

func (m *UnregisterResponse) String() string

func (*UnregisterResponse) XXX_DiscardUnknown 

func (m *UnregisterResponse) XXX_DiscardUnknown()

func (*UnregisterResponse) XXX_Marshal 

func (m *UnregisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnregisterResponse) XXX_Merge 

func (m *UnregisterResponse) XXX_Merge(src proto.Message)

func (*UnregisterResponse) XXX_Size 

func (m *UnregisterResponse) XXX_Size() int

func (*UnregisterResponse) XXX_Unmarshal 

func (m *UnregisterResponse) XXX_Unmarshal(b []byte) error

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.