mongo

Documentation

Index

• type Mongo
  • func New(ctx context.Context, log lgr.L, uri, db string) (*Mongo, error)
  • func (m *Mongo) Disconnect(ctx context.Context)
  • func (m *Mongo) Operation(fn func(db *mongo.Database) error) error
  • func (m *Mongo) Session(ctx context.Context, ...) error
  • func (m *Mongo) Transaction(ctx context.Context, ...) error

Types

type Mongo

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

func New

func New(ctx context.Context, log lgr.L, uri, db string) (*Mongo, error)

func (*Mongo) Disconnect

func (m *Mongo) Disconnect(ctx context.Context)

func (*Mongo) Operation

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

func (*Mongo) Session

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

func (*Mongo) Transaction

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