dao

package
v0.0.0-...-83adff0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PromError 

func PromError(name, format string, args ...interface{})

PromError prometheus error count.

Types

type BulkItem 

type BulkItem interface {
	IndexName() string
	IndexType() string
	IndexID() string
}

BulkItem .

type BulkMapItem 

type BulkMapItem interface {
	IndexName() string
	IndexType() string
	IndexID() string
	PField() map[string]interface{}
}

BulkMapItem .

type Dao 

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

Dao .

func New 

func New(c *conf.Config) (d *Dao)

New init dao

func (*Dao) AddApp 

func (d *Dao) AddApp(ctx context.Context, a *model.MngApp) (id int64, err error)

AddApp .

func (*Dao) AddAsset 

func (d *Dao) AddAsset(ctx context.Context, b *model.MngAsset) (id int64, err error)

AddAsset .

func (*Dao) AddBusiness 

func (d *Dao) AddBusiness(ctx context.Context, b *model.MngBusiness) (id int64, err error)

AddBusiness .

func (*Dao) AppInfo 

func (d *Dao) AppInfo(ctx context.Context, id int64) (a *model.MngApp, err error)

AppInfo .

func (*Dao) AppInfoByAppid 

func (d *Dao) AppInfoByAppid(ctx context.Context, appid string) (a *model.MngApp, err error)

AppInfoByAppid .

func (*Dao) AppList 

func (d *Dao) AppList(ctx context.Context, business string) (list []*model.MngApp, err error)

AppList .

func (*Dao) ArchiveCheck 

func (d *Dao) ArchiveCheck(c context.Context, p *model.ArchiveCheckParams) (res *model.SearchResult, err error)

ArchiveCheck search archive check from ES.

func (*Dao) ArchiveCommerce 

func (d *Dao) ArchiveCommerce(c context.Context, p *model.ArchiveCommerce) (res *model.SearchResult, err error)

ArchiveCommerce .

func (*Dao) ArchiveCommercePTypeIds 

func (d *Dao) ArchiveCommercePTypeIds(c context.Context, query *elastic.BoolQuery) (res *model.SearchResult, err error)

ArchiveCommercePTypeIds .

func (*Dao) ArchiveScore 

func (d *Dao) ArchiveScore(c context.Context, sp *model.QueryParams) (res *model.QueryResult, debug *model.QueryDebugResult, err error)

ArchiveScore 稿件二审打分排序.

func (*Dao) ArchiveVideoScore 

func (d *Dao) ArchiveVideoScore(c context.Context, sp *model.QueryParams) (res *model.QueryResult, debug *model.QueryDebugResult, err error)

ArchiveVideoScore 稿件一审打分排序.

func (*Dao) Asset 

func (d *Dao) Asset(c context.Context, name string) (r *model.GFAsset, err error)

Asset .

func (*Dao) AssetAll 

func (d *Dao) AssetAll(ctx context.Context) (list []*model.MngAsset, err error)

AssetAll .

func (*Dao) AssetDBIns 

func (d *Dao) AssetDBIns(c context.Context, name, description, dsn string) (rows int64, err error)

AssetDBIns insert db asset.

func (*Dao) AssetDBTables 

func (d *Dao) AssetDBTables(c context.Context) (list []*model.GFAsset, err error)

AssetDBTables .

func (*Dao) AssetInfo 

func (d *Dao) AssetInfo(ctx context.Context, id int64) (info *model.MngAsset, err error)

AssetInfo .

func (*Dao) AssetInfoByName 

func (d *Dao) AssetInfoByName(ctx context.Context, name string) (info *model.MngAsset, err error)

AssetInfoByName .

func (*Dao) AssetList 

func (d *Dao) AssetList(ctx context.Context, typ int, name string, offset, limit int) (list []*model.MngAsset, err error)

AssetList .

func (*Dao) AssetTableIns 

func (d *Dao) AssetTableIns(c context.Context, name, db, regex, fields, description string) (rows int64, err error)

AssetTableIns insert table asset.

func (*Dao) AssetTotal 

func (d *Dao) AssetTotal(ctx context.Context, typ int, name string) (total int64, err error)

AssetTotal .

func (*Dao) BulkIndex 

