comet

package
v0.2.0-alpha.0 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Comet_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "im.comet.Comet",
	HandlerType: (*CometServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListCast",
			Handler:    _Comet_ListCast_Handler,
		},
		{
			MethodName: "Broadcast",
			Handler:    _Comet_Broadcast_Handler,
		},
		{
			MethodName: "GroupCast",
			Handler:    _Comet_GroupCast_Handler,
		},
		{
			MethodName: "JoinGroups",
			Handler:    _Comet_JoinGroups_Handler,
		},
		{
			MethodName: "LeaveGroups",
			Handler:    _Comet_LeaveGroups_Handler,
		},
		{
			MethodName: "DelGroups",
			Handler:    _Comet_DelGroups_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "comet/comet.proto",
}

Comet_ServiceDesc is the grpc.ServiceDesc for Comet 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 File_comet_comet_proto protoreflect.FileDescriptor

Functions

func RegisterCometServer 

func RegisterCometServer(s grpc.ServiceRegistrar, srv CometServer)

Types

type BroadcastReply 

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

func (*BroadcastReply) Descriptor deprecated 

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

Deprecated: Use BroadcastReply.ProtoReflect.Descriptor instead.

func (*BroadcastReply) ProtoMessage 

func (*BroadcastReply) ProtoMessage()

func (*BroadcastReply) ProtoReflect 

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

func (*BroadcastReply) Reset 

func (x *BroadcastReply) Reset()

func (*BroadcastReply) String 

func (x *BroadcastReply) String() string

type BroadcastReq 

