mongo

Documentation

Index

• type Mongo
  • func Connect(ctx context.Context, logger tools.Logger, preferences Preferences) (*Mongo, error)
  • func (m *Mongo) Close(ctx context.Context) error
  • func (m *Mongo) Operation(f func(db *mongo.Database) error) error
  • func (m *Mongo) Transaction(ctx context.Context, ...) error
• type Preferences

Types

type Mongo

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

func Connect

func Connect(ctx context.Context, logger tools.Logger, preferences Preferences) (*Mongo, error)

func (*Mongo) Close

func (m *Mongo) Close(ctx context.Context) error

func (*Mongo) Operation

func (m *Mongo) Operation(f func(db *mongo.Database) error) error

Operation executes a single operation on the database

func (*Mongo) Transaction

func (m *Mongo) Transaction(ctx context.Context, actions ...func(sessionCtx mongo.SessionContext, db *mongo.Database) error) error

Transaction executes a series of actions in a single transaction

type Preferences

type Preferences struct {
	URI  string `long:"uri" env:"URI" description:"MongoDB URI" required:"true"`
	Name string `long:"name" env:"NAME" description:"MongoDB database name" required:"true"`
}