Versions in this module Expand all Collapse all v4 v4.27.1 May 31, 2024 v4.27.0 May 31, 2024 Changes in this version + const AggregateInputOperation + const FindInputOperation + func ProcessorSpec() *service.ConfigSpec + type JSONMarshalMode string + const JSONMarshalModeCanonical + const JSONMarshalModeRelaxed + type Operation string + const OperationDeleteMany + const OperationDeleteOne + const OperationFindOne + const OperationInsertOne + const OperationInvalid + const OperationReplaceOne + const OperationUpdateOne + func NewOperation(op string) Operation + type Processor struct + func ProcessorFromParsed(conf *service.ParsedConfig, res *service.Resources) (mp *Processor, err error) + func (m *Processor) Close(ctx context.Context) error + func (m *Processor) ProcessBatch(ctx context.Context, batch service.MessageBatch) ([]service.MessageBatch, error)