queue

Oct 4, 2024

Changes in this version

+ const DefaultWorkerCount

+ type ConcurrentRandomQueue struct

+ func NewConcurrentRandomQueue[T any](seed int64, capacityHint int) *ConcurrentRandomQueue[T]

+ func (q *ConcurrentRandomQueue[T]) Pop() *T

+ func (q *ConcurrentRandomQueue[T]) Push(item T)

+ type Option func(*Scheduler)

+ func WithCaser(c *caser.Caser) Option

+ func WithDeterministicCQID(deterministicCQID bool) Option

+ func WithInvocationID(invocationID string) Option

+ func WithWorkerCount(workerCount int) Option

+ type Scheduler struct

+ func NewShuffleQueueScheduler(logger zerolog.Logger, m *metrics.Metrics, seed int64, opts ...Option) *Scheduler

+ func (d *Scheduler) Sync(ctx context.Context, tableClients []WorkUnit, ...)

+ type WorkUnit struct

+ Client schema.ClientMeta

+ Parent *schema.Resource

+ Table *schema.Table