Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FixedQueue ¶
type FixedQueue[T interface{}] struct {
// contains filtered or unexported fields
}
func NewFixedQueue ¶
func NewFixedQueue[T interface{}](ctx context.Context, size int) *FixedQueue[T]
func (*FixedQueue[T]) Fetch ¶
func (q *FixedQueue[T]) Fetch(ctx context.Context) <-chan T
func (*FixedQueue[T]) GetMaxSize ¶
func (q *FixedQueue[T]) GetMaxSize() int
func (*FixedQueue[T]) Pop ¶
func (q *FixedQueue[T]) Pop() *T
func (*FixedQueue[T]) Push ¶
func (q *FixedQueue[T]) Push(element T)
Source Files
Click to show internal directories.
Click to hide internal directories.