From 27717c26be64f144264fb4a6d27add48ea164ab5 Mon Sep 17 00:00:00 2001
From: Yun <yun@yun.ink>
Date: Sat, 4 Oct 2025 22:47:54 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A4=84=E7=90=86Leader=E7=9A=84key=E4=B8=BA?=
 =?UTF-8?q?=E7=A9=BA=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 cluster.go       | 6 +++---
 leader/leader.go | 1 +
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/cluster.go b/cluster.go
index c582da6..9bb00fc 100644
--- a/cluster.go
+++ b/cluster.go
@@ -9,8 +9,8 @@ import (
 	"sync"
 	"time"
 
-	"github.com/redis/go-redis/v9"
 	"github.com/google/uuid"
+	"github.com/redis/go-redis/v9"
 	"github.com/yuninks/cachex"
 	"github.com/yuninks/lockx"
 	"github.com/yuninks/timerx/heartbeat"
@@ -94,7 +94,7 @@ func InitCluster(ctx context.Context, red redis.UniversalClient, keyPrefix strin
 		pri, err := priority.InitPriority(
 			ctx,
 			red,
-			clu.priorityKey,
+			clu.keyPrefix,
 			op.priorityVal,
 			priority.WithLogger(clu.logger),
 			priority.WithInstanceId(clu.instanceId),
@@ -111,7 +111,7 @@ func InitCluster(ctx context.Context, red redis.UniversalClient, keyPrefix strin
 	le, err := leader.InitLeader(
 		ctx,
 		clu.redis,
-		keyPrefix,
+		clu.keyPrefix,
 		leader.WithLogger(clu.logger),
 		leader.WithPriority(clu.priority),
 		leader.WithInstanceId(clu.instanceId),
diff --git a/leader/leader.go b/leader/leader.go
index c05fafe..f325d98 100644
--- a/leader/leader.go
+++ b/leader/leader.go
@@ -53,6 +53,7 @@ func InitLeader(ctx context.Context, ref redis.UniversalClient, keyPrefix string
 		cancel:           cancel,
 		redis:            ref,
 		leaderUniLockKey: "timer:leader_lockKey" + op.source + keyPrefix,
+		leaderKey:        "timer:leader" + op.source + keyPrefix,
 		priority:         op.priority,
 		instanceId:       op.instanceId,
 		logger:           op.logger,