Skip to content

Commit

Permalink
PR Feedback
Browse files Browse the repository at this point in the history
Signed-off-by: Jean-Noël Moyne <jnmoyne@gmail.com>
  • Loading branch information
jnmoyne committed Apr 29, 2024
1 parent 675e1cb commit 9c806c3
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions server/stream.go
Expand Up @@ -291,8 +291,8 @@ type stream struct {
syncSub *subscription // Internal subscription for sync messages (on "$JSC.SYNC").
infoSub *subscription // Internal subscription for stream info requests.
clMu sync.Mutex // The mutex for clseq and clfs.
clseq uint64 // The commit log current last sequence number.
clfs uint64 // The count of the commit log failed sequence numbers.
clseq uint64 // The current last seq being proposed to the NRG layer.
clfs uint64 // The count (offset) of the number of failed NRG sequences used to compute clseq.
inflight map[uint64]uint64 // Inflight message sizes per clseq.
leader string // The current leader for the RAFT group.
lqsent time.Time // The time at which the last lost quorum advisory was sent. Used to rate limit.
Expand Down

0 comments on commit 9c806c3

Please sign in to comment.