pagereq

package
v1.0.4 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2025 License: MulanPSL-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InjectCmdRequest 

func InjectCmdRequest(s *CmdRequest)

func InjectIchubQueryRequest 

func InjectIchubQueryRequest(s *QueryRequest)

func LoadCmdRequest 

func LoadCmdRequest() baseiface.ISingleton

func LoadIchubQueryRequest 

func LoadIchubQueryRequest() baseiface.ISingleton

Types

type CmdRequest 

type CmdRequest struct {
	basedto.BaseEntity
	*cmddto.CmdDto
	*QueryRequest
}

func DefaultCmd 

func DefaultCmd() *CmdRequest

func FindBeanCmdRequest 

func FindBeanCmdRequest() *CmdRequest

func NewCmdRequest 

func NewCmdRequest() *CmdRequest

func (*CmdRequest) BulkCreate 

func (self *CmdRequest) BulkCreate() (*elastic.BulkResponse, error)

bulkRequest := client.Bulk() 

 doc1 := Document{ID: "1", Text: "Document one"}
	doc2 := Document{ID: "2", Text: "Document two"}//
	 bulkRequest.Add(elastic.NewBulkIndexRequest().Index("my_index").Id(doc1.ID).Doc(doc1))
	 bulkRequest.Add(elastic.NewBulkIndexRequest().Index("my_index").Id(doc2.ID).Doc(doc2))

func (*CmdRequest) BulkCreate2Result 

func (self *CmdRequest) BulkCreate2Result() *basedto.IchubResult

func (*CmdRequest) BulkDelete 

func (self *CmdRequest) BulkDelete() (int, error)

func (*CmdRequest) BulkDelete2Result 

func (self *CmdRequest) BulkDelete2Result() *basedto.IchubResult

func (*CmdRequest) BulkIndex 

func (self *CmdRequest) BulkIndex() (*elastic.BulkResponse, error)

func (*CmdRequest) BulkIndex2Result 

func (self *CmdRequest) BulkIndex2Result() *basedto.IchubResult

func (*CmdRequest) BulkStru 

func (self *CmdRequest) BulkStru(strus []*cmddto.BulkStru) (*elastic.BulkResponse, error)

func (*CmdRequest) BulkUpdate 

func (self *CmdRequest) BulkUpdate() (*elastic.BulkResponse, error)

