databases

Documentation

Index

• type Database
  • func NewDb(uri string, dbname string, transactions bool, findandmodify bool) (*Database, error)
  • func (db *Database) CreateIndexes() error
  • func (db *Database) DoDelivery(ctx context.Context, wId int, oCarrierId int, olDeliveryD time.Time, dId int) error
  • func (db *Database) DoNewOrder(ctx context.Context, w_id int, d_id int, c_id int, o_entry_d time.Time, ...) error
  • func (db *Database) DoOrderStatus(ctx context.Context, wId int, dId int, cId int, cLast string) error
  • func (db *Database) DoPayment(ctx context.Context, wId int, dId int, hAmount float64, cWId int, cDId int, ...) error
  • func (db *Database) DoStockLevelTrx(ctx context.Context, wId int, dId int, threshold int) error
  • func (db *Database) DoTrxRetries(fn func(ctx context.Context) error, retries int) error
  • func (db *Database) InsertBatch(collectionName string, d []interface{}) error
  • func (db *Database) InsertOne(collectionName string, d interface{}) error

Types

type Database

type Database struct {
	Client    *mongo.Client
	C         *mongo.Database
	Aggregate bool
	// contains filtered or unexported fields
}

func NewDb

func NewDb(uri string, dbname string, transactions bool, findandmodify bool) (*Database, error)

func (*Database) CreateIndexes

func (db *Database) CreateIndexes() error

func (*Database) DoDelivery

func (db *Database) DoDelivery(ctx context.Context, wId int, oCarrierId int, olDeliveryD time.Time, dId int) error

func (*Database) DoNewOrder

func (db *Database) DoNewOrder(
	ctx context.Context,
	w_id int,
	d_id int,
	c_id int,
	o_entry_d time.Time,
	i_ids []int,
	i_w_ids []int,
	i_qtys []int,
) error

func (*Database) DoOrderStatus

func (db *Database) DoOrderStatus(ctx context.Context, wId int, dId int, cId int, cLast string) error

func (*Database) DoPayment

func (db *Database) DoPayment(ctx context.Context, wId int, dId int, hAmount float64, cWId int,
	cDId int, cId int, cLast string, hDate time.Time, badCredit string, cDataLen int) error

func (*Database) DoStockLevelTrx

func (db *Database) DoStockLevelTrx(ctx context.Context, wId int, dId int, threshold int) error

func (*Database) DoTrxRetries

func (db *Database) DoTrxRetries(fn func(ctx context.Context) error, retries int) error

func (*Database) InsertBatch

func (db *Database) InsertBatch(collectionName string, d []interface{}) error

func (*Database) InsertOne

func (db *Database) InsertOne(collectionName string, d interface{}) error