Versions in this module Expand all Collapse all v4 v4.14.1 Apr 26, 2023 Changes in this version + const AggregateInputOperation + const FindInputOperation + func NewOutput(conf output.MongoDBConfig, mgr bundle.NewManagement) (output.Streamed, error) + func NewProcessor(conf processor.Config, mgr bundle.NewManagement) (processor.AutoObservedBatched, error) + type Processor struct + func (m *Processor) Close(ctx context.Context) error + func (m *Processor) ProcessBatch(ctx *processor.BatchProcContext, batch message.Batch) ([]message.Batch, error) + type Writer struct + func NewWriter(mgr bundle.NewManagement, conf output.MongoDBConfig, log log.Modular, ...) (*Writer, error) + func (m *Writer) Close(ctx context.Context) error + func (m *Writer) Connect(ctx context.Context) error + func (m *Writer) WriteBatch(ctx context.Context, msg message.Batch) error Other modules containing this package github.com/dafanshu/benthos/v3
Go to main page