queue

package

v0.0.0-...-3951dda Latest Latest Go to latest Published: Sep 16, 2024 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Queue[T any] struct {
	// contains filtered or unexported fields
}

func NewQueue[T any](ctx context.Context, options ...QueueOption) *Queue[T]

func (q *Queue[T]) Close()

func (q *Queue[T]) Enqueue(value T) error

func (q *Queue[T]) Receive() chan []T

type QueueOption interface {
	// contains filtered or unexported methods
}

func WithFlushInterval(value time.Duration) QueueOption

func WithMemoryLimit(value int) QueueOption

func WithSizeLimit(value int) QueueOption

type QueueOptions struct {
	// contains filtered or unexported fields
}