gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-17 03:24:40 -07:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #1972 from nats-io/change_cons_snapshot

Browse Source 
monitorConsumer perform snapshot similar to monitorStream
This commit is contained in:
Derek Collison
2021-03-05 21:47:15 -07:00
committed by GitHub
parent 9b80d55fad 4e3b79f62b
commit 6d9cb21648
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
server/jetstream_cluster.go
View File

@@ -1254,7 +1254,7 @@ func (js *jetStream) monitorStream(mset *stream, sa *streamAssignment) {
const (
compactInterval = 2 * time.Minute
compactSizeMin = 64 * 1024 * 1024
compactSizeMin = 32 * 1024 * 1024
compactNumMin = 8192
)
@@ -2538,8 +2538,7 @@ func (js *jetStream) monitorConsumer(o *consumer, ca *consumerAssignment) {
const (
compactInterval = 2 * time.Minute
compactSizeMin = 4 * 1024 * 1024
compactNumMin = 4
compactNumMin = 8192
)
t := time.NewTicker(compactInterval)
@@ -2577,8 +2576,8 @@ func (js *jetStream) monitorConsumer(o *consumer, ca *consumerAssignment) {
if err := js.applyConsumerEntries(o, ce, isLeader); err == nil {
n.Applied(ce.Index)
ne := ce.Index - lastApplied
// If over our compact min and we have at least min entries to compact, go ahead and snapshot/compact.
if _, b := n.Size(); b > compactSizeMin && ne > compactNumMin {
// If we have at least min entries to compact, go ahead and snapshot/compact.
if ne >= compactNumMin {
doSnapshot()
}
} else {