Skip to content

Commit

Permalink
enable congestion control for AWS
Browse files Browse the repository at this point in the history
  • Loading branch information
sandeepsukhani committed Jul 29, 2024
1 parent 0b5e5f9 commit 325ceb7
Showing 1 changed file with 3 additions and 0 deletions.
3 changes: 3 additions & 0 deletions pkg/storage/factory.go
Original file line number Diff line number Diff line change
Expand Up @@ -488,6 +488,9 @@ func NewChunkClient(name string, cfg Config, schemaCfg config.SchemaConfig, cc c
if err != nil {
return nil, err
}
if cfg.CongestionControl.Enabled {
c = cc.Wrap(c)
}
return client.NewClientWithMaxParallel(c, nil, cfg.MaxParallelGetChunk, schemaCfg), nil

case types.StorageTypeGCS:
Expand Down

0 comments on commit 325ceb7

Please sign in to comment.