lfq

package module

Go to main page

Versions in this module

v0

v0.1.3

Feb 19, 2026

Changes in this version

type MPMC

+ func (q *MPMC[T]) Init(capacity int)

type MPMCCompactIndirect

+ func (q *MPMCCompactIndirect) Init(capacity int)

type MPMCIndirect

+ func (q *MPMCIndirect) Init(capacity int)

type MPMCIndirectSeq

+ func (q *MPMCIndirectSeq) Init(capacity int)

type MPMCPtr

+ func (q *MPMCPtr) Init(capacity int)

type MPMCPtrSeq

+ func (q *MPMCPtrSeq) Init(capacity int)

type MPMCSeq

+ func (q *MPMCSeq[T]) Init(capacity int)

type MPSC

+ func (q *MPSC[T]) Init(capacity int)

type MPSCCompactIndirect

+ func (q *MPSCCompactIndirect) Init(capacity int)

type MPSCIndirect

+ func (q *MPSCIndirect) Init(capacity int)

type MPSCIndirectSeq

+ func (q *MPSCIndirectSeq) Init(capacity int)

type MPSCPtr

+ func (q *MPSCPtr) Init(capacity int)

type MPSCPtrSeq

+ func (q *MPSCPtrSeq) Init(capacity int)

type MPSCSeq

+ func (q *MPSCSeq[T]) Init(capacity int)

type SPMC

+ func (q *SPMC[T]) Init(capacity int)

type SPMCCompactIndirect

+ func (q *SPMCCompactIndirect) Init(capacity int)

type SPMCIndirect

+ func (q *SPMCIndirect) Init(capacity int)

type SPMCIndirectSeq

+ func (q *SPMCIndirectSeq) Init(capacity int)

type SPMCPtr

+ func (q *SPMCPtr) Init(capacity int)

type SPMCPtrSeq

+ func (q *SPMCPtrSeq) Init(capacity int)

type SPMCSeq

+ func (q *SPMCSeq[T]) Init(capacity int)

type SPSC

+ func (q *SPSC[T]) Init(capacity int)

type SPSCIndirect

+ func (q *SPSCIndirect) Init(capacity int)

type SPSCPtr

+ func (q *SPSCPtr) Init(capacity int)

v0.1.2

Feb 17, 2026

v0.1.1

Feb 5, 2026

Changes in this version

+ type Drainer interface

+ Drain func()

type MPMC

+ func (q *MPMC[T]) Drain()

type MPMCIndirect

+ func (q *MPMCIndirect) Drain()

type MPMCPtr

+ func (q *MPMCPtr) Drain()

type MPSC

+ func (q *MPSC[T]) Drain()

type MPSCIndirect

+ func (q *MPSCIndirect) Drain()

type MPSCPtr

+ func (q *MPSCPtr) Drain()

type SPMC

+ func (q *SPMC[T]) Drain()

type SPMCIndirect

+ func (q *SPMCIndirect) Drain()

type SPMCPtr

+ func (q *SPMCPtr) Drain()

v0.1.0

Jan 28, 2026

v0.0.0

Jan 27, 2026

Changes in this version

+ const RaceEnabled

+ var ErrWouldBlock = iox.ErrWouldBlock

+ func IsNonFailure(err error) bool

+ func IsSemantic(err error) bool

+ func IsWouldBlock(err error) bool

+ type Builder struct

+ func New(capacity int) *Builder

+ func (b *Builder) BuildIndirect() QueueIndirect

+ func (b *Builder) BuildIndirectMPMC() QueueIndirect

+ func (b *Builder) BuildIndirectMPSC() QueueIndirect

+ func (b *Builder) BuildIndirectSPMC() QueueIndirect

+ func (b *Builder) BuildIndirectSPSC() *SPSCIndirect

+ func (b *Builder) BuildPtr() QueuePtr

+ func (b *Builder) BuildPtrMPMC() QueuePtr

+ func (b *Builder) BuildPtrMPSC() QueuePtr

+ func (b *Builder) BuildPtrSPMC() QueuePtr

+ func (b *Builder) BuildPtrSPSC() *SPSCPtr

+ func (b *Builder) Compact() *Builder

+ func (b *Builder) SingleConsumer() *Builder

+ func (b *Builder) SingleProducer() *Builder

+ type Consumer interface

+ Dequeue func() (T, error)

+ type ConsumerIndirect interface

