Versions in this module Expand all Collapse all v0 v0.1.0 Aug 20, 2024 Changes in this version + type DataProcessor interface + Process func(T) (T, error) + func NewTPSLimiter[T any](ctx context.Context, n int) DataProcessor[T] + type ProcessorWorker struct + func NewProcessorWorker[T any](processor DataProcessor[T]) *ProcessorWorker[T] + func (w *ProcessorWorker[T]) Run(ctx context.Context) error + func (w *ProcessorWorker[T]) SetReceiveChan(c <-chan T) + func (w *ProcessorWorker[T]) SetSendChan(c chan<- T) + type TokenProcessor = DataProcessor[*models.Token] + func NewChangeNamespace(source, destination *string) TokenProcessor + func NewExpirationSetter(expired *atomic.Uint64, logger *slog.Logger) TokenProcessor + func NewFilterByBin(binList []string, skipped *atomic.Uint64) TokenProcessor + func NewFilterBySet(setList []string, skipped *atomic.Uint64) TokenProcessor + func NewFilterByType(noRecords, noIndexes, noUdf bool) TokenProcessor + func NewRecordCounter(counter *atomic.Uint64) TokenProcessor + func NewSizeCounter(counter *atomic.Uint64) TokenProcessor + func NewVoidTimeSetter(logger *slog.Logger) TokenProcessor
Go to main page