openbilibili/app/job/main/web-goblin/dao/web/dao.go

package web

import (
	"context"

	"go-common/app/job/main/web-goblin/conf"
	"go-common/library/database/elastic"
	"go-common/library/log"
	bm "go-common/library/net/http/blademaster"
	"go-common/library/stat/prom"
)

const _broadURL = "/x/internal/broadcast/push/all"

// Dao dao
type Dao struct {
	c *conf.Config
	// http client
	http *bm.Client
	// broadcast URL
	broadcastURL string
	ela          *elastic.Elastic
}

// New init mysql db
func New(c *conf.Config) (dao *Dao) {
	dao = &Dao{
		c:            c,
		http:         bm.NewClient(c.HTTPClient),
		broadcastURL: c.Host.API + _broadURL,
		ela:          elastic.NewElastic(nil),
	}
	return
}

// Close close the resource.
func (d *Dao) Close() {
}

// Ping dao ping
func (d *Dao) Ping(c context.Context) error {
	return nil
}

// PromError stat and log.
func PromError(name string, format string, args ...interface{}) {
	prom.BusinessErrCount.Incr(name)
	log.Error(format, args...)
}