goqueue

Nov 25, 2024

Changes in this version

+ const QueueMetricsSubsystem

+ type AsyncReader struct

+ func NewAsyncReader[T any](ch <-chan T) *AsyncReader[T]

+ func (cr *AsyncReader[T]) Read() []T

+ type FanOut struct

+ func NewFanOut[T any](ctx context.Context, name string, source <-chan T) *FanOut[T]

+ func (b *FanOut[T]) Run() *FanOut[T]

+ func (b *FanOut[T]) Subscribe() <-chan T

+ func (b *FanOut[T]) Unsubscribe(channel <-chan T)

+ func (b *FanOut[T]) WithMetrics(metrics *QueueMetrics) *FanOut[T]

+ func (b *FanOut[T]) WithQueueSize(size int) *FanOut[T]

+ type FanOutChan struct

+ func NewChanBroadcaster[T any](ctx context.Context, name string, source <-chan (chan T)) *FanOutChan[T]

+ func (b *FanOutChan[T]) Run() *FanOutChan[T]

+ func (b *FanOutChan[T]) Subscribe() <-chan (<-chan T)

+ func (b *FanOutChan[T]) Unsubscribe(channel chan (<-chan T))

+ func (b *FanOutChan[T]) WithMetrics(metrics *QueueMetrics) *FanOutChan[T]

+ func (b *FanOutChan[T]) WithQueueSize(size int) *FanOutChan[T]

+ type QueueMetrics struct

+ ObserverReadCount *prometheus.CounterVec

+ ObserverSubscribed *prometheus.GaugeVec

+ ObserverWriteCount *prometheus.CounterVec

+ ObserverWriteFullCount *prometheus.CounterVec

+ func NewQueueMetrics() *QueueMetrics