for id, doc := range m { bulkService.Add(elastic.NewBulkCreateRequest(). Index(index).// Id(id).// Doc(doc))// } bulkIndex 批量索引文档更新，文档不存在就建立，存在就覆盖,​​如果文档原来有3个字段，批量更新时有2个字段，在bulkIndex之后，它最后会变成最新的2个字段​​ bulkUpdate 批量更新文档字段，​​如果文档原来有3个字段，批量更新时有2个字段，结果还是3个字段​​ Add(elastic.NewBulkUpdateRequest().Id(this.Id).Doc(this.Doc)).

func (*CmdRequest) BulkUpdate2Result 

func (self *CmdRequest) BulkUpdate2Result() *basedto.IchubResult

func (*CmdRequest) CopyFromDb 

func (self *CmdRequest) CopyFromDb(tableName string, pkField ...string) error

func (*CmdRequest) Delete 

func (self *CmdRequest) Delete() (*elastic.DeleteResponse, error)

func (*CmdRequest) DeleteByQuery 

func (self *CmdRequest) DeleteByQuery() (int64, error)

func (*CmdRequest) DocAsUpsert 

func (self *CmdRequest) DocAsUpsert() (*elastic.UpdateResponse, error)

func (*CmdRequest) Execute 

func (self *CmdRequest) Execute() *basedto.IchubResult

func (*CmdRequest) SaveIndex 

func (self *CmdRequest) SaveIndex(id string, model any) (*elastic.IndexResponse, error)

func (*CmdRequest) SaveIndexData 

func (self *CmdRequest) SaveIndexData() (*elastic.IndexResponse, error)

func (*CmdRequest) Update 

func (self *CmdRequest) Update() (*elastic.UpdateResponse, error)

func (*CmdRequest) UpdateAsResult 

func (self *CmdRequest) UpdateAsResult() *basedto.IchubResult

func (*CmdRequest) UpdateByQuery 

func (self *CmdRequest) UpdateByQuery() (*elastic.BulkIndexByScrollResponse, error)

func (*CmdRequest) Upsert 

func (self *CmdRequest) Upsert() (*elastic.UpdateResponse, error)

type KeyWorkRequest 

type KeyWorkRequest struct {
	basedto.BaseProxy
	esdto.EsRequest
	Tokenizer string
	Text      string
}

func NewKeyworkRequest 

func NewKeyworkRequest() *KeyWorkRequest

func (*KeyWorkRequest) Analyze 

func (this *KeyWorkRequest) Analyze() (*elastic.IndicesAnalyzeResponse, error)

func (*KeyWorkRequest) IndexAnalyze 

func (this *KeyWorkRequest) IndexAnalyze(text string) (*elastic.IndicesAnalyzeResponse, error)

func (*KeyWorkRequest) IndexAnalyzeToken 

func (this *KeyWorkRequest) IndexAnalyzeToken(token string, text string) (*elastic.IndicesAnalyzeResponse, error)

func (*KeyWorkRequest) IndexAnalyzeWord 

func (this *KeyWorkRequest) IndexAnalyzeWord(r *splitword.SplitWordRequest) (*elastic.IndicesAnalyzeResponse, error)

type MetadataRequest 

type MetadataRequest struct {
	esdto.EsRequest
	Fields map[string]string

	Mappings string
}

func DefaultMetadata 

func DefaultMetadata() *MetadataRequest

func NewMetadataRequest 

func NewMetadataRequest() *MetadataRequest

func (*MetadataRequest) CreateAlias 

func (this *MetadataRequest) CreateAlias() (*basedto.IchubResult, error)

func (*MetadataRequest) CreateIndex 

func (this *MetadataRequest) CreateIndex() (bool, error)

bool create ok, error

func (*MetadataRequest) DefineIndexField 

func (this *MetadataRequest) DefineIndexField(name, Type string)

func (*MetadataRequest) DropIndex 

func (this *MetadataRequest) DropIndex() *elastic.IndicesDeleteService

func (*MetadataRequest) Execute 

func (this *MetadataRequest) Execute() (interface{}, error)

func (*MetadataRequest) GetMapping 

func (this *MetadataRequest) GetMapping() (map[string]interface{}, error)

func (*MetadataRequest) IndexExist 

func (this *MetadataRequest) IndexExist() (bool, error)

func (*MetadataRequest) ToMetadata 

func (this *MetadataRequest) ToMetadata() *indexmeta.EsIndexMetadata

type QueryRequest 

type QueryRequest struct {
	basedto.BaseEntity
	*pagees.PageEsRequest
	*clidto.HttpQueryBody

	SearchType      string            `json:"search_type"`
	MaxResponseSize int64             `json:"max_response_size"`
	TrackTotalHits  bool              `json:"track_total_hits"`
	EsAggDtos       []*esdto.EsAggDto `json:"es_agg_dtos"`
	// contains filtered or unexported fields
}

func Default 

func Default() *QueryRequest

func FindBeanIchubQueryRequest 

func FindBeanIchubQueryRequest() *QueryRequest

func NewQueryRequest 

func NewQueryRequest() *QueryRequest

func (*QueryRequest) Aggregation 

func (self *QueryRequest) Aggregation(name string, aggregation elastic.Aggregation)

func (*QueryRequest) Aggregations 

func (self *QueryRequest) Aggregations() map[string]elastic.Aggregation

func (*QueryRequest) EsStats 

func (self *QueryRequest) EsStats(statField string, size ...int) *QueryRequest

func (*QueryRequest) Execute 

func (this *QueryRequest) Execute() (*pagees.PageEsResult, error)

func (*QueryRequest) Filter 

func (this *QueryRequest) Filter() (*pagees.PageEsResult, error)

func (*QueryRequest) Get 

func (this *QueryRequest) Get() *basedto.IchubResult

func (*QueryRequest) Get2PageEsResult 

func (this *QueryRequest) Get2PageEsResult() *pagees.PageEsResult

func (*QueryRequest) IfAggStats 

func (self *QueryRequest) IfAggStats() bool

func (*QueryRequest) IfGet 

func (this *QueryRequest) IfGet() bool

func (*QueryRequest) IfQuery 

func (this *QueryRequest) IfQuery() bool

func (*QueryRequest) IfServerHttpcliBodyEmpty 

func (self *QueryRequest) IfServerHttpcliBodyEmpty() bool

func (*QueryRequest) IsMust 

func (this *QueryRequest) IsMust() bool

func (*QueryRequest) Must 

func (this *QueryRequest) Must() (*pagees.PageEsResult, error)

func (*QueryRequest) MustNot 

func (this *QueryRequest) MustNot() (*pagees.PageEsResult, error)

func (*QueryRequest) Query 

func (this *QueryRequest) Query() (*pagees.PageEsResult, error)

func (*QueryRequest) QuerySourceBody 

func (self *QueryRequest) QuerySourceBody() *QueryRequest

func (*QueryRequest) SearchSources 

func (self *QueryRequest) SearchSources() map[string]any

func (*QueryRequest) SetIndexName 

func (self *QueryRequest) SetIndexName(index string) *QueryRequest

func (*QueryRequest) SetPageCurrent 

func (self *QueryRequest) SetPageCurrent(current int) *QueryRequest

func (*QueryRequest) SetPageSize 

func (self *QueryRequest) SetPageSize(size int) *QueryRequest

func (*QueryRequest) SetSearchSources 

func (self *QueryRequest) SetSearchSources(key string, value any) *QueryRequest

func (*QueryRequest) SetSource 

func (self *QueryRequest) SetSource(src string) *QueryRequest

func (*QueryRequest) Should 

func (this *QueryRequest) Should() (*pagees.PageEsResult, error)

Source Files

View all Source files

Directories

Path Synopsis
splitword

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.