@@ -47,17 +47,21 @@ const (
47
47
ClusterRoles
48
48
ClusterRoleBindings
49
49
50
- numHAPodsWithScheduler = 16
51
- numHAPodsOld = 13
52
- numNonHAPodsWithScheduler = 6
53
- numNonHAPodsOld = 5
50
+ numHAPodsWithScheduler = 16
51
+ numHAPodsOld = 13
52
+ numNonHAPodsWithHAScheduler = 8
53
+ numNonHAPodsWithScheduler = 6
54
+ numNonHAPodsOld = 5
54
55
55
56
thirdPartyDevNamespace = "default"
56
57
devRedisReleaseName = "dapr-dev-redis"
57
58
devZipkinReleaseName = "dapr-dev-zipkin"
58
59
)
59
60
60
- var VersionWithScheduler = semver .MustParse ("1.14.0-rc.1" )
61
+ var (
62
+ VersionWithScheduler = semver .MustParse ("1.14.0-rc.1" )
63
+ VersionWithHAScheduler = semver .MustParse ("1.15.0-rc.1" )
64
+ )
61
65
62
66
type VersionDetails struct {
63
67
RuntimeVersion string
@@ -1232,23 +1236,26 @@ func getVersionedNumberOfPods(isHAEnabled bool, details VersionDetails) (int, er
1232
1236
return 0 , err
1233
1237
}
1234
1238
1235
- if rv .LessThan (VersionWithScheduler ) {
1236
- return numHAPodsOld , nil
1239
+ if rv .GreaterThanEqual (VersionWithScheduler ) {
1240
+ return numHAPodsWithScheduler , nil
1237
1241
}
1238
- return numHAPodsWithScheduler , nil
1242
+ return numHAPodsOld , nil
1239
1243
} else {
1240
1244
if details .UseDaprLatestVersion {
1241
- return numNonHAPodsWithScheduler , nil
1245
+ return numNonHAPodsWithHAScheduler , nil
1242
1246
}
1243
1247
rv , err := semver .NewVersion (details .RuntimeVersion )
1244
1248
if err != nil {
1245
1249
return 0 , err
1246
1250
}
1247
1251
1248
- if rv .LessThan (VersionWithScheduler ) {
1249
- return numNonHAPodsOld , nil
1252
+ if rv .GreaterThanEqual (VersionWithHAScheduler ) {
1253
+ return numNonHAPodsWithHAScheduler , nil
1254
+ }
1255
+ if rv .GreaterThanEqual (VersionWithScheduler ) {
1256
+ return numNonHAPodsWithScheduler , nil
1250
1257
}
1251
- return numNonHAPodsWithScheduler , nil
1258
+ return numNonHAPodsOld , nil
1252
1259
}
1253
1260
}
1254
1261
0 commit comments