esdto

package
v1.0.1-rel-02 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 2024 License: AFL-3.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AGGS_STATE_FIELDS = `  "aggs": {
  		{{.AggsFields}}    
   }`
	AGGS_STATE_FIELD = `  "{{.Field}}": {
        "stats": {
            "field": "{{.Field}}"
        }
    }`

	ORDER_TEMPLATE = `
		"sort": [
		  {
			  {{.SortFields}}   
		  }  
		]
		`

	HTTP_SOURCE_TEMPLATE = `
		"_source": [{{.SourceFields}}]
		`
	HTTP_HIGHLIGHT_TEMPLATE = `"highlight":{{.Highlight}}`
)
View Source 
const BodyQueryTemplate = `{
	  "query":{{.QueryBody}}, 	
       {{.HttpQueryParams}}	
	  "size":{{.Size}},
	  "from":{{.From}}	
	}`
View Source 
const C_StatFieldName = "stats"
View Source 
const HttpCliMax = esconst.MAX_ES_RECORD_NUMBER

Variables

This section is empty.

Functions

func InjectEsAggResult 

func InjectEsAggResult(s *EsAggResult)

func InjectEsHighlight 

func InjectEsHighlight(s *EsHighlight)

func InjectEsRequest 

func InjectEsRequest(s *EsRequest)

func InjectGetResultDto 

func InjectGetResultDto(s *GetResultDto)

func InjectHttpQueryBody 

func InjectHttpQueryBody(s *HttpQueryBody)

func InjectHttpQueryParams 

func InjectHttpQueryParams(s *HttpQueryParams)

func InjectQueryGroup 

func InjectQueryGroup(s *QueryGroup)

func InjectQueryList 

func InjectQueryList(s *QueryList)

func LoadEsAggResult 

func LoadEsAggResult() baseiface.ISingleton

func LoadEsHighlight 

func LoadEsHighlight() baseiface.ISingleton

func LoadEsRequest 

func LoadEsRequest() baseiface.ISingleton

func LoadGetResultDto 

func LoadGetResultDto() baseiface.ISingleton

func LoadHttpQueryBody 

func LoadHttpQueryBody() baseiface.ISingleton

func LoadHttpQueryParams 

func LoadHttpQueryParams() baseiface.ISingleton

func LoadQueryGroup 

func LoadQueryGroup() baseiface.ISingleton

func LoadQueryList 

func LoadQueryList() baseiface.ISingleton

Types

type AggType 

type AggType int
const (
	AggType_AggStats AggType = iota + 100

	AggType_AggCount
	AggType_AggMax
	AggType_AggMin
	AggType_AggSum

	AggType_AggAvg

	AggType_Stats

	AggType_Count
	AggType_Max
	AggType_Min
	AggType_Sum

	AggType_Avg
)

func (AggType) IfAggAvg 

func (self AggType) IfAggAvg() bool

func (AggType) IfAggCount 

func (self AggType) IfAggCount() bool

func (AggType) IfAggMax 

func (self AggType) IfAggMax() bool

func (AggType) IfAggMin 

func (self AggType) IfAggMin() bool

func (AggType) IfAggStats 

func (self AggType) IfAggStats() bool

func (AggType) IfAggSum 

func (self AggType) IfAggSum() bool

func (AggType) String 

func (self AggType) String() string

type EsAggDto 

type EsAggDto struct {
	AggType AggType `json:"agg_type"`

	AggName    string          `json:"agg_name"`
	AggField   string          `json:"agg_field"`
	StatField  string          `json:"stat_field"`
	AggOrderBy *dto.OrderByDto `json:"agg_order_by"`
	Size       int             `json:"size"`
	UseKey     bool            `json:"use_key"`
}

func NewEsAggDto 

func NewEsAggDto() *EsAggDto

func (*EsAggDto) IfAggSub 

func (this *EsAggDto) IfAggSub() bool

func (*EsAggDto) IfStatFields 

func (this *EsAggDto) IfStatFields() bool

func (*EsAggDto) StatFieldName 

func (this *EsAggDto) StatFieldName(statF string) string

type EsAggResult 

