job

Documentation

Index

• Variables
• type Job
  • func NewJob(conf *conf.Config) *Job
  • func (b *Job) Close()
  • func (b *Job) Consume(msg *sarama.ConsumerMessage)
  • func (b *Job) CreateOrGetRoom(roomId string) *RoomJob
  • func (b *Job) DelRoom(roomId string)
  • func (b *Job) SendToAll(subId int32, speed int32, message []byte) (err error)
  • func (b *Job) SendToRoom(subId int32, roomId string, batchMessage []byte) (err error)
  • func (b *Job) SendToUser(subId int32, serverId string, tcpSessionIds []string, message []byte) (err error)
  • func (b *Job) Watch(conf *conf.Config)
• type RoomJob
  • func NewRoom(b *Job, roomId string) (r *RoomJob)
  • func (r *RoomJob) SendToCh(msg []byte) error

Variables

var (
	ErrRoomFull = errors.New("room proto chan full")
)

Types

type Job

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

Job 任务（消费KAFKA，执行指定行为）

func NewJob

func NewJob(conf *conf.Config) *Job

func (*Job) Close

func (b *Job) Close()

func (*Job) Consume

func (b *Job) Consume(msg *sarama.ConsumerMessage)

Consume messages, watch signals

func (*Job) CreateOrGetRoom

func (b *Job) CreateOrGetRoom(roomId string) *RoomJob

func (*Job) DelRoom

func (b *Job) DelRoom(roomId string)

func (*Job) SendToAll

func (b *Job) SendToAll(subId int32, speed int32, message []byte) (err error)

func (*Job) SendToRoom

func (b *Job) SendToRoom(subId int32, roomId string, batchMessage []byte) (err error)

func (*Job) SendToUser

func (b *Job) SendToUser(subId int32, serverId string, tcpSessionIds []string, message []byte) (err error)

func (*Job) Watch

func (b *Job) Watch(conf *conf.Config)

type RoomJob

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

RoomJob 房间任务

func NewRoom

func NewRoom(b *Job, roomId string) (r *RoomJob)

func (*RoomJob) SendToCh

func (r *RoomJob) SendToCh(msg []byte) error

SendToCh 向房间发送消息