Versions in this module Expand all Collapse all v1 v1.0.0 Sep 4, 2024 Changes in this version + type FixedQueue struct + func NewFixedQueue[T interface{}](ctx context.Context, size int) *FixedQueue[T] + func (q *FixedQueue[T]) Fetch(ctx context.Context) <-chan T + func (q *FixedQueue[T]) GetMaxSize() int + func (q *FixedQueue[T]) Pop() *T + func (q *FixedQueue[T]) Push(element T)