10757112177

Committed 07 Sep 2024 06:55PM UTC coverage: 85.271% (+0.03%) from 85.241%

Build # 10757112177

Build Type

push

github

Committed by

web-flow

Commit Message

Stream ingest rate limiting (#5796)

Built on top of #5575. Tries to prevent the stream `msgs` queue from
becoming overwhelmed by core NATS publishes. In this case, where a reply
subject is known, the sender will receive a 429 "Too Many Requests".
Otherwise it's rate-logged.

Two new configuration options are added to the JetStream block:
`max_buffered_size` and `max_buffered_msgs`. If not configured, defaults
are used.

Signed-off-by: Neil Twigg <neil@nats.io>

Signed-off-by: Neil Twigg <neil@nats.io>

Run Details

66577 of 78077 relevant lines covered (85.27%)

1283216.94 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

70.43

/src/github.com/nats-io/nats-server/server/jetstream_api.go

Source Not Available

The file "src/github.com/nats-io/nats-server/server/jetstream_api.go" isn't available on github. Either it's been removed, or the repo root directory needs to be updated.

nats-io / nats-server / 10757112177

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source Not Available

Source File
Press 'n' to go to next uncovered line, 'b' for previous