We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 803df1a commit 82c7891Copy full SHA for 82c7891
pkg/stream/client.go
@@ -414,7 +414,7 @@ func (c *Client) DeleteStream(streamName string) error {
414
415
func (c *Client) heartBeat() {
416
ticker := time.NewTicker(time.Duration(c.tuneState.requestedHeartbeat) * time.Second)
417
- tickerHeatBeat := time.NewTicker(time.Duration(c.tuneState.requestedHeartbeat-2) * time.Second)
+ tickerHeartbeat := time.NewTicker(time.Duration(c.tuneState.requestedHeartbeat-2) * time.Second)
418
419
resp := c.coordinator.NewResponseWitName("heartbeat")
420
var heartBeatMissed int32
0 commit comments