Skip to content

Commit

Permalink
feat(ARCO-291): Do not allow buffer size larger than 10k
Browse files Browse the repository at this point in the history
  • Loading branch information
boecklim committed Jan 31, 2025
1 parent 69a89de commit 1eaf2df
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions internal/callbacker/send_manager/send_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,10 @@ func WithNow(nowFunc func() time.Time) func(*SendManager) {

func WithBufferSize(size int) func(*SendManager) {
return func(m *SendManager) {
if size >= entriesBufferSize {
m.bufferSize = entriesBufferSize
return
}
m.bufferSize = size
}
}
Expand Down

0 comments on commit 1eaf2df

Please sign in to comment.