Skip to content

Commit 42f1c47

Browse files
committed
fix: apply S2Config documented defaults when zero values are passed
1 parent ab5d8ba commit 42f1c47

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

server/lib/events/s2storage.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -58,6 +58,12 @@ func NewS2Storage(ctx context.Context, basin, accessToken, streamName string, cf
5858
return nil, fmt.Errorf("s2storage: open append session: %w", err)
5959
}
6060

61+
if cfg.BatcherLinger == 0 {
62+
cfg.BatcherLinger = 100 * time.Millisecond
63+
}
64+
if cfg.BatcherMaxRecords == 0 {
65+
cfg.BatcherMaxRecords = 50
66+
}
6167
batcher := s2.NewBatcher(ctx, &s2.BatchingOptions{
6268
Linger: cfg.BatcherLinger,
6369
MaxRecords: cfg.BatcherMaxRecords,

0 commit comments

Comments
 (0)