job

Documentation

Index

• type Comet
  • func NewComet(c *conf.Comet, addr string) *Comet
  • func (c *Comet) Broadcast(arg *pb.BroadcastReq) (err error)
  • func (c *Comet) BroadcastRoom(arg *pb.BroadcastRoomReq) (err error)
  • func (c *Comet) Close()
  • func (c *Comet) GetRooms() map[string]bool
  • func (c *Comet) Push(arg *pb.PushMsgReq) (err error)
• type Comets
  • func InitComets(c *conf.Comet) *Comets
  • func (this *Comets) Broadcast(args *pb.BroadcastReq)
  • func (this *Comets) BroadcastRoom(roomId string, args *pb.BroadcastRoomReq)
  • func (this *Comets) Close()
  • func (this *Comets) MergeRoomServers()
  • func (this *Comets) Push(serverId string, args *pb.PushMsgReq)
  • func (this *Comets) SyncComets(c *conf.Comet)
  • func (this *Comets) SyncRoomServers()
• type Job
  • func New(c *conf.Config) *Job
  • func (j *Job) Close()
  • func (j *Job) Consume()

Types

type Comet

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

Comet is a comet.

func NewComet

func NewComet(c *conf.Comet, addr string) *Comet

NewComet new a comet.

func (*Comet) Broadcast

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

Broadcast broadcast a message.

func (*Comet) BroadcastRoom

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

BroadcastRoom broadcast a room message.

func (*Comet) Close

func (c *Comet) Close()

Close close the resouces.

func (*Comet) GetRooms

func (c *Comet) GetRooms() map[string]bool

func (*Comet) Push

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

Push push a user message.

type Comets

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

func InitComets

func InitComets(c *conf.Comet) *Comets

func (*Comets) Broadcast

func (this *Comets) Broadcast(args *pb.BroadcastReq)

broadcast a message to all

func (*Comets) BroadcastRoom

func (this *Comets) BroadcastRoom(roomId string, args *pb.BroadcastRoomReq)

broadcast aggregation messages to room

func (*Comets) Close

func (this *Comets) Close()

func (*Comets) MergeRoomServers

func (this *Comets) MergeRoomServers()

func (*Comets) Push

func (this *Comets) Push(serverId string, args *pb.PushMsgReq)

push a message to a batch of subkeys

func (*Comets) SyncComets

func (this *Comets) SyncComets(c *conf.Comet)

func (*Comets) SyncRoomServers

func (this *Comets) SyncRoomServers()

type Job

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

Job is push job.

func New

func New(c *conf.Config) *Job

New new a push job.

func (*Job) Close

func (j *Job) Close()

Close close resounces.

func (*Job) Consume

func (j *Job) Consume()

Consume messages, watch signals