.

go/neo/client.go

@@ -508,6 +508,9 @@ func openClientByURL(ctx context.Context, u *url.URL, opt *zodb.DriverOptions) (
 	}
 
 	// XXX handle opt.WatchQ
+	if opt.WatchQ != nil {
+		panic("TODO watchq")
+	}
 
 	// XXX check/use other url fields
 	net := xnet.NetPlain("tcp")	// TODO + TLS; not only "tcp" ?

go/zodb/storage/zeo/zeo.go

@@ -311,6 +311,9 @@ func openByURL(ctx context.Context, u *url.URL, opt *zodb.DriverOptions) (_ zodb
 	}
 
 	// XXX handle opt.WatchQ
+	if opt.WatchQ != nil {
+		panic("TODO watchq")
+	}
 
 	zl, err := dialZLink(ctx, net, addr)	// XXX + methodTable
 	if err != nil {

go/zodb/zodb.go

@@ -352,8 +352,6 @@ type Prefetcher interface {
 }
 
 // IStorageDriver is the raw interface provided by ZODB storage drivers.
-//
-// A storage driver is created by DriverOpener
 type IStorageDriver interface {
 	// URL returns URL of how the storage was opened
 	URL() string
@@ -368,7 +366,11 @@ type IStorageDriver interface {
 
 	Loader
 	Iterator
-/*
+
+	// A storage driver also delivers database change events to watchq
+	// channel, which is passed to it when the driver is created.
+
+/* XXX kill
 	Watcher
 
 	// Notifier returns storage driver notifier.