Versions in this module Expand all Collapse all v1 v1.1.0 Jan 11, 2025 v1.0.0 Dec 16, 2024 Changes in this version + func New(c *config.Config) (pipeline.Processor, error) + type Config struct + BulkSizeInKB int + BulkSizeInMB int + Elasticsearch string + IndexName string + MessageField param.ParaKey + OutputQueue struct{ ... } + TypeName string + type IndexingMergeToBulkProcessor struct + func (processor *IndexingMergeToBulkProcessor) Name() string + func (processor *IndexingMergeToBulkProcessor) Process(ctx *pipeline.Context) error
Go to main page