queue

Documentation

Index

• type IManager
  • func NewManager(cfg *config.Estuary, log *zap.SugaredLogger) IManager

Types

type IManager

type IManager interface {
	QueueContent(contID uint64, tx *gorm.DB) error
	DealComplete(contID uint64, tx *gorm.DB)
	MadeOneDeal(contID uint64, tx *gorm.DB) error
	DealFailed(contID uint64, tx *gorm.DB)
	DealCheckComplete(contID uint64, dealsToBeMade int, tx *gorm.DB)
	DealCheckFailed(contID uint64, tx *gorm.DB)
}

func NewManager

func NewManager(cfg *config.Estuary, log *zap.SugaredLogger) IManager