batch

May 16, 2022

Changes in this version

+ type Metric struct

+ BatchStart time.Time

+ Error error

+ LoadResourceDuration time.Duration

+ OperationCount int

+ ResourceKey string

+ SaveResourceDuration time.Duration

+ TotalDuration time.Duration

type Processor

+ func (p *Processor[Resource]) SubscribeBatchMetrics() <-chan Metric

May 5, 2022

Changes in this version

+ var OperationCancelled = errors.New("run failed: operation was canceled before it was run")

May 2, 2022

Changes in this version

+ var ProcessorStopped = errors.New("run failed: processor is stopped")

+ func GoroutineNumberForKey(key string, goroutines int) int

+ type Options struct

+ GoRoutineNumberForKey func(_ string, goroutines int) int

+ GoRoutines int

+ LoadResource func(_ context.Context, key string) (Resource, error)

+ MaxDuration time.Duration

+ MinDuration time.Duration

+ SaveResource func(_ context.Context, key string, _ Resource) error

+ type Processor struct

+ func StartProcessor(options Options[Resource]) *Processor[Resource]

+ func (p *Processor[Resource]) Run(key string, op func(Resource)) error

+ func (p *Processor[Resource]) Stop()