Commit 8ee4675a authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent a059779e
...@@ -38,7 +38,11 @@ import ( ...@@ -38,7 +38,11 @@ import (
"lab.nexedi.com/kirr/neo/go/zodb" "lab.nexedi.com/kirr/neo/go/zodb"
) )
// XXX // Storage combines base and δ storages as if δ transactional log is logically
// appended to base.
//
// Base must remain unmodified, and all δ transactions must be with TIDs
// strictly after base.Head .
type Storage struct { type Storage struct {
base zodb.IStorageDriver base zodb.IStorageDriver
δ zodb.IStorageDriver δ zodb.IStorageDriver
...@@ -74,7 +78,7 @@ func (e *baseError) Error() string { ...@@ -74,7 +78,7 @@ func (e *baseError) Error() string {
func (e *baseError) Cause() error { return e.err } func (e *baseError) Cause() error { return e.err }
func (e *baseError) Unwrap() error { return e.err } func (e *baseError) Unwrap() error { return e.err }
// watcher detects base mutation and proxies δ events to user. // watcher detects base mutation and proxies δ events to user watchq.
// it runs as separate goroutine. // it runs as separate goroutine.
func (d *Storage) watcher(ctx context.Context) error { func (d *Storage) watcher(ctx context.Context) error {
if d.watchq != nil { if d.watchq != nil {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment