dao

Documentation

Index

• func PromError(name string)
• func PromInfo(name string)
• type Dao
  • func New(c *conf.Config) *Dao
  • func (d *Dao) Close()
  • func (d *Dao) Ping(c context.Context) (err error)
  • func (d *Dao) PubCallback(c context.Context, v []*pushmdl.Callback) (err error)
  • func (d *Dao) PubReport(c context.Context, info *pushmdl.Report) (err error)

Functions

func PromError

func PromError(name string)

PromError prom error

func PromInfo

func PromInfo(name string)

PromInfo add prom info

Types

type Dao

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

Dao .

func New

func New(c *conf.Config) *Dao

New creates a push-service DAO instance.

func (*Dao) Close

func (d *Dao) Close()

Close dao.

func (*Dao) Ping

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

Ping check connection status.

func (*Dao) PubCallback

func (d *Dao) PubCallback(c context.Context, v []*pushmdl.Callback) (err error)

PubCallback add push arrive/click callback to databus.

func (*Dao) PubReport

func (d *Dao) PubReport(c context.Context, info *pushmdl.Report) (err error)

PubReport add report to databus.