Documentation
¶
Overview ¶
Package seqobsv wants to supply an observable value sepcialized for sequence numbers in append-only logs. It should be fine for access from multiple goroutines.
These values only go up by one. For margaret they start with 0.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Observable ¶
type Observable struct {
// contains filtered or unexported fields
}
func (*Observable) Inc ¶
func (seq *Observable) Inc() uint64
func (*Observable) Seq ¶
func (seq *Observable) Seq() int64
func (*Observable) WaitFor ¶
func (seq *Observable) WaitFor(n uint64) <-chan struct{}
Source Files
Click to show internal directories.
Click to hide internal directories.