type EsAggResult struct {
	basedto.BaseEntity

	AggType   AggType `json:"agg_type"`
	Key       string  `json:"key"`           //"key": "722827384120016897",
	DocCount  int64   `json:"doc_count"`     //": 82,
	StatField string  `json:"stat_field"`    //"shop_account_id": {
	Count     int     `json:"count"`         //"count": 3,
	Min       any     `json:"min,omitempty"` //: 0.0,
	Max       any     `json:"max,omitempty"` //": 7.2344678761876685E17,
	Avg       any     `json:"avg,omitempty"` //": 2.41148929206255616E17,
	Sum       any     `json:"sum,omitempty"` //": 7.2344678761876685E17

	Value any `json:"value,omitempty"`
	Data  any `json:"data,omitempty"`

	EsAggResultMap map[string]*EsAggResult `json:"agg_map,omitempty"`
}

func FindBeanEsAggResult 

func FindBeanEsAggResult() *EsAggResult

FindBeanEsAggResult

func NewEsAggResult 

func NewEsAggResult() *EsAggResult

func (*EsAggResult) FromStatsResult 

func (self *EsAggResult) FromStatsResult(stats StatsResult) *EsAggResult

func (*EsAggResult) ToAgg2Result 

func (self *EsAggResult) ToAgg2Result(aggdto *EsAggDto, aggs elastic.Aggregations) *EsAggResult

func (*EsAggResult) ToAgg2ResultMap 

func (self *EsAggResult) ToAgg2ResultMap(aggdto *EsAggDto, aggs elastic.Aggregations) *EsAggResult

func (*EsAggResult) ToAgg2ResultOne 

func (self *EsAggResult) ToAgg2ResultOne(aggdto *EsAggDto, aggs elastic.Aggregations) *EsAggResult

func (*EsAggResult) Value2Stats 

func (self *EsAggResult) Value2Stats()

type EsHighlight 

type EsHighlight struct {
	basedto.BaseEntity
	*elastic.Highlight `json:"-"`
	Src                map[string]any `json:"src"`
}

func FindBeanEsHighlight 

func FindBeanEsHighlight() *EsHighlight

FindBeanEsHighlight

func NewEsHighlight 

func NewEsHighlight() *EsHighlight

func (*EsHighlight) FromMap 

func (self *EsHighlight) FromMap()

ToMap

func (*EsHighlight) FromSource 

func (self *EsHighlight) FromSource() error

func (*EsHighlight) Get 

func (self *EsHighlight) Get(key string) any

func (*EsHighlight) GetMapItem 

func (self *EsHighlight) GetMapItem(key string, v reflect.Value)

func (*EsHighlight) IfHighlight 

func (self *EsHighlight) IfHighlight() bool

func (*EsHighlight) Init 

func (self *EsHighlight) Init() *EsHighlight

func (*EsHighlight) Put 

func (self *EsHighlight) Put(key string, v any)

func (*EsHighlight) PutMapItem 

func (self *EsHighlight) PutMapItem(key string, v reflect.Value)

func (*EsHighlight) ToMap 

func (self *EsHighlight) ToMap()

func (*EsHighlight) ToSource 

func (self *EsHighlight) ToSource() (any, error)

type EsRequest 

type EsRequest struct {
	basedto.BaseEntity
	RootDir     string                      `json:"-"`
	EsClient    *ichubelastic.ElasticClient `json:"-"`
	CmdCategory esconst.CMDTYPE             `json:"cmd_category"`

	*ReqDto
	// contains filtered or unexported fields
}

func FindBeanEsRequest 

func FindBeanEsRequest() *EsRequest

FindBeanEsRequest

func NewEsRequest 

func NewEsRequest() *EsRequest

func (*EsRequest) Check 

func (this *EsRequest) Check() error

func (*EsRequest) Client 

func (this *EsRequest) Client() *elastic.Client

func (*EsRequest) FindAnyName 

func (this *EsRequest) FindAnyName(data interface{}) string

func (*EsRequest) FullPath 

func (this *EsRequest) FullPath(data interface{}) string

func (*EsRequest) Parse2IndexName 

func (this *EsRequest) Parse2IndexName(data baseiface.IbaseProxy)

