Versions in this module Expand all Collapse all v4 v4.1.3 Nov 17, 2022 v4.1.2 Apr 26, 2022 v4.1.1 Jan 11, 2022 v4.1.0 Oct 15, 2021 Changes in this version + func ApplyMerge(doc *models.Document, command *UpdateCommand, secondary []*models.Document) *models.Document + type BulkIngestRequest struct + Docs []*models.Document + DocumentType string + MergeConfig []*merge.Config + UUID string + type BulkIngester struct + Cache *ttlcache.Cache + EsExecutor *elasticsearch.EsExecutor + TypedIngesters map[string]*TypedIngester + func NewBulkIngester(esExecutor *elasticsearch.EsExecutor) *BulkIngester + func (ingester *BulkIngester) Ingest(bir BulkIngestRequest) + type GetQuery struct + DocumentType string + ID string + type IndexingWorker struct + Client *elasticsearch.EsExecutor + Data chan *UpdateCommand + ID int + TypedIngester *TypedIngester + func NewIndexingWorker(typedIngester *TypedIngester, id int) *IndexingWorker + func (worker *IndexingWorker) BulkChainedUpdate(documents [][]*UpdateCommand) + func (worker *IndexingWorker) Run() + type IngestRequest struct + BulkUUID string + Doc *models.Document + DocumentType string + MergeConfig *merge.Config + UUID string + type TypedIngester struct + Data chan *IngestRequest + DocumentType string + Workers map[int]*IndexingWorker + func NewTypedIngester(bulkIngester *BulkIngester, documentType string) *TypedIngester + func (ingester *TypedIngester) Run() + type UpdateCommand struct + DocumentID string + DocumentType string + MergeConfig *merge.Config + NewDoc *models.Document + func NewUpdateCommand(documentID string, documentType string, newDoc *models.Document, ...) *UpdateCommand Other modules containing this package github.com/myrteametrics/myrtea-ingester-api/v5
Go to main page