+ Dequeue func() (uintptr, error)

+ type ConsumerPtr interface

+ Dequeue func() (unsafe.Pointer, error)

+ type MPMC struct

+ func NewMPMC[T any](capacity int) *MPMC[T]

+ func (q *MPMC[T]) Cap() int

+ func (q *MPMC[T]) Dequeue() (T, error)

+ func (q *MPMC[T]) Enqueue(elem *T) error

+ type MPMCCompactIndirect struct

+ func NewMPMCCompactIndirect(capacity int) *MPMCCompactIndirect

+ func (q *MPMCCompactIndirect) Cap() int

+ func (q *MPMCCompactIndirect) Dequeue() (uintptr, error)

+ func (q *MPMCCompactIndirect) Enqueue(elem uintptr) error

+ type MPMCIndirect struct

+ func NewMPMCIndirect(capacity int) *MPMCIndirect

+ func (q *MPMCIndirect) Cap() int

+ func (q *MPMCIndirect) Dequeue() (uintptr, error)

+ func (q *MPMCIndirect) Enqueue(elem uintptr) error

+ type MPMCIndirectSeq struct

+ func NewMPMCIndirectSeq(capacity int) *MPMCIndirectSeq

+ func (q *MPMCIndirectSeq) Cap() int

+ func (q *MPMCIndirectSeq) Dequeue() (uintptr, error)

+ func (q *MPMCIndirectSeq) Enqueue(elem uintptr) error

+ type MPMCPtr struct

+ func NewMPMCPtr(capacity int) *MPMCPtr

+ func (q *MPMCPtr) Cap() int

+ func (q *MPMCPtr) Dequeue() (unsafe.Pointer, error)

+ func (q *MPMCPtr) Enqueue(elem unsafe.Pointer) error

+ type MPMCPtrSeq struct

+ func NewMPMCPtrSeq(capacity int) *MPMCPtrSeq

+ func (q *MPMCPtrSeq) Cap() int

+ func (q *MPMCPtrSeq) Dequeue() (unsafe.Pointer, error)

+ func (q *MPMCPtrSeq) Enqueue(elem unsafe.Pointer) error

+ type MPMCSeq struct

+ func NewMPMCSeq[T any](capacity int) *MPMCSeq[T]

+ func (q *MPMCSeq[T]) Cap() int

+ func (q *MPMCSeq[T]) Dequeue() (T, error)

+ func (q *MPMCSeq[T]) Enqueue(elem *T) error

+ type MPSC struct

+ func NewMPSC[T any](capacity int) *MPSC[T]

+ func (q *MPSC[T]) Cap() int

+ func (q *MPSC[T]) Dequeue() (T, error)

+ func (q *MPSC[T]) Enqueue(elem *T) error

+ type MPSCCompactIndirect struct

+ func NewMPSCCompactIndirect(capacity int) *MPSCCompactIndirect

+ func (q *MPSCCompactIndirect) Cap() int

+ func (q *MPSCCompactIndirect) Dequeue() (uintptr, error)

+ func (q *MPSCCompactIndirect) Enqueue(elem uintptr) error

+ type MPSCIndirect struct

+ func NewMPSCIndirect(capacity int) *MPSCIndirect

+ func (q *MPSCIndirect) Cap() int

+ func (q *MPSCIndirect) Dequeue() (uintptr, error)

+ func (q *MPSCIndirect) Enqueue(elem uintptr) error

+ type MPSCIndirectSeq struct

+ func NewMPSCIndirectSeq(capacity int) *MPSCIndirectSeq

+ func (q *MPSCIndirectSeq) Cap() int

+ func (q *MPSCIndirectSeq) Dequeue() (uintptr, error)

+ func (q *MPSCIndirectSeq) Enqueue(elem uintptr) error

+ type MPSCPtr struct

+ func NewMPSCPtr(capacity int) *MPSCPtr

+ func (q *MPSCPtr) Cap() int

+ func (q *MPSCPtr) Dequeue() (unsafe.Pointer, error)

+ func (q *MPSCPtr) Enqueue(elem unsafe.Pointer) error

+ type MPSCPtrSeq struct

+ func NewMPSCPtrSeq(capacity int) *MPSCPtrSeq

+ func (q *MPSCPtrSeq) Cap() int

+ func (q *MPSCPtrSeq) Dequeue() (unsafe.Pointer, error)

