cometclient

Documentation

Index

• type AuthMsg
• type BroadcastGroupReply
• type BroadcastGroupReq
• type BroadcastReply
• type BroadcastReq
• type Comet
  • func NewComet(cli zrpc.Client) Comet
• type DelGroupsReply
• type DelGroupsReq
• type Empty
• type JoinGroupsReply
• type JoinGroupsReq
• type LeaveGroupsReply
• type LeaveGroupsReq
• type Proto
• type PushMsgReply
• type PushMsgReq
• type SyncMsg

Types

type AuthMsg

type AuthMsg = comet.AuthMsg

type BroadcastGroupReply

type BroadcastGroupReply = comet.BroadcastGroupReply

type BroadcastGroupReq

type BroadcastGroupReq = comet.BroadcastGroupReq

type BroadcastReply

type BroadcastReply = comet.BroadcastReply

type BroadcastReq

type BroadcastReq = comet.BroadcastReq

type Comet

type Comet interface {
	PushMsg(ctx context.Context, in *PushMsgReq, opts ...grpc.CallOption) (*PushMsgReply, error)
	Broadcast(ctx context.Context, in *BroadcastReq, opts ...grpc.CallOption) (*BroadcastReply, error)
	BroadcastGroup(ctx context.Context, in *BroadcastGroupReq, opts ...grpc.CallOption) (*BroadcastGroupReply, 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)
}

func NewComet

func NewComet(cli zrpc.Client) Comet

type DelGroupsReply

type DelGroupsReply = comet.DelGroupsReply

type DelGroupsReq

type DelGroupsReq = comet.DelGroupsReq

type Empty

type Empty = comet.Empty

type JoinGroupsReply

type JoinGroupsReply = comet.JoinGroupsReply

type JoinGroupsReq

type JoinGroupsReq = comet.JoinGroupsReq

type LeaveGroupsReply

type LeaveGroupsReply = comet.LeaveGroupsReply

type LeaveGroupsReq

type LeaveGroupsReq = comet.LeaveGroupsReq

type Proto

type Proto = protocol.Proto

type PushMsgReply

type PushMsgReply = comet.PushMsgReply

type PushMsgReq

type PushMsgReq = comet.PushMsgReq

type SyncMsg

type SyncMsg = comet.SyncMsg