func (*EsRequest) Pretty 

func (this *EsRequest) Pretty() bool

func (*EsRequest) Save2File 

func (this *EsRequest) Save2File(datas ...baseiface.IbaseProxy)

func (*EsRequest) Save2FileBytes 

func (this *EsRequest) Save2FileBytes(file string, proxy baseiface.IbaseProxy) error

func (*EsRequest) SaveFile 

func (this *EsRequest) SaveFile()

func (*EsRequest) SetPretty 

func (this *EsRequest) SetPretty(pretty bool)

type EsStats 

type EsStats struct {
	//stats one filed
	Stats StatsResult `json:"stats,omitempty"`
	//stats multi fields
	StatsMap map[string]StatsResult `json:"stats_map,omitempty"`
}

func NewEsStats 

func NewEsStats() *EsStats

func (*EsStats) Value2Stats 

func (self *EsStats) Value2Stats(aggs elastic.Aggregations) *EsStats

func (*EsStats) Value2StatsMap 

func (self *EsStats) Value2StatsMap(aggs elastic.Aggregations) *EsStats

type GetResultDto 

type GetResultDto struct {
	basedto.BaseEntity

	Index       string      `json:"_index"`
	Type        string      `json:"_type"`
	Id          string      `json:"_id"`
	Uid         string      `json:"_uid"`
	Routing     string      `json:"_routing"`
	Parent      string      `json:"_parent"`
	Version     int         `json:"_version"`
	SeqNo       int         `json:"_seq_no"`
	PrimaryTerm int         `json:"_primary_term"`
	Source      interface{} `json:"_source"`
	Found       bool        `json:"found"`
}

func FindBeanGetResultDto 

func FindBeanGetResultDto() *GetResultDto

FindBeanGetResultDto

func NewGetResultDto 

func NewGetResultDto() *GetResultDto

func (*GetResultDto) As 

func (this *GetResultDto) As(out interface{}) *GetResultDto

type HttpQueryBody 

type HttpQueryBody struct {
	basedto.BaseEntity
	HttpcliBody     string           `json:"httpcli_body,omitempty"`
	HttpurlParams   map[string]any   `json:"httpurl_params,omitempty"`
	HttpQueryParams *HttpQueryParams `json:"http_query_params,omitempty"`
}

func DefaultHttpQueryBody 

func DefaultHttpQueryBody() *HttpQueryBody

func FindBeanHttpQueryBody 

func FindBeanHttpQueryBody() *HttpQueryBody

FindBeanHttpQueryBody

func NewHttpQueryBody 

func NewHttpQueryBody() *HttpQueryBody

func (*HttpQueryBody) Aggregations 

func (self *HttpQueryBody) Aggregations(agg string, aggcase elastic.Aggregation)

func (*HttpQueryBody) Correct 

func (self *HttpQueryBody) Correct()

func (*HttpQueryBody) MakeBody 

func (self *HttpQueryBody) MakeBody(limit, start int) string

type HttpQueryParams 

type HttpQueryParams struct {
	basedto.BaseEntity
	EsAggDtos          []*EsAggDto
	HttpQuerySorts     []*HttpQuerySort
	HttpSourceFields   string `json:"http_source_fields"`
	OrderTemplate      string
	SearchType         string
	RestTotalHitsAsInt string

	AggScripts         string `json:"agg_scripts"`
	HighlightScripts   string `json:"highlight_scripts"`
	*elastic.Highlight `json:"-"`
	// contains filtered or unexported fields
}

func DefaultHHttpQueryParams 

func DefaultHHttpQueryParams() *HttpQueryParams

func FindBeanHttpQueryParams 

func FindBeanHttpQueryParams() *HttpQueryParams

FindBeanHttpQueryParams

func (*HttpQueryParams) Aggregations 

func (self *HttpQueryParams) Aggregations(aggName string, aggcase elastic.Aggregation)

func (*HttpQueryParams) Append 

func (self *HttpQueryParams) Append(field string, asc bool)

func (*HttpQueryParams) BuildJson 

func (self *HttpQueryParams) BuildJson() string

func (*HttpQueryParams) IfAggs 

