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) AddServerOnline(c context.Context, server string, online *model.Online) (err error)
  • func (d *Dao) BroadcastMsg(c context.Context, op, speed int32, msg []byte) (err error)
  • func (d *Dao) BroadcastRoomMsg(c context.Context, op int32, room string, msg []byte) (err error)
  • func (d *Dao) Close() error
  • func (d *Dao) DelMapping(c context.Context, mid int64, key, server string) (has bool, err error)
  • func (d *Dao) DelServerOnline(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) 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) ServerOnline(c context.Context, server string) (online *model.Online, err error)
  • func (d *Dao) ServersByKeys(c context.Context, keys []string) (res []string, 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 -> key_server
key -> server

func (*Dao) AddServerOnline

func (d *Dao) AddServerOnline(c context.Context, server string, online *model.Online) (err error)

AddServerOnline add a server online.

func (*Dao) BroadcastMsg

func (d *Dao) BroadcastMsg(c context.Context, op, speed int32, 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() error

Close close the resource.

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) DelServerOnline

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

DelServerOnline del a server online.

func (*Dao) ExpireMapping

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

ExpireMapping expire a mapping.

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) ServerOnline

func (d *Dao) ServerOnline(c context.Context, server string) (online *model.Online, err error)

ServerOnline get a server online.

func (*Dao) ServersByKeys

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

ServersByKeys get a server by key.