mongodb

Documentation

Index

• Constants
• func ProcessorSpec() *service.ConfigSpec
• type JSONMarshalMode
• type Operation
  • func NewOperation(op string) Operation
• type Processor
  • 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)

Constants

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

mongodb input component allowed operations.

Functions

func ProcessorSpec

func ProcessorSpec() *service.ConfigSpec

ProcessorSpec defines the config spec of the mongodb processor.

Types

type JSONMarshalMode

type JSONMarshalMode string

JSONMarshalMode represents the way in which BSON should be marshalled to JSON.

const (
	// JSONMarshalModeCanonical Canonical BSON to JSON marshal mode.
	JSONMarshalModeCanonical JSONMarshalMode = "canonical"
	// JSONMarshalModeRelaxed Relaxed BSON to JSON marshal mode.
	JSONMarshalModeRelaxed JSONMarshalMode = "relaxed"
)

type Operation

type Operation string

Operation represents the operation that will be performed by MongoDB.

const (
	// OperationInsertOne Insert One operation.
	OperationInsertOne Operation = "insert-one"
	// OperationDeleteOne Delete One operation.
	OperationDeleteOne Operation = "delete-one"
	// OperationDeleteMany Delete many operation.
	OperationDeleteMany Operation = "delete-many"
	// OperationReplaceOne Replace one operation.
	OperationReplaceOne Operation = "replace-one"
	// OperationUpdateOne Update one operation.
	OperationUpdateOne Operation = "update-one"
	// OperationFindOne Find one operation.
	OperationFindOne Operation = "find-one"
	// OperationInvalid Invalid operation.
	OperationInvalid Operation = "invalid"
)

func NewOperation

func NewOperation(op string) Operation

NewOperation converts a string operation to a strongly-typed Operation.

type Processor

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

Processor encapsulates the logic of the mongodb processor.

func ProcessorFromParsed

func ProcessorFromParsed(conf *service.ParsedConfig, res *service.Resources) (mp *Processor, err error)

ProcessorFromParsed returns a mongodb processor from a parsed config.

func (*Processor) Close

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

Close the connection to mongodb.

func (*Processor) ProcessBatch

func (m *Processor) ProcessBatch(ctx context.Context, batch service.MessageBatch) ([]service.MessageBatch, error)

ProcessBatch attempts to process a batch of messages.