queue

Documentation

Index

• type ChannelQueue
  • func NewChannelQueue[T any](channel chan T) *ChannelQueue[T]
  • func (q *ChannelQueue[T]) Close()
  • func (q *ChannelQueue[T]) Get() (T, error)
  • func (q *ChannelQueue[T]) Put(item T) error
  • func (q *ChannelQueue[T]) Size() (int64, error)
• type Queue

Types

type ChannelQueue

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

func NewChannelQueue

func NewChannelQueue[T any](channel chan T) *ChannelQueue[T]

func (*ChannelQueue[T]) Close

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

func (*ChannelQueue[T]) Get

func (q *ChannelQueue[T]) Get() (T, error)

func (*ChannelQueue[T]) Put

func (q *ChannelQueue[T]) Put(item T) error

func (*ChannelQueue[T]) Size

func (q *ChannelQueue[T]) Size() (int64, error)

type Queue

type Queue[T any] interface {
	Put(item T) error
	Get() (T, error)
	Size() (int64, error)
	Close()
}