func (self *HttpQueryParams) IfAggs() bool

func (*HttpQueryParams) IfEsAggs 

func (self *HttpQueryParams) IfEsAggs() bool

func (*HttpQueryParams) IfHighlight 

func (self *HttpQueryParams) IfHighlight() bool

func (*HttpQueryParams) IfHighlightFrom 

func (self *HttpQueryParams) IfHighlightFrom(hl *elastic.Highlight) bool

func (*HttpQueryParams) QuatedStr 

func (self *HttpQueryParams) QuatedStr(ins []string) string

func (*HttpQueryParams) ToEsAggs 

func (self *HttpQueryParams) ToEsAggs() string

func (*HttpQueryParams) ToHighlight 

func (self *HttpQueryParams) ToHighlight() string

func (*HttpQueryParams) ToOrderBy 

func (self *HttpQueryParams) ToOrderBy() string

func (*HttpQueryParams) ToSourceFields 

func (self *HttpQueryParams) ToSourceFields() string

type HttpQuerySort 

type HttpQuerySort struct {
	Field   string
	Ascdesc string
}

func NewHttpQuerySort 

func NewHttpQuerySort() *HttpQuerySort

func (*HttpQuerySort) ToOrderJson 

func (self *HttpQuerySort) ToOrderJson() string

type QueryGroup 

type QueryGroup struct {
	basedto.BaseEntity
	EsBoolType int
	Queries    []*elastic.Query
}

func FindBeanQueryGroup 

func FindBeanQueryGroup() *QueryGroup

FindBeanQueryGroup

func NewQueryGroup 

func NewQueryGroup() *QueryGroup

func (*QueryGroup) AddQuery 

func (this *QueryGroup) AddQuery(query *elastic.Query)

type QueryList 

type QueryList struct {
	basedto.BaseEntity
	// contains filtered or unexported fields
}

func FindBeanQueryList 

func FindBeanQueryList() *QueryList

FindBeanQueryList

func NewQueryList 

func NewQueryList() *QueryList

func (*QueryList) Append 

func (this *QueryList) Append(query elastic.Query)

func (*QueryList) AppendFields 

func (this *QueryList) AppendFields(page *page.PageRequest) []elastic.Query

type RawQueryDto 

type RawQueryDto struct {
	Query struct {
	} `json:"query"`
}

type ReqDto 

type ReqDto struct {
	CmdType    esconst.CMDTYPE `json:"cmd_type"`
	Source     string          `json:"source"`
	IndexName  string          `json:"index_name"`
	IndexAlias string          `json:"index_alias"`

	Id  string   `json:"id,omitempty"`
	Ids []string `json:"ids,omitempty"`

	Timeout int `json:"timeout"`
	*HttpQueryBody
	// contains filtered or unexported fields
}

func NewReqDto 

func NewReqDto() *ReqDto

func (*ReqDto) Check 

func (self *ReqDto) Check() error

func (*ReqDto) IndexTable 

func (self *ReqDto) IndexTable() baseindex.IndexTable

func (*ReqDto) SetCmdType 

func (self *ReqDto) SetCmdType(CmdType esconst.CMDTYPE) *ReqDto

func (*ReqDto) SetHttpcliBody 

func (self *ReqDto) SetHttpcliBody(HttpcliBody string) *ReqDto

func (*ReqDto) SetHttpurlParams 

func (self *ReqDto) SetHttpurlParams(HttpurlParams map[string]any) *ReqDto

func (*ReqDto) SetIndexName 

func (self *ReqDto) SetIndexName(IndexName string) *ReqDto

func (*ReqDto) SetIndexTable 

func (self *ReqDto) SetIndexTable(index baseindex.IndexTable)

func (*ReqDto) SetSource 

func (self *ReqDto) SetSource(Source string) *ReqDto

func (*ReqDto) Table2IndexName 

func (self *ReqDto) Table2IndexName(tablename string) string

type StatsResult 

type StatsResult struct {
	Count int     `json:"count"`
	Min   float64 `json:"min"`
	Max   float64 `json:"max"`
	Avg   float64 `json:"avg"`
	Sum   float64 `json:"sum"`
}

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.