executor

Documentation

Index

• Constants
• type Executor
  • func NewExecutor(db *databases.Database, batchSize int) (*Executor, error)
  • func (e *Executor) ChangeBatchSize(batchSize int)
  • func (e *Executor) ChangeRetries(r int)
  • func (e *Executor) CreateIndexes() error
  • func (e *Executor) DoDelivery(wId int, oCarrierId int, olDeliveryD time.Time, dId int) error
  • func (e *Executor) DoDeliveryTrx(wId int, oCarrierId int, olDeliveryD time.Time, dId int) error
  • func (e *Executor) DoNewOrder(wId, dId, cId int, oEntryD time.Time, iIds []int, iWids []int, iQtys []int) error
  • func (e *Executor) DoNewOrderTrx(wId, dId, cId int, oEntryD time.Time, iIds []int, iWids []int, iQtys []int) error
  • func (e *Executor) DoOrderStatus(warehouseId, districtId, cId int, cLast string) error
  • func (e *Executor) DoOrderStatusTrx(warehouseId, districtId, cId int, cLast string) error
  • func (e *Executor) DoPayment(warehouseId, districtId int, amount float64, cWId, cDId, cId int, cLast string, ...) error
  • func (e *Executor) DoPaymentTrx(warehouseId, districtId int, amount float64, cWId, cDId, cId int, cLast string, ...) error
  • func (e *Executor) DoStockLevelTrx(warehouseId int, districtId int, threshold int) error
  • func (e *Executor) DoTrxRetries(fn func() error) error
  • func (e *Executor) Flush(collectionName string)
  • func (e *Executor) Save(collectionName string, d interface{})
  • func (e *Executor) SaveBatch(collectionName string, d interface{})

Constants

const DefaultRetries = 10

Types

type Executor

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

func NewExecutor

func NewExecutor(db *databases.Database, batchSize int) (*Executor, error)

func (*Executor) ChangeBatchSize

func (e *Executor) ChangeBatchSize(batchSize int)

func (*Executor) ChangeRetries

func (e *Executor) ChangeRetries(r int)

func (*Executor) CreateIndexes

func (e *Executor) CreateIndexes() error

func (*Executor) DoDelivery

func (e *Executor) DoDelivery(wId int, oCarrierId int, olDeliveryD time.Time, dId int) error

todo the order of arguments here is weird also the dId passed from the worker is probably utterly wrong

func (*Executor) DoDeliveryTrx

func (e *Executor) DoDeliveryTrx(wId int, oCarrierId int, olDeliveryD time.Time, dId int) error

func (*Executor) DoNewOrder

func (e *Executor) DoNewOrder(wId, dId, cId int, oEntryD time.Time, iIds []int, iWids []int, iQtys []int) error

func (*Executor) DoNewOrderTrx

func (e *Executor) DoNewOrderTrx(wId, dId, cId int, oEntryD time.Time, iIds []int, iWids []int, iQtys []int) error

func (*Executor) DoOrderStatus

func (e *Executor) DoOrderStatus(warehouseId, districtId, cId int, cLast string) error

func (*Executor) DoOrderStatusTrx

func (e *Executor) DoOrderStatusTrx(warehouseId, districtId, cId int, cLast string) error

func (*Executor) DoPayment

func (e *Executor) DoPayment(
	warehouseId, districtId int,
	amount float64,
	cWId, cDId, cId int,
	cLast string,
	hDate time.Time,
	badCredit string,
	cdatalen int,
) error

func (*Executor) DoPaymentTrx

func (e *Executor) DoPaymentTrx(warehouseId, districtId int,
	amount float64,
	cWId, cDId, cId int,
	cLast string,
	hDate time.Time,
	badCredit string,
	cdatalen int) error

func (*Executor) DoStockLevelTrx

func (e *Executor) DoStockLevelTrx(warehouseId int, districtId int, threshold int) error

func (*Executor) DoTrxRetries

func (e *Executor) DoTrxRetries(fn func() error) error

func (*Executor) Flush

func (e *Executor) Flush(collectionName string)

func (*Executor) Save

func (e *Executor) Save(collectionName string, d interface{})

@TODO@ error handling

func (*Executor) SaveBatch

func (e *Executor) SaveBatch(collectionName string, d interface{})