mong

Documentation

Index

• func ExtractId(doc bson.Raw) primitive.E
• func GetCollectionStats(r *Mong, database, collection string) (uint64, error)
• func IsDuplicateKeyError(err error) bool
• func ListCollections(ctx context.Context, db string, mongo *Mong) ([]string, error)
• func ListDbCollections(ctx context.Context, databases []string) (map[string][]string, error)
• type Mong
  • func NewMongo(connectUri string) *Mong
• type MongoRegistry
  • func NewMongoRegistry(appConfig *config.AppConfig) *MongoRegistry
  • func (m *MongoRegistry) GetSource() *Mong
  • func (m *MongoRegistry) GetTarget() *Mong

Functions

func ExtractId

func ExtractId(doc bson.Raw) primitive.E

func GetCollectionStats

func GetCollectionStats(r *Mong, database, collection string) (uint64, error)

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

func ListDbCollections

func ListDbCollections(ctx context.Context, databases []string) (map[string][]string, error)

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 = nil

func NewMongoRegistry

func NewMongoRegistry(appConfig *config.AppConfig) *MongoRegistry

func (*MongoRegistry) GetSource

func (m *MongoRegistry) GetSource() *Mong

func (*MongoRegistry) GetTarget

func (m *MongoRegistry) GetTarget() *Mong