Versions in this module Expand all Collapse all v0 v0.1.0 Jan 24, 2025 Changes in this version + var ErrMongoInitialization = errors.New("failed to start mongo writer") + func NewMongoDBWriter[T entities.PipelineEvent](ctx context.Context, config *Config) (sinks.Sink[T], error) + type Config struct + Collection string + Database string + InsertOnly bool + URL config.SecretSource + func (c *Config) Validate() error + type Writer struct + func (w *Writer[T]) Delete(ctx context.Context, data T) error + func (w *Writer[T]) Insert(ctx context.Context, data T) error + func (w *Writer[T]) Upsert(ctx context.Context, data T) error + func (w *Writer[T]) WriteData(ctx context.Context, data T) error
Go to main page