Versions in this module Expand all Collapse all v0 v0.8.1 Sep 14, 2025 v0.8.0 Sep 14, 2025 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[T any](max ...int) *Queue[T] + func (q *Queue[T]) Consume(lower, upper int64) + func (q *Queue[T]) Finish() + func (q *Queue[T]) Push(data ...T) + func (q *Queue[T]) PushOne(data T) + func (q *Queue[T]) SetReadEvent(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
Go to main page