16435002168
83%

Ran 22 Jul 2025 05:53AM UTC

Jobs 1

Files 59

Run time 1min

Badge

Embed ▾

Committed 21 Jul 2025 04:05PM UTC coverage: 85.791% (+0.06%) from 85.736%

Build # 16435002168

Build Type

push

github

Committed by

web-flow

Commit Message

(2.12) Stream leader should propose consumer remaps once assignment processed (#7071)

Right now, in a stream scale up/scale down scenario where there are
consumers that also need to be scaled, the metaleader makes a proposal
to update the stream and then immediately makes proposals to update the
consumers. However, this does not account for the fact that the stream
proposal _could_ fail to be applied, which is where we have sometimes
seen peer set drifts.

This moves this logic to take place on the stream leader once the stream
update proposal is applied instead.

This will also be necessary in a world where the consumer assignments
are managed by the stream leader, as the metaleader will not know
anything about the stream NRG.

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

Run Details

71148 of 82932 relevant lines covered (85.79%)

344990.82 hits per line

Uncovered Existing Lines

Lines	Coverage	∆	File
2	88.24	0.77%	src/github.com/nats-io/nats-server/server/consumer.go
2	94.12	0.57%	src/github.com/nats-io/nats-server/server/sdm.go
3	90.92	0.12%	src/github.com/nats-io/nats-server/server/leafnode.go
3	81.33	0.09%	src/github.com/nats-io/nats-server/server/opts.go
4	84.25	0.76%	src/github.com/nats-io/nats-server/server/filestore.go
4	53.6	0.0%	src/github.com/nats-io/nats-server/server/jetstream_errors_generated.go
6	86.49	-0.05%	src/github.com/nats-io/nats-server/server/events.go
6	94.38	-0.24%	src/github.com/nats-io/nats-server/server/gateway.go
7	93.67	-0.2%	src/github.com/nats-io/nats-server/server/route.go
8	72.96	-0.09%	src/github.com/nats-io/nats-server/server/jetstream_api.go
9	86.52	-0.18%	src/github.com/nats-io/nats-server/server/accounts.go
21	78.95	-0.19%	src/github.com/nats-io/nats-server/server/jwt.go
39	85.55	-0.77%	src/github.com/nats-io/nats-server/server/raft.go
76	94.44	0.01%	src/github.com/nats-io/nats-server/server/server.go
570	86.19	0.36%	src/github.com/nats-io/nats-server/server/stream.go
934	80.92	-0.62%	src/github.com/nats-io/nats-server/server/jetstream_cluster.go

Jobs

ID	Job ID	Ran	Files	Coverage
1	16435002168.1	22 Jul 2025 05:53AM UTC	59	85.79	GitHub Action Run

nats-io / nats-server / 16435002168
83%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

Uncovered Existing Lines

Jobs

Source Files on build 16435002168

nats-io / nats-server / 16435002168 83%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

Uncovered Existing Lines

Jobs

Source Files on build 16435002168

nats-io / nats-server / 16435002168
83%

README BADGES
x