dao

package

v0.0.3 Latest Latest Go to latest Published: Aug 18, 2022 License: MIT Imports: 14 Imported by: 0

Details

View Source

const (
	MidFmt = "%s:%v" // {appId}:{uid}

)

This section is empty.

This section is empty.

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

Dao dao.

func New(c *conf.Config) *Dao

New new a dao and return.

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

func (d *Dao) Close() error

Close close the resource.

func (d *Dao) DecGroupServer(c context.Context, appId, key, server string, gid []string) (err error)

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

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

ExpireMapping expire a mapping.

func (d *Dao) GetMember(c context.Context, key string) (appId string, mid string, err error)

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

func (d *Dao) IncGroupServer(c context.Context, appId, key, server string, gid []string) (err error)

groups

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

KeysByMids get a key server by mid.

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

Ping dao ping.

func (d *Dao) PublishMsg(ctx context.Context, appId string, fromId string, op comet.Op, key string, msg []byte) (err error)

PushMsg push a message to databus.

func (d *Dao) ServersByGid(c context.Context, appId string, gid string) (res []string, err error)

KeysByMids get a key server by mid.

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

ServersByKeys get a server by key.