bzqueue

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

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