mongo

Documentation

Index

• type MongoSink
  • func NewMongoSink(ctx context.Context, db *mongo.Database, conf SinkConfig) (*MongoSink, error)
  • func (ks *MongoSink) In() chan<- interface{}
• type SinkConfig

Types

type MongoSink

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

MongoSink represents an Mongo sink connector.

func NewMongoSink

func NewMongoSink(ctx context.Context, db *mongo.Database, conf SinkConfig) (*MongoSink, error)

NewMongoSink returns a new MongoSink instance.

func (*MongoSink) In

func (ks *MongoSink) In() chan<- interface{}

In returns an input channel for receiving data.

type SinkConfig

type SinkConfig struct {
	CollectionName            string
	CollectionCapMaxDocuments int64
	CollectionCapMaxSizeBytes int64
	CollectionCapEnable       bool
}