mongodb

Documentation

Index

• Constants
• func NewOutput(conf output.MongoDBConfig, mgr bundle.NewManagement) (output.Streamed, error)
• func NewProcessor(conf processor.Config, mgr bundle.NewManagement) (processor.V2Batched, error)
• type Processor
  • func (m *Processor) Close(ctx context.Context) error
  • func (m *Processor) ProcessBatch(ctx context.Context, spans []*tracing.Span, batch message.Batch) ([]message.Batch, error)
• type Writer
  • 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

Constants

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

mongodb input component allowed operations.

Functions

func NewOutput

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

NewOutput creates a new MongoDB output type.

func NewProcessor

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

NewProcessor returns a MongoDB processor.

Types

type 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 (*Processor) Close

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

Close shuts down the processor and stops processing requests.

func (*Processor) ProcessBatch

func (m *Processor) ProcessBatch(ctx context.Context, spans []*tracing.Span, 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

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

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

func NewWriter

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

NewWriter creates a new MongoDB writer.Type.

func (*Writer) Close

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

Close begins cleaning up resources used by this writer.

func (*Writer) Connect

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

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

func (*Writer) WriteBatch

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

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