Struct Store

src/pkg/store/store.go:43–55

Applies mutations sent on Ops in sequence according to field Seqn. Any errors that occur will be written to ErrorPath. Duplicate operations at a given position are sliently ignored.

// errors that occur will be written to ErrorPath. Duplicate operations at a
// given position are sliently ignored.
type Store struct {
	Ops     chan<- Op
	Seqns   <-chan int64
	Waiting <-chan int
	watchCh chan *watch
	watches []*watch
	todo    *vector.Vector
	state   *state
	head    int64
	log     map[int64]Event
	cleanCh chan int64
	flush   chan bool
}

// Represents an operation to apply to the store at position Seqn.
//