dao

Documentation

Index

• type Dao
  • func New(c *conf.Config) *Dao
  • func (d *Dao) AddMapping(c context.Context, mid int64, key, server string) (err error)
  • func (d *Dao) AddServerScore(c context.Context, server string) (err error)
  • func (d *Dao) BroadcastMsg(c context.Context, op, speed int32, platform string, msg []byte) (err error)
  • func (d *Dao) BroadcastRoomMsg(c context.Context, op int32, room string, msg []byte) (err error)
  • func (d *Dao) Close()
  • func (d *Dao) DecrServerScore(c context.Context, server string) (err error)
  • func (d *Dao) DelMapping(c context.Context, mid int64, key, server string) (has bool, err error)
  • func (d *Dao) DelServerScore(c context.Context, server string) (err error)
  • func (d *Dao) ExpireMapping(c context.Context, mid int64, key string) (has bool, err error)
  • func (d *Dao) GetAllRoomCount(c context.Context) (allroomCount map[string]int32, err error)
  • func (d *Dao) IncrServerScore(c context.Context, server string) (err error)
  • func (d *Dao) KeysByMids(c context.Context, mids []int64) (ress map[string]string, olMids []int64, err error)
  • func (d *Dao) Ping(c context.Context) error
  • func (d *Dao) PushMsg(c context.Context, op int32, server string, keys []string, msg []byte) (err error)
  • func (d *Dao) ServersByKeys(c context.Context, keys []string) (res []string, err error)
  • func (d *Dao) ServersRank(c context.Context, num int64) (list []string, err error)
  • func (d *Dao) UpdateRoomCount(c context.Context, server string, roomCount map[string]int32) (err error)

Types

type Dao

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

Dao dao.

func New

func New(c *conf.Config) *Dao

New new a dao and return.

func (*Dao) AddMapping

func (d *Dao) AddMapping(c context.Context, mid int64, key, server string) (err error)

AddMapping add a mapping. Mapping: mid:用户ID key:设备ID mid -> key_server 一个用户可同时登录多个设备 key -> server 一个用户设备对应一个server

func (*Dao) AddServerScore

func (d *Dao) AddServerScore(c context.Context, server string) (err error)

add server info

func (*Dao) BroadcastMsg

func (d *Dao) BroadcastMsg(c context.Context, op, speed int32, platform string, msg []byte) (err error)

BroadcastMsg push a message to databus.

func (*Dao) BroadcastRoomMsg

func (d *Dao) BroadcastRoomMsg(c context.Context, op int32, room string, msg []byte) (err error)

BroadcastRoomMsg push a message to databus.

func (*Dao) Close

func (d *Dao) Close()

Close close the resource.

func (*Dao) DecrServerScore

func (d *Dao) DecrServerScore(c context.Context, server string) (err error)

decr server score

func (*Dao) DelMapping

func (d *Dao) DelMapping(c context.Context, mid int64, key, server string) (has bool, err error)

DelMapping del a mapping.

func (*Dao) DelServerScore

func (d *Dao) DelServerScore(c context.Context, server string) (err error)

del server info

func (*Dao) ExpireMapping

func (d *Dao) ExpireMapping(c context.Context, mid int64, key string) (has bool, err error)

ExpireMapping expire a mapping.

func (*Dao) GetAllRoomCount

func (d *Dao) GetAllRoomCount(c context.Context) (allroomCount map[string]int32, err error)

func (*Dao) IncrServerScore

func (d *Dao) IncrServerScore(c context.Context, server string) (err error)

incr server score

func (*Dao) KeysByMids

func (d *Dao) KeysByMids(c context.Context, mids []int64) (ress map[string]string, olMids []int64, err error)

KeysByMids get a key server by mid.

func (*Dao) Ping

func (d *Dao) Ping(c context.Context) error

Ping dao ping.

func (*Dao) PushMsg

func (d *Dao) PushMsg(c context.Context, op int32, server string, keys []string, msg []byte) (err error)

PushMsg push a message to databus.

func (*Dao) ServersByKeys

func (d *Dao) ServersByKeys(c context.Context, keys []string) (res []string, err error)

ServersByKeys get a server by key.

func (*Dao) ServersRank

func (d *Dao) ServersRank(c context.Context, num int64) (list []string, err error)

get server list top

func (*Dao) UpdateRoomCount

func (d *Dao) UpdateRoomCount(c context.Context, server string, roomCount map[string]int32) (err error)