fastqueue

Oct 1, 2023

Changes in this version

type Queue

+ func (q *Queue[T]) Finish()

+ func (q *Queue[T]) PushOne(data T)

+ func (q *Queue[T]) SetReadEvent(event func(data []T))

Jun 26, 2023

Changes in this version

+ const BUFFER_PAD

+ const SpinMask

+ var ErrMinimumReservationSize = errors.New("the minimum reservation size is 1 slot")

+ type Barrier interface

+ Load func() int64

+ func NewCompositeBarrier(sequences ...*Cursor) Barrier

+ type Consumer interface

+ Consume func(lower, upper int64)

+ type Cursor [8]int64

+ func NewCursor() *Cursor

+ func (this *Cursor) Load() int64

+ func (this *Cursor) Store(value int64)

+ type DefaultReader struct

+ func NewReader(current, written *Cursor, upstream Barrier, waiter WaitStrategy, ...) *DefaultReader

+ func (this *DefaultReader) Close() error

+ func (this *DefaultReader) Read()

+ type DefaultWaitStrategy struct

+ func NewWaitStrategy() DefaultWaitStrategy

+ func (this DefaultWaitStrategy) Gate(count int64)

+ func (this DefaultWaitStrategy) Idle(count int64)

+ type DefaultWriter struct

+ func NewWriter(written *Cursor, upstream Barrier, capacity int64) *DefaultWriter

+ func (this *DefaultWriter) Commit(_, upper int64)

+ func (this *DefaultWriter) Reserve(count int64) int64

+ type Disruptor struct

+ func NewDisruptor(options ...Option) Disruptor

+ type Option func(*Wireup)

+ func WithCapacity(value int64) Option

+ func WithConsumerGroup(value ...Consumer) Option

+ func WithWaitStrategy(value WaitStrategy) Option

+ type Queue struct

+ func NewQueue(max ...int) *Queue[T]

+ func (q *Queue[T]) Consume(lower, upper int64)

+ func (q *Queue[T]) Push(data ...T)

+ func (q *Queue[T]) SetEvent(event func(data []T))

+ func (q *Queue[T]) Wait()

+ type Reader interface

+ Close func() error

+ Read func()

+ type WaitStrategy interface

+ Gate func(int64)

+ Idle func(int64)

+ type Wireup struct

+ func NewWireup(options ...Option) (*Wireup, error)

+ func (this *Wireup) Build() (Writer, Reader)

+ type Writer interface

+ Commit func(lower, upper int64)

+ Reserve func(count int64) int64