Documentation ¶ Index ¶ type IQueue type Queue func New[T any](maxSize int) *Queue[T] func (q *Queue[T]) DeQueue(ctx context.Context) (data T, err error) func (q *Queue[T]) EnQueue(ctx context.Context, data T) error func (q *Queue[T]) IsEmpty() bool func (q *Queue[T]) IsFull() bool func (q *Queue[T]) Len() uint64 Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type IQueue ¶ type IQueue interface { EnQueue(ctx context.Context, data any) error DeQueue(ctx context.Context) (data any, err error) IsFull() bool IsEmpty() bool Len() uint64 } type Queue ¶ type Queue[T any] struct { // contains filtered or unexported fields } func New ¶ func New[T any](maxSize int) *Queue[T] func (*Queue[T]) DeQueue ¶ func (q *Queue[T]) DeQueue(ctx context.Context) (data T, err error) func (*Queue[T]) EnQueue ¶ func (q *Queue[T]) EnQueue(ctx context.Context, data T) error func (*Queue[T]) IsEmpty ¶ func (q *Queue[T]) IsEmpty() bool func (*Queue[T]) IsFull ¶ func (q *Queue[T]) IsFull() bool func (*Queue[T]) Len ¶ func (q *Queue[T]) Len() uint64 Source Files ¶ View all Source files queue.go types.go Click to show internal directories. Click to hide internal directories.