sequencer

Documentation

Index

• Variables
• type Sequencer
  • func NewNoopSequencer(channelDepth int) Sequencer
  • func NewSingleWriterSeq(maxOutOfOrder uint32) Sequencer

Variables

var ErrClosed = errors.New("sequencer closed")

var ErrTimedOut = errors.New("operation timed out")

Types

type Sequencer

type Sequencer interface {
	PutSequenced(seq uint32, v interface{}) error
	GetNext() interface{}
	GetNextWithDeadline(t time.Time) (interface{}, error)
	Close()
}

this is simple queue which sorts items according to their sequence number and waits until sequence can be completed without gaps

func NewNoopSequencer

func NewNoopSequencer(channelDepth int) Sequencer

func NewSingleWriterSeq

func NewSingleWriterSeq(maxOutOfOrder uint32) Sequencer