diff --git a/operator/redisfailover/factory.go b/operator/redisfailover/factory.go index 9d19fbecb..d164e2947 100644 --- a/operator/redisfailover/factory.go +++ b/operator/redisfailover/factory.go @@ -41,8 +41,14 @@ func New(cfg Config, k8sService k8s.Services, k8sClient kubernetes.Interface, lo rfRetriever := NewRedisFailoverRetriever(cfg, k8sService) kooperLogger := kooperlogger{Logger: logger.WithField("operator", "redisfailover")} + + lockCfg := &leaderelection.LockConfig{ + LeaseDuration: 60 * time.Second, + RenewDeadline: 55 * time.Second, + RetryPeriod: 2 * time.Second, + } // Leader election service. - leSVC, err := leaderelection.NewDefault(lockKey, lockNamespace, k8sClient, kooperLogger) + leSVC, err := leaderelection.New(lockKey, lockNamespace, lockCfg, k8sClient, kooperLogger) if err != nil { return nil, err }