batch

Documentation

Index

• type BatchItem
• type BatchProcessor
  • func NewBatchProcessor(config Config, processor func([]BatchItem) []BatchItem) *BatchProcessor
  • func (b *BatchProcessor) Add(item BatchItem)
  • func (b *BatchProcessor) Start()
  • func (b *BatchProcessor) Stop()
• type Config
  • func DefaultConfig() Config

Types

type BatchItem

type BatchItem struct {
	ID      string
	Data    any
	Error   error
	Success bool
}

BatchItem represents a single item in a batch

type BatchProcessor

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

BatchProcessor handles batch processing operations

func NewBatchProcessor

func NewBatchProcessor(config Config, processor func([]BatchItem) []BatchItem) *BatchProcessor

NewBatchProcessor creates a new batch processor

func (*BatchProcessor) Add

func (b *BatchProcessor) Add(item BatchItem)

Add adds a new item to be processed

func (*BatchProcessor) Start

func (b *BatchProcessor) Start()

Start begins processing batches

func (*BatchProcessor) Stop

func (b *BatchProcessor) Stop()

Stop gracefully shuts down the batch processor

type Config

type Config struct {
	BatchSize     int
	FlushTimeout  time.Duration
	MaxConcurrent int
	MaxRetries    int
	RetryDelay    time.Duration
}

Config represents batch processor configuration

func DefaultConfig

func DefaultConfig() Config

DefaultConfig returns default configuration