db

Documentation

Index

• func NewDatabase(mongoUrl string, name string) (*mongo.Database, error)
• type Collection
  • func NewCollection(log log.LogRusEntry, database *mongo.Database, collectionName string, ...) (col Collection, err error)
• type Cursor
  • func NewCursor(cursor *mongo.Cursor) Cursor

Functions

func NewDatabase

func NewDatabase(
	mongoUrl string,
	name string,
) (*mongo.Database, error)

NewDatabase the mongo database

Types

type Collection

type Collection interface {
	FindOne(ctx context.Context, filter interface{}, v interface{}) error

	InsertOne(ctx context.Context, document interface{}) (id interface{}, error error)

	UpdateOne(ctx context.Context, filter interface{}, update interface{}) (modified int64, error error)

	Find(ctx context.Context, filter interface{}) (cur Cursor, err error)

	ReplaceOne(ctx context.Context, filter interface{}, replacement interface{}) (modified int64, error error)
}

func NewCollection

func NewCollection(
	log log.LogRusEntry,
	database *mongo.Database,
	collectionName string,
	onError func(error),
	indexes ...string,
) (col Collection, err error)

type Cursor

type Cursor interface {
	Close(ctx context.Context) error
	Next(ctx context.Context) bool
	Decode(val interface{}) error
}

func NewCursor

func NewCursor(cursor *mongo.Cursor) Cursor