summaryrefslogtreecommitdiff
path: root/internal/failover/failover.go
diff options
context:
space:
mode:
Diffstat (limited to 'internal/failover/failover.go')
-rw-r--r--internal/failover/failover.go7
1 files changed, 2 insertions, 5 deletions
diff --git a/internal/failover/failover.go b/internal/failover/failover.go
index 31fb2b0..1c4c32e 100644
--- a/internal/failover/failover.go
+++ b/internal/failover/failover.go
@@ -10,9 +10,6 @@ const (
// Send a ping every 2 seconds to the gateway
pInterval time.Duration = 2 * time.Second
- // pAlive is how many pings we need to have sent to check if the connection is alive
- pAlive int = 3
-
// pDropped is how many pings we need to have sent to check if the connection is dropped
pDropped int = 5
)
@@ -20,6 +17,6 @@ const (
// New creates a failover monitor for the gateway and the rx bytes function reader
// This is a simple wrapper over `NewDroppedMonitor` to create one with the default settings
// If this function returns True, the connection is dropped. False means it has exited and we don't know for sure if it's dropped or not
-func New(readRxBytes func() (int64, error), logger log.FileLogger) (*DroppedConMon, error) {
- return NewDroppedMonitor(pInterval, pAlive, pDropped, readRxBytes, logger)
+func New(readRxBytes func() (int64, error), logger log.FileLogger) *DroppedConMon {
+ return NewDroppedMonitor(pInterval, pDropped, readRxBytes, logger)
}