mong

Documentation

Index

• func ExtractId(doc bson.Raw) primitive.E
• func IsDuplicateKeyError(err error) bool
• func ListCollections(ctx context.Context, db string, mongo *Mong) ([]string, error)
• type Mong
  • func NewMongo(connectUri string) *Mong
• type MongoRegistry
  • func NewMongoRegistry() *MongoRegistry
  • func (m *MongoRegistry) GetSource() *Mong
  • func (m *MongoRegistry) GetTarget() *Mong

Functions

func ExtractId

func ExtractId(doc bson.Raw) primitive.E

func IsDuplicateKeyError

func IsDuplicateKeyError(err error) bool

IsDuplicateKeyError checks if the error is a duplicate key error

func ListCollections

func ListCollections(ctx context.Context, db string, mongo *Mong) ([]string, error)

List the collections of a database

Types

type Mong

type Mong struct {
	// Keep the connection/client
	Client *mongo.Client
}

func NewMongo

func NewMongo(connectUri string) *Mong

NewMongo returns a new Mongo struct

type MongoRegistry

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

var Registry *MongoRegistry = NewMongoRegistry()

func NewMongoRegistry

func NewMongoRegistry() *MongoRegistry

func (*MongoRegistry) GetSource

func (m *MongoRegistry) GetSource() *Mong

func (*MongoRegistry) GetTarget

func (m *MongoRegistry) GetTarget() *Mong