seqobsv

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

• type Observable
  • func New(start uint64) *Observable
  • func (seq *Observable) Inc() uint64
  • func (seq *Observable) Seq() int64
  • func (seq *Observable) Value() uint64
  • func (seq *Observable) WaitFor(n uint64) <-chan struct{}

Types

type Observable

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

func New

func New(start uint64) *Observable

New creates a new Observable

func (*Observable) Inc

func (seq *Observable) Inc() uint64

func (*Observable) Seq

func (seq *Observable) Seq() int64

func (*Observable) Value

func (seq *Observable) Value() uint64

Value returns the current value

func (*Observable) WaitFor

func (seq *Observable) WaitFor(n uint64) <-chan struct{}