mongodb

Documentation

Index

• Variables
• func Disconnect(connection *Connection)
• func LoadMongoDBName(key string) (database string, err error)
• func LoadMongoDBURI(key string) (uri string, err error)
• type Collection
  • func NewCollection(name string, singleFieldIndexes *[]*SingleFieldIndex, ...) *Collection
  • func (c *Collection) CreateCollection(database *mongo.Database) (collection *mongo.Collection, err error)
• type CompoundFieldIndex
  • func NewCompoundFieldIndex(fieldIndexes []*FieldIndex, unique bool) *CompoundFieldIndex
• type Config
• type Connection
  • func Connect(config *Config) (connection *Connection, err error)
• type FieldIndex
  • func NewFieldIndex(name string, order Order) *FieldIndex
• type Logger
  • func NewLogger(name string) *Logger
  • func (m *Logger) ConnectedToMongoDB()
  • func (m *Logger) DisconnectedFromMongoDB()
• type Order
  • func (o Order) OrderInt() int
• type SingleFieldIndex
  • func NewSingleFieldIndex(fieldIndex FieldIndex, unique bool) *SingleFieldIndex

Variables

var FailedToConnectError = errors.New("failed to connect to MongoDB")

var FailedToCreateCompoundIndexError = errors.New("failed to create compound index")

var FailedToCreateDocumentError = errors.New("failed to create document")

var FailedToCreateSingleFieldIndexError = errors.New("failed to create single field index")

var FailedToDisconnectError = errors.New("failed to disconnect from MongoDB")

var FailedToPingError = errors.New("failed to ping MongoDB")

var FailedToStartSessionError = errors.New("failed to start session")

Functions

func Disconnect

func Disconnect(connection *Connection)

Disconnect closes the MongoDB client connection

func LoadMongoDBName

func LoadMongoDBName(key string) (database string, err error)

LoadMongoDBName load MongoDB database name from environment variables

func LoadMongoDBURI

func LoadMongoDBURI(key string) (uri string, err error)

LoadMongoDBURI load MongoDB URI from environment variables

Types

type Collection

type Collection struct {
	Name               string
	SingleFieldIndexes *[]*SingleFieldIndex
	CompoundIndexes    *[]*CompoundFieldIndex
}

Collection represents a MongoDB collection

func NewCollection

func NewCollection(name string, singleFieldIndexes *[]*SingleFieldIndex, compoundIndexes *[]*CompoundFieldIndex) *Collection

NewCollection creates a new MongoDB collection

func (*Collection) CreateCollection

func (c *Collection) CreateCollection(database *mongo.Database) (collection *mongo.Collection, err error)

CreateCollection creates the collection

type CompoundFieldIndex

type CompoundFieldIndex struct {
	Model *mongo.IndexModel
}

CompoundFieldIndex represents a compound field index

func NewCompoundFieldIndex

func NewCompoundFieldIndex(fieldIndexes []*FieldIndex, unique bool) *CompoundFieldIndex

NewCompoundFieldIndex creates a new compound field index

type Config

type Config struct {
	Uri     string
	Timeout time.Duration
}

type Connection

type Connection struct {
	Config *Config
	Client *mongo.Client
	Ctx    context.Context
	Cancel context.CancelFunc
}

func Connect

func Connect(config *Config) (connection *Connection, err error)

Connect returns a new MongoDB client

type FieldIndex

type FieldIndex struct {
	Name  string
	Order Order
}

func NewFieldIndex

func NewFieldIndex(name string, order Order) *FieldIndex

NewFieldIndex creates a new field index

type Logger

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

func NewLogger

func NewLogger(name string) *Logger

NewLogger is the logger for the MongoDB model

func (*Logger) ConnectedToMongoDB

func (m *Logger) ConnectedToMongoDB()

ConnectedToMongoDB logs a success message when the server connects from MongoDB

func (*Logger) DisconnectedFromMongoDB

func (m *Logger) DisconnectedFromMongoDB()

DisconnectedFromMongoDB logs a success message when the server disconnects from MongoDB

type Order

type Order int

const (
	// Ascending order
	Ascending Order = 1

	// Descending order
	Descending Order = -1
)

func (Order) OrderInt

func (o Order) OrderInt() int

OrderInt converts the Order type to an integer

type SingleFieldIndex

type SingleFieldIndex struct {
	Model *mongo.IndexModel
}

func NewSingleFieldIndex

func NewSingleFieldIndex(fieldIndex FieldIndex, unique bool) *SingleFieldIndex

NewSingleFieldIndex creates a new single field index