Increase claim scheduling and defaulting max jitter to 1.5 seconds
200ms seems low enough that GCP consistently beats Azure when scheduling RedisCluster claims in my experiments. Signed-off-by: Nic Cope <negz@rk0n.org>
This commit is contained in:
parent
eb0bb8b34f
commit
a81fb19350
|
|
@ -34,8 +34,9 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
claimDefaultingControllerName = "resourceclaimdefaulter.crossplane.io"
|
claimDefaultingControllerName = "resourceclaimdefaulter.crossplane.io"
|
||||||
claimDefaultingReconcileTimeout = 1 * time.Minute
|
claimDefaultingReconcileTimeout = 1 * time.Minute
|
||||||
|
claimDefaultingReconcileMaxJitterMs = 1500
|
||||||
)
|
)
|
||||||
|
|
||||||
// A ClaimDefaultingReconciler reconciles resource claims by setting their
|
// A ClaimDefaultingReconciler reconciles resource claims by setting their
|
||||||
|
|
@ -75,7 +76,7 @@ func NewClaimDefaultingReconciler(m manager.Manager, of ClaimKind, to ClassKind,
|
||||||
classKind: to,
|
classKind: to,
|
||||||
jitter: func() {
|
jitter: func() {
|
||||||
random := rand.New(rand.NewSource(time.Now().UnixNano()))
|
random := rand.New(rand.NewSource(time.Now().UnixNano()))
|
||||||
time.Sleep(time.Duration(random.Intn(200)) * time.Millisecond)
|
time.Sleep(time.Duration(random.Intn(claimDefaultingReconcileMaxJitterMs)) * time.Millisecond)
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -33,8 +33,9 @@ import (
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
claimSchedulingControllerName = "resourceclaimscheduler.crossplane.io"
|
claimSchedulingControllerName = "resourceclaimscheduler.crossplane.io"
|
||||||
claimSchedulingReconcileTimeout = 1 * time.Minute
|
claimSchedulingReconcileTimeout = 1 * time.Minute
|
||||||
|
claimSchedulingReconcileMaxJitterMs = 1500
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
const (
|
||||||
|
|
@ -85,7 +86,7 @@ func NewClaimSchedulingReconciler(m manager.Manager, of ClaimKind, to ClassKind,
|
||||||
classKind: to,
|
classKind: to,
|
||||||
jitter: func() {
|
jitter: func() {
|
||||||
random := rand.New(rand.NewSource(time.Now().UnixNano()))
|
random := rand.New(rand.NewSource(time.Now().UnixNano()))
|
||||||
time.Sleep(time.Duration(random.Intn(200)) * time.Millisecond)
|
time.Sleep(time.Duration(random.Intn(claimSchedulingReconcileMaxJitterMs)) * time.Millisecond)
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue