Versions in this module Expand all Collapse all v0 v0.16.0 Aug 21, 2024 Changes in this version + const DefaultQueueSize + func DisableLog() + func UseLogger(logger btclog.Logger) + type BatchWriter struct + func NewBatchWriter[T any](cfg *BatchWriterConfig[T]) *BatchWriter[T] + func (b *BatchWriter[T]) AddItem(item T) + func (b *BatchWriter[T]) Start() + func (b *BatchWriter[T]) Stop() + type BatchWriterConfig struct + DBWritesTickerDuration time.Duration + MaxBatch int + PutItems func(...T) error + QueueBufferSize int + type ConcurrentQueue struct + func NewConcurrentQueue[T any](bufferSize int) *ConcurrentQueue[T] + func (cq *ConcurrentQueue[T]) ChanIn() chan<- T + func (cq *ConcurrentQueue[T]) ChanOut() <-chan T + func (cq *ConcurrentQueue[T]) Start() + func (cq *ConcurrentQueue[T]) Stop()
Go to main page