Skip to content

Commit

Permalink
fix regression in periodic stream position check
Browse files Browse the repository at this point in the history
  • Loading branch information
FZambia committed Feb 25, 2022
1 parent b20db4f commit 487cdf8
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 0 deletions.
5 changes: 5 additions & 0 deletions changelog.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,8 @@
v0.21.1
=======

* Fix regression of v0.21.0: periodic stream position check was off due to missing zero value in `Config`.

v0.21.0
=======

Expand Down
1 change: 1 addition & 0 deletions config.go
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,7 @@ type Config struct {
HistoryMaxPublicationLimit int
// RecoveryMaxPublicationLimit allows limiting the number of Publications that could be
// restored during the automatic recovery process. See also HistoryMaxPublicationLimit.
// By default, no limit used.
RecoveryMaxPublicationLimit int
// UseSingleFlight allows turning on mode where singleflight will be automatically used for
// Node.History (including recovery) and Node.Presence/Node.PresenceStats calls.
Expand Down
3 changes: 3 additions & 0 deletions node.go
Original file line number Diff line number Diff line change
Expand Up @@ -94,6 +94,9 @@ func New(c Config) (*Node, error) {
if c.ClientPresenceUpdateInterval == 0 {
c.ClientPresenceUpdateInterval = 27 * time.Second
}
if c.ClientChannelPositionCheckDelay == 0 {
c.ClientChannelPositionCheckDelay = 40 * time.Second
}
if c.ClientExpiredCloseDelay == 0 {
c.ClientExpiredCloseDelay = 25 * time.Second
}
Expand Down

0 comments on commit 487cdf8

Please sign in to comment.