grpc_client

Documentation

Index

• type Comet
  • func NewComet(in *naming.Instance, c *conf.Comet) (*Comet, error)
  • func (c *Comet) Broadcast(arg *comet.BroadcastReq) (err error)
  • func (c *Comet) BroadcastRoom(arg *comet.BroadcastRoomReq) (err error)
  • func (c *Comet) Close() (err error)
  • func (c *Comet) Push(arg *comet.PushMsgReq) (err error)

Types

type Comet

type Comet struct {
	Ctx    context.Context
	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

Comet is a comet.

func NewComet

func NewComet(in *naming.Instance, c *conf.Comet) (*Comet, error)

NewComet new a comet.

func (*Comet) Broadcast

func (c *Comet) Broadcast(arg *comet.BroadcastReq) (err error)

Broadcast broadcast a message.

func (*Comet) BroadcastRoom

func (c *Comet) BroadcastRoom(arg *comet.BroadcastRoomReq) (err error)

BroadcastRoom broadcast a room message.

func (*Comet) Close

func (c *Comet) Close() (err error)

Close close the resouces.

func (*Comet) Push

func (c *Comet) Push(arg *comet.PushMsgReq) (err error)

Push push a user message.