type BroadcastReq struct {
	Proto *protocol.Proto `protobuf:"bytes,1,opt,name=proto,proto3" json:"proto,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastReq) Descriptor deprecated 

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

Deprecated: Use BroadcastReq.ProtoReflect.Descriptor instead.

func (*BroadcastReq) GetProto 

func (x *BroadcastReq) GetProto() *protocol.Proto

func (*BroadcastReq) ProtoMessage 

func (*BroadcastReq) ProtoMessage()

func (*BroadcastReq) ProtoReflect 

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

func (*BroadcastReq) Reset 

func (x *BroadcastReq) Reset()

func (*BroadcastReq) String 

func (x *BroadcastReq) String() string

type CometClient 

type CometClient interface {
	ListCast(ctx context.Context, in *ListCastReq, opts ...grpc.CallOption) (*ListCastReply, error)
	Broadcast(ctx context.Context, in *BroadcastReq, opts ...grpc.CallOption) (*BroadcastReply, error)
	GroupCast(ctx context.Context, in *GroupCastReq, opts ...grpc.CallOption) (*GroupCastReply, error)
	JoinGroups(ctx context.Context, in *JoinGroupsReq, opts ...grpc.CallOption) (*JoinGroupsReply, error)
	LeaveGroups(ctx context.Context, in *LeaveGroupsReq, opts ...grpc.CallOption) (*LeaveGroupsReply, error)
	DelGroups(ctx context.Context, in *DelGroupsReq, opts ...grpc.CallOption) (*DelGroupsReply, error)
}

CometClient is the client API for Comet 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 NewCometClient 

func NewCometClient(cc grpc.ClientConnInterface) CometClient

type CometServer 

type CometServer interface {
	ListCast(context.Context, *ListCastReq) (*ListCastReply, error)
	Broadcast(context.Context, *BroadcastReq) (*BroadcastReply, error)
	GroupCast(context.Context, *GroupCastReq) (*GroupCastReply, error)
	JoinGroups(context.Context, *JoinGroupsReq) (*JoinGroupsReply, error)
	LeaveGroups(context.Context, *LeaveGroupsReq) (*LeaveGroupsReply, error)
	DelGroups(context.Context, *DelGroupsReq) (*DelGroupsReply, error)
	// contains filtered or unexported methods
}

CometServer is the server API for Comet service. All implementations must embed UnimplementedCometServer for forward compatibility

type DelGroupsReply 

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

func (*DelGroupsReply) Descriptor deprecated 

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

Deprecated: Use DelGroupsReply.ProtoReflect.Descriptor instead.

func (*DelGroupsReply) ProtoMessage 

func (*DelGroupsReply) ProtoMessage()

func (*DelGroupsReply) ProtoReflect 

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

func (*DelGroupsReply) Reset 

func (x *DelGroupsReply) Reset()

func (*DelGroupsReply) String 

func (x *DelGroupsReply) String() string

type DelGroupsReq 

type DelGroupsReq struct {
	Gid []string `protobuf:"bytes,1,rep,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

func (*DelGroupsReq) Descriptor deprecated 

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

Deprecated: Use DelGroupsReq.ProtoReflect.Descriptor instead.

func (*DelGroupsReq) GetGid 

func (x *DelGroupsReq) GetGid() []string

func (*DelGroupsReq) ProtoMessage 

func (*DelGroupsReq) ProtoMessage()

func (*DelGroupsReq) ProtoReflect 

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

func (*DelGroupsReq) Reset 

func (x *DelGroupsReq) Reset()

func (*DelGroupsReq) String 

func (x *DelGroupsReq) String() string

type GroupCastReply 

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

func (*GroupCastReply) Descriptor deprecated 

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

Deprecated: Use GroupCastReply.ProtoReflect.Descriptor instead.

func (*GroupCastReply) ProtoMessage 

func (*GroupCastReply) ProtoMessage()

func (*GroupCastReply) ProtoReflect 

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

func (*GroupCastReply) Reset 

func (x *GroupCastReply) Reset()

func (*GroupCastReply) String 

func (x *GroupCastReply) String() string

type GroupCastReq 

type GroupCastReq struct {
	Gid   string          `protobuf:"bytes,1,opt,name=gid,proto3" json:"gid,omitempty"`
	Proto *protocol.Proto `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupCastReq) Descriptor deprecated 

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

Deprecated: Use GroupCastReq.ProtoReflect.Descriptor instead.

func (*GroupCastReq) GetGid 

func (x *GroupCastReq) GetGid() string

func (*GroupCastReq) GetProto 

func (x *GroupCastReq) GetProto() *protocol.Proto

func (*GroupCastReq) ProtoMessage 

func (*GroupCastReq) ProtoMessage()

func (*GroupCastReq) ProtoReflect 

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

func (*GroupCastReq) Reset 

func (x *GroupCastReq) Reset()

func (*GroupCastReq) String 

func (x *GroupCastReq) String() string

type JoinGroupsReply 

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

func (*JoinGroupsReply) Descriptor deprecated 

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

Deprecated: Use JoinGroupsReply.ProtoReflect.Descriptor instead.

func (*JoinGroupsReply) ProtoMessage 

func (*JoinGroupsReply) ProtoMessage()

func (*JoinGroupsReply) ProtoReflect 

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

func (*JoinGroupsReply) Reset 

func (x *JoinGroupsReply) Reset()

func (*JoinGroupsReply) String 

func (x *JoinGroupsReply) String() string

type JoinGroupsReq 

type JoinGroupsReq struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Gid  []string `protobuf:"bytes,2,rep,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinGroupsReq) Descriptor deprecated 

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

Deprecated: Use JoinGroupsReq.ProtoReflect.Descriptor instead.

func (*JoinGroupsReq) GetGid 

func (x *JoinGroupsReq) GetGid() []string

func (*JoinGroupsReq) GetKeys 

func (x *JoinGroupsReq) GetKeys() []string

func (*JoinGroupsReq) ProtoMessage 

func (*JoinGroupsReq) ProtoMessage()

func (*JoinGroupsReq) ProtoReflect 

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

func (*JoinGroupsReq) Reset 

func (x *JoinGroupsReq) Reset()

func (*JoinGroupsReq) String 

func (x *JoinGroupsReq) String() string

type LeaveGroupsReply 

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

func (*LeaveGroupsReply) Descriptor deprecated 

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

Deprecated: Use LeaveGroupsReply.ProtoReflect.Descriptor instead.

func (*LeaveGroupsReply) ProtoMessage 

func (*LeaveGroupsReply) ProtoMessage()

func (*LeaveGroupsReply) ProtoReflect 

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

func (*LeaveGroupsReply) Reset 

func (x *LeaveGroupsReply) Reset()

func (*LeaveGroupsReply) String 

func (x *LeaveGroupsReply) String() string

type LeaveGroupsReq 

type LeaveGroupsReq struct {
	Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Gid  []string `protobuf:"bytes,2,rep,name=gid,proto3" json:"gid,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaveGroupsReq) Descriptor deprecated 

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

Deprecated: Use LeaveGroupsReq.ProtoReflect.Descriptor instead.

func (*LeaveGroupsReq) GetGid 

func (x *LeaveGroupsReq) GetGid() []string

func (*LeaveGroupsReq) GetKeys 

func (x *LeaveGroupsReq) GetKeys() []string

func (*LeaveGroupsReq) ProtoMessage 

func (*LeaveGroupsReq) ProtoMessage()

func (*LeaveGroupsReq) ProtoReflect 

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

func (*LeaveGroupsReq) Reset 

func (x *LeaveGroupsReq) Reset()

func (*LeaveGroupsReq) String 

func (x *LeaveGroupsReq) String() string

type ListCastReply 

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

func (*ListCastReply) Descriptor deprecated 

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

Deprecated: Use ListCastReply.ProtoReflect.Descriptor instead.

func (*ListCastReply) ProtoMessage 

func (*ListCastReply) ProtoMessage()

func (*ListCastReply) ProtoReflect 

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

func (*ListCastReply) Reset 

func (x *ListCastReply) Reset()

func (*ListCastReply) String 

func (x *ListCastReply) String() string

type ListCastReq 

type ListCastReq struct {
	Keys  []string        `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Proto *protocol.Proto `protobuf:"bytes,2,opt,name=proto,proto3" json:"proto,omitempty"`
	// contains filtered or unexported fields
}

func (*ListCastReq) Descriptor deprecated 

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

Deprecated: Use ListCastReq.ProtoReflect.Descriptor instead.

func (*ListCastReq) GetKeys 

func (x *ListCastReq) GetKeys() []string

func (*ListCastReq) GetProto 

func (x *ListCastReq) GetProto() *protocol.Proto

func (*ListCastReq) ProtoMessage 

func (*ListCastReq) ProtoMessage()

func (*ListCastReq) ProtoReflect 

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

func (*ListCastReq) Reset 

func (x *ListCastReq) Reset()

func (*ListCastReq) String 

func (x *ListCastReq) String() string

type UnimplementedCometServer 

type UnimplementedCometServer struct {
}

UnimplementedCometServer must be embedded to have forward compatible implementations.

func (UnimplementedCometServer) Broadcast 

func (UnimplementedCometServer) Broadcast(context.Context, *BroadcastReq) (*BroadcastReply, error)

func (UnimplementedCometServer) DelGroups 

func (UnimplementedCometServer) DelGroups(context.Context, *DelGroupsReq) (*DelGroupsReply, error)

func (UnimplementedCometServer) GroupCast 

func (UnimplementedCometServer) GroupCast(context.Context, *GroupCastReq) (*GroupCastReply, error)

func (UnimplementedCometServer) JoinGroups 

func (UnimplementedCometServer) JoinGroups(context.Context, *JoinGroupsReq) (*JoinGroupsReply, error)

func (UnimplementedCometServer) LeaveGroups 

func (UnimplementedCometServer) LeaveGroups(context.Context, *LeaveGroupsReq) (*LeaveGroupsReply, error)

func (UnimplementedCometServer) ListCast 

func (UnimplementedCometServer) ListCast(context.Context, *ListCastReq) (*ListCastReply, error)

type UnsafeCometServer 

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

UnsafeCometServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CometServer 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.