sequence

Documentation

Index

• Constants
• Variables
• func NewConsumer(bufferSize int) (ringbuffer.Sequencer, error)
• func NewProducer(bufferSize int) (ringbuffer.Sequencer, error)
• func NewSequence() *sequence
• type Consumer
  • func (this *Consumer) AddGatingSequence(seq ...ringbuffer.Sequencer)
  • func (this *Consumer) Commit(n int64) error
  • func (this *Consumer) Next(n int) (int64, error)
  • func (this *Consumer) RemoveGatingSequence(seq ringbuffer.Sequencer)
  • func (this *Consumer) Request(n int) (int64, error)
• type Producer
  • func (this *Producer) AddGatingSequence(seq ...ringbuffer.Sequencer)
  • func (this *Producer) Commit(n int64) error
  • func (this *Producer) Next(n int) (int64, error)
  • func (this *Producer) RemoveGatingSequence(seq ringbuffer.Sequencer)
  • func (this *Producer) Request(n int) (int64, error)

Constants

const (
	InitialSequenceValue = -1
)

Variables

var (
	ErrNotPositiveInteger = errors.New("sequence.sequencer: Not Positive Integer Value")
	ErrNotPowerOfTwo      = errors.New("ringbuffer.ByteBuffer: Slot Count Must Be Power of Two")
)

Functions

func NewConsumer

func NewConsumer(bufferSize int) (ringbuffer.Sequencer, error)

func NewProducer

func NewProducer(bufferSize int) (ringbuffer.Sequencer, error)

func NewSequence

func NewSequence() *sequence

Types

type Consumer

type Consumer struct {
	// contains filtered or unexported fields
}

func (*Consumer) AddGatingSequence

func (this *Consumer) AddGatingSequence(seq ...ringbuffer.Sequencer)

func (*Consumer) Commit

func (this *Consumer) Commit(n int64) error

func (*Consumer) Next

func (this *Consumer) Next(n int) (int64, error)

func (*Consumer) RemoveGatingSequence

func (this *Consumer) RemoveGatingSequence(seq ringbuffer.Sequencer)

func (*Consumer) Request

func (this *Consumer) Request(n int) (int64, error)

type Producer

type Producer struct {
	// contains filtered or unexported fields
}

func (*Producer) AddGatingSequence

func (this *Producer) AddGatingSequence(seq ...ringbuffer.Sequencer)

func (*Producer) Commit

func (this *Producer) Commit(n int64) error

func (*Producer) Next

func (this *Producer) Next(n int) (int64, error)

func (*Producer) RemoveGatingSequence

func (this *Producer) RemoveGatingSequence(seq ringbuffer.Sequencer)

func (*Producer) Request

func (this *Producer) Request(n int) (int64, error)