clusterpb

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 6, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_cluster_proto protoreflect.FileDescriptor
View Source 
var Master_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "clusterpb.Master",
	HandlerType: (*MasterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Master_Register_Handler,
		},
		{
			MethodName: "Unregister",
			Handler:    _Master_Unregister_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _Master_Heartbeat_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cluster.proto",
}

Master_ServiceDesc is the grpc.ServiceDesc for Master service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var Member_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "clusterpb.Member",
	HandlerType: (*MemberServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HandleRequest",
			Handler:    _Member_HandleRequest_Handler,
		},
		{
			MethodName: "HandleNotify",
			Handler:    _Member_HandleNotify_Handler,
		},
		{
			MethodName: "HandlePush",
			Handler:    _Member_HandlePush_Handler,
		},
		{
			MethodName: "HandleResponse",
			Handler:    _Member_HandleResponse_Handler,
		},
		{
			MethodName: "NewMember",
			Handler:    _Member_NewMember_Handler,
		},
		{
			MethodName: "DelMember",
			Handler:    _Member_DelMember_Handler,
		},
		{
			MethodName: "SessionClosed",
			Handler:    _Member_SessionClosed_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _Member_CloseSession_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cluster.proto",
}

Member_ServiceDesc is the grpc.ServiceDesc for Member service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMasterServer 

func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)

func RegisterMemberServer 

func RegisterMemberServer(s grpc.ServiceRegistrar, 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 HeartbeatRequest 

type HeartbeatRequest struct {
	MemberInfo *MemberInfo `protobuf:"bytes,1,opt,name=memberInfo,proto3" json:"memberInfo,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetMemberInfo 

func (x *HeartbeatRequest) GetMemberInfo() *MemberInfo

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

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

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) 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)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
}

MasterClient is the client API for Master service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#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)
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
}

MasterServer is the server API for Master service. All implementations should embed UnimplementedMasterServer for forward compatibility

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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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 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. All implementations should embed UnimplementedMemberServer for forward compatibility

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 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 should be embedded to have forward compatible implementations.

func (UnimplementedMasterServer) Heartbeat 

func (UnimplementedMasterServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

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 should 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) SessionClosed 

func (UnimplementedMemberServer) SessionClosed(context.Context, *SessionClosedRequest) (*SessionClosedResponse, 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

type UnsafeMasterServer 

type UnsafeMasterServer interface {
	// contains filtered or unexported methods
}

UnsafeMasterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MasterServer will result in compilation errors.

type UnsafeMemberServer 

type UnsafeMemberServer interface {
	// contains filtered or unexported methods
}

UnsafeMemberServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MemberServer will result in compilation errors.

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.