add extend interval

castaneai · Dec 25, 2023 · 7488550 · 7488550
1 parent df0698a
commit 7488550
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/loadtest/cmd/backend/main.go b/loadtest/cmd/backend/main.go
@@ -90,7 +90,8 @@ func newRedisStateStore(conf *config) (statestore.StateStore, error) {
 		opts = append(opts, statestore.WithSeparatedAssignmentRedis(asRedis))
 	}
 	locker, err := rueidislock.NewLocker(rueidislock.LockerOption{
-		ClientOption: copt,
+		ClientOption:   copt,
+		ExtendInterval: 200 * time.Millisecond,
 	})
 	if err != nil {
 		return nil, fmt.Errorf("failed to new rueidis locker: %w", err)