Documentation
¶
Index ¶
- type CometServer
- func (s *CometServer) Broadcast(ctx context.Context, in *comet.BroadcastReq) (*comet.BroadcastReply, error)
- func (s *CometServer) DelGroups(ctx context.Context, in *comet.DelGroupsReq) (*comet.DelGroupsReply, error)
- func (s *CometServer) GroupCast(ctx context.Context, in *comet.GroupCastReq) (*comet.GroupCastReply, error)
- func (s *CometServer) JoinGroups(ctx context.Context, in *comet.JoinGroupsReq) (*comet.JoinGroupsReply, error)
- func (s *CometServer) LeaveGroups(ctx context.Context, in *comet.LeaveGroupsReq) (*comet.LeaveGroupsReply, error)
- func (s *CometServer) ListCast(ctx context.Context, in *comet.ListCastReq) (*comet.ListCastReply, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CometServer ¶
type CometServer struct {
comet.UnimplementedCometServer
// contains filtered or unexported fields
}
func NewCometServer ¶
func NewCometServer(svcCtx *svc.ServiceContext) *CometServer
func (*CometServer) Broadcast ¶
func (s *CometServer) Broadcast(ctx context.Context, in *comet.BroadcastReq) (*comet.BroadcastReply, error)
func (*CometServer) DelGroups ¶
func (s *CometServer) DelGroups(ctx context.Context, in *comet.DelGroupsReq) (*comet.DelGroupsReply, error)
func (*CometServer) GroupCast ¶
func (s *CometServer) GroupCast(ctx context.Context, in *comet.GroupCastReq) (*comet.GroupCastReply, error)
func (*CometServer) JoinGroups ¶
func (s *CometServer) JoinGroups(ctx context.Context, in *comet.JoinGroupsReq) (*comet.JoinGroupsReply, error)
func (*CometServer) LeaveGroups ¶
func (s *CometServer) LeaveGroups(ctx context.Context, in *comet.LeaveGroupsReq) (*comet.LeaveGroupsReply, error)
func (*CometServer) ListCast ¶
func (s *CometServer) ListCast(ctx context.Context, in *comet.ListCastReq) (*comet.ListCastReply, error)
Source Files
Click to show internal directories.
Click to hide internal directories.