func (d *Dao) BulkIndex(c context.Context, esName string, bulkData []BulkItem) (err error)

BulkIndex .

func (*Dao) BusinessAll 

func (d *Dao) BusinessAll(ctx context.Context) (list []*model.MngBusiness, err error)

BusinessAll .

func (*Dao) BusinessAllV2 

func (d *Dao) BusinessAllV2(c context.Context) (list []*model.GFBusiness, err error)

BusinessAllV2 .

func (*Dao) BusinessInfo 

func (d *Dao) BusinessInfo(ctx context.Context, id int64) (info *model.MngBusiness, err error)

BusinessInfo .

func (*Dao) BusinessInfoByName 

func (d *Dao) BusinessInfoByName(ctx context.Context, name string) (info *model.MngBusiness, err error)

BusinessInfoByName .

func (*Dao) BusinessInfoV2 

func (d *Dao) BusinessInfoV2(c context.Context, name string) (b *model.GFBusiness, err error)

BusinessInfoV2 .

func (*Dao) BusinessIns 

func (d *Dao) BusinessIns(c context.Context, pid int64, name, description string) (rows int64, err error)

BusinessIns insert business.

func (*Dao) BusinessList 

func (d *Dao) BusinessList(ctx context.Context, name string, offset, limit int) (list []*model.MngBusiness, err error)

BusinessList .

func (*Dao) BusinessTotal 

func (d *Dao) BusinessTotal(ctx context.Context, name string) (total int64, err error)

BusinessTotal .

func (*Dao) BusinessUpdate 

func (d *Dao) BusinessUpdate(c context.Context, name, field, value string) (rows int64, err error)

BusinessUpdate update business.

func (*Dao) CreativeArchiveApply 

func (d *Dao) CreativeArchiveApply(c context.Context, sp *model.QueryParams) (res *model.QueryResult, debug *model.QueryDebugResult, err error)

CreativeArchiveStaff 创作中心

func (*Dao) CreativeArchiveSearch 

func (d *Dao) CreativeArchiveSearch(c context.Context, sp *model.QueryParams) (res *model.QueryResult, debug *model.QueryDebugResult, err error)

CreativeArchiveSearch 创作中心

func (*Dao) CreativeArchiveStaff 

func (d *Dao) CreativeArchiveStaff(c context.Context, sp *model.QueryParams) (res *model.QueryResult, debug *model.QueryDebugResult, err error)

CreativeArchiveStaff 创作中心

func (*Dao) EsportsContestsDate 

func (d *Dao) EsportsContestsDate(c context.Context, sp *model.QueryParams) (res *model.QueryResult, debug *model.QueryDebugResult, err error)

EsportsContestsDate 电竞右侧日历联动.

func (*Dao) ExistIndex 

func (d *Dao) ExistIndex(c context.Context, esClusterName, indexName string) (exist bool, err error)

ExistIndex .

func (*Dao) GetLogInfo 

func (d *Dao) GetLogInfo(appID string, id int) (business *model.Business, ok bool)

GetLogInfo .

func (*Dao) IP 

func (d *Dao) IP(c context.Context, ip []string) (res *model.IPData, err error)

IP .

func (*Dao) LogAudit 

func (d *Dao) LogAudit(c context.Context, pr map[string][]interface{}, sp *model.LogParams, business *model.Business) (res *model.SearchResult, err error)

LogAudit .

func (*Dao) LogAuditDelete 

func (d *Dao) LogAuditDelete(c context.Context, pr map[string][]interface{}, sp *model.LogParams, business *model.Business) (res *model.SearchResult, err error)

LogAuditDelete .

func (*Dao) LogAuditGroupBy 

func (d *Dao) LogAuditGroupBy(c context.Context, pr map[string][]interface{}, sp *model.LogParams, business *model.Business) (res *model.SearchResult, err error)

LogAuditGroupBy .

func (*Dao) LogCount 

func (d *Dao) LogCount(c context.Context, name string, business int, uid interface{})

LogCount .

func (*Dao) LogUserAction 

func (d *Dao) LogUserAction(c context.Context, pr map[string][]interface{}, sp *model.LogParams, business *model.Business) (res *model.SearchResult, err error)

LogUserAction .

func (*Dao) LogUserActionDelete 

