mongodbutils

Documentation

Index

• Constants
• func Find(ctx context.Context, filter bson.M, collection *mongo.Collection, ...) error
• func IsDuplKeyError(err error) bool
• type MongoDB
  • func NewMongoDB(logger logr.Logger) *MongoDB
  • func (m *MongoDB) Connect(uri string) (*mongo.Client, error)
  • func (m *MongoDB) Disconnect()

Constants

const Err11000DupKeyError = 11000

Err11000DupKeyError code error for E11000.

Functions

func Find

func Find(ctx context.Context, filter bson.M, collection *mongo.Collection, dtos interface{}) error

Find executes the query in MongoDB and decode all results in dtos slice. Example: var dtos []userDTO err := mongodb.Find(ctx, props, m.collection, &dtos).

func IsDuplKeyError

func IsDuplKeyError(err error) bool

IsDuplKeyError detects if the error is a E11000 duplicate key error.

Types

type MongoDB

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

MongoDB will manage the connection with the database.

func NewMongoDB

func NewMongoDB(logger logr.Logger) *MongoDB

NewMongoDB is a constructor function.

func (*MongoDB) Connect

func (m *MongoDB) Connect(uri string) (*mongo.Client, error)

Connect open a database connection and check if it is connecting using ping.

func (*MongoDB) Disconnect

func (m *MongoDB) Disconnect()

Disconnect closes the connection with the database.