diff --git a/pubsublite/internal/wire/settings.go b/pubsublite/internal/wire/settings.go index d4f97bf63fb..6bfe7dc3b11 100644 --- a/pubsublite/internal/wire/settings.go +++ b/pubsublite/internal/wire/settings.go @@ -82,7 +82,7 @@ var DefaultPublishSettings = PublishSettings{ DelayThreshold: 10 * time.Millisecond, CountThreshold: 100, ByteThreshold: 1e6, - Timeout: 10 * time.Minute, + Timeout: 60 * time.Minute, // By default set to a high limit that is not likely to occur, but prevents // OOM errors in clients. BufferedByteLimit: 1 << 30, // 1 GiB @@ -146,7 +146,7 @@ type ReceiveSettings struct { var DefaultReceiveSettings = ReceiveSettings{ MaxOutstandingMessages: 1000, MaxOutstandingBytes: 1e9, - Timeout: 10 * time.Minute, + Timeout: 60 * time.Minute, } func validateReceiveSettings(settings ReceiveSettings) error { diff --git a/pubsublite/pscompat/settings.go b/pubsublite/pscompat/settings.go index ea4fdd40f9a..cb05b0a276a 100644 --- a/pubsublite/pscompat/settings.go +++ b/pubsublite/pscompat/settings.go @@ -106,7 +106,7 @@ var DefaultPublishSettings = PublishSettings{ DelayThreshold: 10 * time.Millisecond, CountThreshold: 100, ByteThreshold: 1e6, - Timeout: 60 * time.Second, + Timeout: 60 * time.Minute, BufferedByteLimit: 1e8, } @@ -206,7 +206,7 @@ type ReceiveSettings struct { var DefaultReceiveSettings = ReceiveSettings{ MaxOutstandingMessages: 1000, MaxOutstandingBytes: 1e9, - Timeout: 60 * time.Second, + Timeout: 60 * time.Minute, } func (s *ReceiveSettings) toWireSettings() wire.ReceiveSettings {