func (d *Dao) LogUserActionDelete(c context.Context, pr map[string][]interface{}, sp *model.LogParams, business *model.Business) (res *model.SearchResult, err error)

LogUserActionDelete .

func (*Dao) MngCount 

func (d *Dao) MngCount(ctx context.Context, c *model.MngCount) (list []*model.MngCountRes, err error)

MngCount .

func (*Dao) MngPercent 

func (d *Dao) MngPercent(ctx context.Context, c *model.MngCount) (list []*model.MngPercentRes, err error)

MngPercent .

func (*Dao) NewLog 

func (d *Dao) NewLog() (err error)

NewLog .

func (*Dao) NewLogProcess 

func (d *Dao) NewLogProcess()

func (*Dao) Ping 

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

Ping health

func (*Dao) QueryBasic 

func (d *Dao) QueryBasic(c context.Context, sp *model.QueryParams) (mixedQuery *elastic.BoolQuery, qbDebug *model.QueryDebugResult)

QueryBasic 其中boolQuery方便定制化业务传参过来.

func (*Dao) QueryConf 

func (d *Dao) QueryConf(ctx context.Context) (res map[string]*model.QueryConfDetail, err error)

QueryConf query conf

func (*Dao) QueryResult 

func (d *Dao) QueryResult(c context.Context, query elastic.Query, sp *model.QueryParams, qbDebug *model.QueryDebugResult) (res *model.QueryResult, qrDebug *model.QueryDebugResult, err error)

QueryResult query result from ES.

func (*Dao) Scroll 

func (d *Dao) Scroll(c context.Context, sp *model.QueryParams) (res *model.QueryResult, debug *model.QueryDebugResult, err error)

func (*Dao) TaskQa 

func (d *Dao) TaskQa(c context.Context, p *model.TaskQa) (res *model.SearchResult, err error)

TaskQa .

func (*Dao) TaskQaRandom 

func (d *Dao) TaskQaRandom(c context.Context, sp *model.QueryParams) (res *model.QueryResult, debug *model.QueryDebugResult, err error)

TaskQaRandom .

func (*Dao) UDepTs 

func (d *Dao) UDepTs(c context.Context, uids []string) (res *model.UDepTsData, err error)

UDepTs .

func (*Dao) Unames 

func (d *Dao) Unames(c context.Context, uids []string) (res *model.UnamesData, err error)

Unames .

func (*Dao) UpdateApp 

func (d *Dao) UpdateApp(ctx context.Context, a *model.MngApp) (err error)

UpdateApp .

func (*Dao) UpdateAppAssetDatabus 

func (d *Dao) UpdateAppAssetDatabus(ctx context.Context, name string, v *model.MngAssetDatabus) (err error)

UpdateAppAssetDatabus .

func (*Dao) UpdateAppAssetTable 

func (d *Dao) UpdateAppAssetTable(ctx context.Context, name string, t *model.MngAssetTable) (err error)

UpdateAppAssetTable .

func (*Dao) UpdateAsset 

func (d *Dao) UpdateAsset(ctx context.Context, b *model.MngAsset) (err error)

UpdateAsset .

func (*Dao) UpdateAssetTable 

func (d *Dao) UpdateAssetTable(c context.Context, name, fields string) (rows int64, err error)

UpdateAssetTable update table asset.

func (*Dao) UpdateBulk 

func (d *Dao) UpdateBulk(c context.Context, esName string, bulkData []BulkItem) (err error)

UpdateBulk (Deprecated).

func (*Dao) UpdateBusiness 

func (d *Dao) UpdateBusiness(ctx context.Context, b *model.MngBusiness) (err error)

UpdateBusiness .

func (*Dao) UpdateMapBulk 

func (d *Dao) UpdateMapBulk(c context.Context, esName string, bulkData []BulkMapItem) (err error)

UpdateMapBulk (Deprecated).

func (*Dao) UpsertBulk 

func (d *Dao) UpsertBulk(c context.Context, esCluster string, up *model.UpsertParams) (err error)

UpsertBulk 为了替换UpdateMapBulk和UpdateBulk .

func (*Dao) Video 

func (d *Dao) Video(c context.Context, p *model.VideoParams) (res *model.SearchResult, err error)

Video search video from ES (deprecated).

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.