+ func (q *MPSCPtrSeq) Enqueue(elem unsafe.Pointer) error

+ type MPSCSeq struct

+ func NewMPSCSeq[T any](capacity int) *MPSCSeq[T]

+ func (q *MPSCSeq[T]) Cap() int

+ func (q *MPSCSeq[T]) Dequeue() (T, error)

+ func (q *MPSCSeq[T]) Enqueue(elem *T) error

+ type Options struct

+ type Producer interface

+ Enqueue func(elem *T) error

+ type ProducerIndirect interface

+ Enqueue func(elem uintptr) error

+ type ProducerPtr interface

+ Enqueue func(elem unsafe.Pointer) error

+ type Queue interface

+ Cap func() int

+ func BuildMPMC[T any](b *Builder) Queue[T]

+ func BuildMPSC[T any](b *Builder) Queue[T]

+ func BuildSPMC[T any](b *Builder) Queue[T]

+ func Build[T any](b *Builder) Queue[T]

+ type QueueIndirect interface

+ Cap func() int

+ type QueuePtr interface

+ Cap func() int

+ type SPMC struct

+ func NewSPMC[T any](capacity int) *SPMC[T]

+ func (q *SPMC[T]) Cap() int

+ func (q *SPMC[T]) Dequeue() (T, error)

+ func (q *SPMC[T]) Enqueue(elem *T) error

+ type SPMCCompactIndirect struct

+ func NewSPMCCompactIndirect(capacity int) *SPMCCompactIndirect

+ func (q *SPMCCompactIndirect) Cap() int

+ func (q *SPMCCompactIndirect) Dequeue() (uintptr, error)

+ func (q *SPMCCompactIndirect) Enqueue(elem uintptr) error

+ type SPMCIndirect struct

+ func NewSPMCIndirect(capacity int) *SPMCIndirect

+ func (q *SPMCIndirect) Cap() int

+ func (q *SPMCIndirect) Dequeue() (uintptr, error)

+ func (q *SPMCIndirect) Enqueue(elem uintptr) error

+ type SPMCIndirectSeq struct

+ func NewSPMCIndirectSeq(capacity int) *SPMCIndirectSeq

+ func (q *SPMCIndirectSeq) Cap() int

+ func (q *SPMCIndirectSeq) Dequeue() (uintptr, error)

+ func (q *SPMCIndirectSeq) Enqueue(elem uintptr) error

+ type SPMCPtr struct

+ func NewSPMCPtr(capacity int) *SPMCPtr

+ func (q *SPMCPtr) Cap() int

+ func (q *SPMCPtr) Dequeue() (unsafe.Pointer, error)

+ func (q *SPMCPtr) Enqueue(elem unsafe.Pointer) error

+ type SPMCPtrSeq struct

+ func NewSPMCPtrSeq(capacity int) *SPMCPtrSeq

+ func (q *SPMCPtrSeq) Cap() int

+ func (q *SPMCPtrSeq) Dequeue() (unsafe.Pointer, error)

+ func (q *SPMCPtrSeq) Enqueue(elem unsafe.Pointer) error

+ type SPMCSeq struct

+ func NewSPMCSeq[T any](capacity int) *SPMCSeq[T]

+ func (q *SPMCSeq[T]) Cap() int

+ func (q *SPMCSeq[T]) Dequeue() (T, error)

+ func (q *SPMCSeq[T]) Enqueue(elem *T) error

+ type SPSC struct

+ func BuildSPSC[T any](b *Builder) *SPSC[T]

+ func NewSPSC[T any](capacity int) *SPSC[T]

+ func (q *SPSC[T]) Cap() int

+ func (q *SPSC[T]) Dequeue() (T, error)

+ func (q *SPSC[T]) Enqueue(elem *T) error

+ type SPSCIndirect struct

+ func NewSPSCIndirect(capacity int) *SPSCIndirect

+ func (q *SPSCIndirect) Cap() int

+ func (q *SPSCIndirect) Dequeue() (uintptr, error)

+ func (q *SPSCIndirect) Enqueue(elem uintptr) error

+ type SPSCPtr struct

+ func NewSPSCPtr(capacity int) *SPSCPtr

+ func (q *SPSCPtr) Cap() int

+ func (q *SPSCPtr) Dequeue() (unsafe.Pointer, error)

+ func (q *SPSCPtr) Enqueue(elem unsafe.Pointer) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL