Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrClosed = errors.New("sequencer closed")
View Source
var ErrTimedOut = errors.New("operation timed out")
Functions ¶
This section is empty.
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 NewSingleWriterSeq ¶
Source Files
Click to show internal directories.
Click to hide internal directories.