cmd

Documentation

Index

• Constants
• func Execute() error
• type Processor
  • func NewProcessor(cfg *config.Secret, db *sql.DB, logger *logger.Logger) *Processor
  • func (p *Processor) DR(wg *sync.WaitGroup, message []byte)
  • func (p *Processor) MO(wg *sync.WaitGroup, message []byte)
  • func (p *Processor) Renewal(wg *sync.WaitGroup, message []byte)
  • func (p *Processor) Retry(wg *sync.WaitGroup, message []byte)

Constants

const (
	RMQ_AUTOACK            = false
	RMQ_EXCHANGETYPE       = "direct"
	RMQ_EXCHANGEDURABILITY = false
	RMQ_QUEUEDURABILITY    = true
	RMQ_DATATYPE           = "application/json"
	RMQ_MOEXCHANGE         = "E_MO"
	RMQ_MOQUEUE            = "Q_MO"
	RMQ_DREXCHANGE         = "E_DR"
	RMQ_DRQUEUE            = "Q_DR"
	RMQ_REMINDEREXCHANGE   = "E_REMINDER"
	RMQ_REMINDERQUEUE      = "Q_REMINDER"
	RMQ_RENEWALEXCHANGE    = "E_RENEWAL"
	RMQ_RENEWALQUEUE       = "Q_RENEWAL"
	RMQ_RETRYEXCHANGE      = "E_RETRY"
	RMQ_RETRYQUEUE         = "Q_RETRY"
	MT_FIRSTPUSH           = "MT_FIRSTPUSH"
	ACT_RENEWAL            = "RENEWAL"
	ACT_RETRY              = "RETRY"
)

Functions

func Execute

func Execute() error

Types

type Processor

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

func NewProcessor

func NewProcessor(
	cfg *config.Secret,
	db *sql.DB,
	logger *logger.Logger,
) *Processor

func (*Processor) DR

func (p *Processor) DR(wg *sync.WaitGroup, message []byte)

func (*Processor) MO

func (p *Processor) MO(wg *sync.WaitGroup, message []byte)

func (*Processor) Renewal

func (p *Processor) Renewal(wg *sync.WaitGroup, message []byte)

func (*Processor) Retry

func (p *Processor) Retry(wg *sync.WaitGroup, message []byte)