Documentation
¶
Index ¶
- Variables
- type 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
Constants ¶
This section is empty.
Variables ¶
View Source
var (
ErrRoomFull = errors.New("room proto chan full")
)
Functions ¶
This section is empty.
Types ¶
type Job ¶
type Job struct {
// contains filtered or unexported fields
}
Job 任务（消费KAFKA，执行指定行为）
func (*Job) Consume ¶
func (b *Job) Consume(msg *sarama.ConsumerMessage)
Consume messages, watch signals
func (*Job) CreateOrGetRoom ¶
func (*Job) SendToRoom ¶
func (*Job) SendToUser ¶
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.