pkg

Documentation

Index

• type MongoDBDestination
  • func NewMongoDBDestination(uri, connectionTimeout, queryTimeout, database, collection string, ...) *MongoDBDestination
  • func (d *MongoDBDestination) Initialize() error
  • func (d *MongoDBDestination) Persist(data []map[string]interface{}) error

Types

type MongoDBDestination

type MongoDBDestination struct {
	Uri                     string
	ConnectionTimeoutString string
	ConnectionTimeout       time.Duration
	QueryTimeoutString      string
	QueryTimeout            time.Duration
	DatabaseName            string
	CollectionName          string
	MongoIndexModels        []mongo.IndexModel
	UpsertFilterFields      []string
	Client                  *mongo.Client
	Collection              *mongo.Collection
}

func NewMongoDBDestination

func NewMongoDBDestination(uri, connectionTimeout, queryTimeout, database, collection string, upsertFilterFields []string, mongoIndexModels []mongo.IndexModel) *MongoDBDestination

func (*MongoDBDestination) Initialize

func (d *MongoDBDestination) Initialize() error

func (*MongoDBDestination) Persist

func (d *MongoDBDestination) Persist(data []map[string]interface{}) error