invoker

Documentation

Index

• type CometInvoker
  • func NewCometInvoker(serverId, grpcAddr string, conf *conf.CometInvoker) (*CometInvoker, error)
  • func (c *CometInvoker) Close() (err error)
  • func (c *CometInvoker) Run(i int)
  • func (c *CometInvoker) SendToAll(arg *pb.SendToAllReq) (err error)
  • func (c *CometInvoker) SendToRoom(arg *pb.SendToRoomReq) (err error)
  • func (c *CometInvoker) SendToUsers(arg *pb.SendToUsersReq) (err error)

Types

type CometInvoker

type CometInvoker struct {
	Cancel context.CancelFunc

	RoutineNum uint64
	// contains filtered or unexported fields
}

CometInvoker 调用comet的服务

func NewCometInvoker

func NewCometInvoker(serverId, grpcAddr string, conf *conf.CometInvoker) (*CometInvoker, error)

func (*CometInvoker) Close

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

Close 关闭（暂时没有任何的调用地方） - 确保所有channel的内容消费完毕后，再继续往下走 - 如果超时时间内还没消费完，也继续往下走

func (*CometInvoker) Run

func (c *CometInvoker) Run(i int)

func (*CometInvoker) SendToAll

func (c *CometInvoker) SendToAll(arg *pb.SendToAllReq) (err error)

func (*CometInvoker) SendToRoom

func (c *CometInvoker) SendToRoom(arg *pb.SendToRoomReq) (err error)

func (*CometInvoker) SendToUsers

func (c *CometInvoker) SendToUsers(arg *pb.SendToUsersReq) (err error)