mongodb

package

v4.14.1 Latest Latest Go to latest Published: Apr 26, 2023 License: MIT Imports: 28 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	FindInputOperation      = "find"
	AggregateInputOperation = "aggregate"
)

mongodb input component allowed operations.

This section is empty.

func NewOutput(conf output.MongoDBConfig, mgr bundle.NewManagement) (output.Streamed, error)

NewOutput creates a new MongoDB output type.

func NewProcessor(conf processor.Config, mgr bundle.NewManagement) (processor.AutoObservedBatched, error)

NewProcessor returns a MongoDB processor.

type Processor struct {
	// contains filtered or unexported fields
}

Processor stores or retrieves data from a mongo db for each message of a batch.

func (m *Processor) Close(ctx context.Context) error

Close shuts down the processor and stops processing requests.

func (m *Processor) ProcessBatch(ctx *processor.BatchProcContext, batch message.Batch) ([]message.Batch, error)

ProcessBatch applies the processor to a message batch, either creating >0 resulting messages or a response to be sent back to the message source.

type Writer struct {
	// contains filtered or unexported fields
}

Writer is a benthos writer.Type implementation that writes messages to an Writer database.

func NewWriter(
	mgr bundle.NewManagement,
	conf output.MongoDBConfig,
	log log.Modular,
	stats metrics.Type,
) (*Writer, error)

NewWriter creates a new MongoDB writer.Type.

func (m *Writer) Close(ctx context.Context) error

Close begins cleaning up resources used by this writer.

func (m *Writer) Connect(ctx context.Context) error

Connect attempts to establish a connection to the target mongo DB.

func (m *Writer) WriteBatch(ctx context.Context, msg message.Batch) error

WriteBatch attempts to perform the designated operation to the mongo DB collection.

Path	Synopsis
client