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

monitorConsumer perform snapshot similar to monitorStream

Browse Source 
Changed the stream min size default value back to 32MB and removed
the one for consumer since we don't use it anymore but set the
count size same than for stream (8192).

Signed-off-by: Ivan Kozlovic <ivan@synadia.com>
This commit is contained in:
Ivan Kozlovic
2021-03-05 19:01:01 -07:00
parent 9b80d55fad
commit 4e3b79f62b
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 {