fix: ConcurrentRevisionWatch for postgres

Author: miparnisari

internal/datastore/crdb/watch.go

@@ -74,7 +74,7 @@ func (cds *crdbDatastore) DefaultsWatchOptions() datastore.WatchOptions {
 		WatchBufferLength:              128,
 		WatchBufferWriteTimeout:        1 * time.Second,
 		WatchConnectTimeout:            1 * time.Second,
-		MaximumBufferedChangesByteSize: 1024,
+		MaximumBufferedChangesByteSize: 0, // 0 means no limit
 	}
 }
 

internal/datastore/mysql/watch.go

@@ -21,7 +21,7 @@ func (mds *mysqlDatastore) DefaultsWatchOptions() datastore.WatchOptions {
 	return datastore.WatchOptions{
 		WatchBufferLength:              defaultWatchBufferLength,
 		WatchBufferWriteTimeout:        defaultWatchBufferWriteTimeout,
-		MaximumBufferedChangesByteSize: 1204,
+		MaximumBufferedChangesByteSize: 0, // 0 means no limit
 		// MySQL does not use CheckpointInterval or WatchConnectTimeout
 		// MySQL does not support EmitImmediatelyStrategy or WatchSchema
 	}

internal/datastore/postgres/watch.go

@@ -29,7 +29,7 @@ func (pgd *pgDatastore) DefaultsWatchOptions() datastore.WatchOptions {
 		CheckpointInterval:             minimumWatchSleep,
 		WatchBufferLength:              defaultWatchBufferLength,
 		WatchBufferWriteTimeout:        defaultWatchBufferWriteTimeout,
-		MaximumBufferedChangesByteSize: 1024,
+		MaximumBufferedChangesByteSize: 0, // 0 means no limit
 		// Postgres does not use WatchConnectTimeout
 		// Postgres does not support EmitImmediatelyStrategy
 	}

internal/datastore/spanner/watch.go

@@ -58,7 +58,7 @@ func (sd *spannerDatastore) DefaultsWatchOptions() datastore.WatchOptions {
 		CheckpointInterval:             100 * time.Millisecond,
 		WatchBufferLength:              defaultWatchBufferLength,
 		WatchBufferWriteTimeout:        defaultWatchBufferWriteTimeout,
-		MaximumBufferedChangesByteSize: 1024,
+		MaximumBufferedChangesByteSize: 0, // 0 means no limit
 		// Spanner does not use WatchConnectTimeout
 		// Spanner does not support EmitImmediatelyStrategy
 	}