mongoutils

Documentation

Index

• func Aggregate(collName string, db *mongo.Database, pipeline mongo.Pipeline) error
• func ConnectToMongo(m MongoURI, connectDirect bool) (a *mongo.Database, b *mongo.Client)
• type MongoURI
• type MongoWriter
  • func (writer *MongoWriter) Write(p []byte) (n int, err error)

Functions

func Aggregate

func Aggregate(collName string, db *mongo.Database, pipeline mongo.Pipeline) error

Aggregate func

func ConnectToMongo

func ConnectToMongo(m MongoURI, connectDirect bool) (a *mongo.Database, b *mongo.Client)

ConnectToMongo func

Types

type MongoURI

type MongoURI struct {
	Db       string
	User     string
	Password string
	Cluster  string
}

MongoURI struct for connection

type MongoWriter

type MongoWriter struct {
	DB *mongo.Database
}

MongoWriter implementing io.Writer interface

func (*MongoWriter) Write

func (writer *MongoWriter) Write(p []byte) (n int, err error)

Write func for logger