invalid

Documentation

Index

• Constants
• type Config
• type Processor
  • func NewProcessor(invalidQueue *queue.Queue[*responses.Accrual], orderManager orderManager, ...) *Processor
  • func (processor *Processor) Process(ctx context.Context) error

Constants

const DefaultBatchSize = 100

const DefaultConcurrency = 10

const DefaultFailedTaskDelay = time.Second * 10

const DefaultNoTasksDelay = time.Second * 5

Types

type Config

type Config struct {
	Concurrency     uint64
	BatchSize       uint64
	NoTasksDelay    *time.Duration
	FailedTaskDelay *time.Duration
}

type Processor

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

func NewProcessor

func NewProcessor(
	invalidQueue *queue.Queue[*responses.Accrual],
	orderManager orderManager,
	config *Config,
) *Processor

func (*Processor) Process

func (processor *Processor) Process(ctx context.Context) error