clusterpb

package
v0.5.4 Latest Latest
Warning

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

Go to latest
Published: Aug 27, 2021 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 int64 `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() int64

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 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)
	HandleRemote(ctx context.Context, in *RPCRequestMessage, opts ...grpc.CallOption) (*RPCResponseMessage, 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"`
	Services    []string `protobuf:"bytes,3,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberInfo) Descriptor deprecated

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

Deprecated: Use MemberInfo.ProtoReflect.Descriptor instead.

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) 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 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 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"`
	// contains filtered or unexported fields
}

func (*NotifyMessage) Descriptor deprecated

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

Deprecated: Use NotifyMessage.ProtoReflect.Descriptor instead.

func (*NotifyMessage) GetData

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

func (*NotifyMessage) GetGateAddr

func (x *NotifyMessage) GetGateAddr() string

func (*NotifyMessage) GetRoute

func (x *NotifyMessage) GetRoute() string

func (*NotifyMessage) GetSessionId

func (x *NotifyMessage) GetSessionId() 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 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"`
	// 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() int64

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 RPCRequestMessage added in v0.5.4

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

func (*RPCRequestMessage) Descriptor deprecated added in v0.5.4

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

Deprecated: Use RPCRequestMessage.ProtoReflect.Descriptor instead.

func (*RPCRequestMessage) GetData added in v0.5.4

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

func (*RPCRequestMessage) GetRoute added in v0.5.4

func (x *RPCRequestMessage) GetRoute() string

func (*RPCRequestMessage) ProtoMessage added in v0.5.4

func (*RPCRequestMessage) ProtoMessage()

func (*RPCRequestMessage) ProtoReflect added in v0.5.4

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

func (*RPCRequestMessage) Reset added in v0.5.4

func (x *RPCRequestMessage) Reset()

func (*RPCRequestMessage) String added in v0.5.4

func (x *RPCRequestMessage) String() string

type RPCResponseMessage added in v0.5.4

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

func (*RPCResponseMessage) Descriptor deprecated added in v0.5.4

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

Deprecated: Use RPCResponseMessage.ProtoReflect.Descriptor instead.

func (*RPCResponseMessage) GetData added in v0.5.4

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

func (*RPCResponseMessage) ProtoMessage added in v0.5.4

func (*RPCResponseMessage) ProtoMessage()

func (*RPCResponseMessage) ProtoReflect added in v0.5.4

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

func (*RPCResponseMessage) Reset added in v0.5.4

func (x *RPCResponseMessage) Reset()

func (*RPCResponseMessage) String added in v0.5.4

func (x *RPCResponseMessage) 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 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"`
	// contains filtered or unexported fields
}

func (*RequestMessage) Descriptor deprecated

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

Deprecated: Use RequestMessage.ProtoReflect.Descriptor instead.

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

func (x *RequestMessage) GetRoute() string

func (*RequestMessage) GetSessionId

func (x *RequestMessage) GetSessionId() 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 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"`
	// 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) GetSessionId

func (x *ResponseMessage) GetSessionId() int64

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

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 UnimplementedMasterServer

type UnimplementedMasterServer struct {
}

UnimplementedMasterServer can be embedded to have forward compatible implementations.

func (*UnimplementedMasterServer) Register

func (*UnimplementedMasterServer) Unregister

type UnimplementedMemberServer

type UnimplementedMemberServer struct {
}

UnimplementedMemberServer can be embedded to have forward compatible implementations.

func (*UnimplementedMemberServer) CloseSession

func (*UnimplementedMemberServer) DelMember

func (*UnimplementedMemberServer) HandleNotify

func (*UnimplementedMemberServer) HandlePush

func (*UnimplementedMemberServer) HandleRemote added in v0.5.4

func (*UnimplementedMemberServer) HandleRequest

func (*UnimplementedMemberServer) HandleResponse

func (*UnimplementedMemberServer) NewMember

func (*UnimplementedMemberServer) SessionClosed

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

Jump to

Keyboard shortcuts

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