mirror of
https://github.com/fluxcd/flagger.git
synced 2026-04-09 12:17:27 +00:00
56b6339f8c
This adds a new Checksum field to the canary webhook body, which is a hash of the LastAppliedSpec and TrackedConfigs. This can be used to identify the rollout of a specific configuration, and differentiate between webhooks being sent for different configuration and deployment versions. Signed-off-by: Kevin McDermott <kevin@weave.works>
66 lines
1.8 KiB
Go
66 lines
1.8 KiB
Go
/*
|
|
Copyright 2020 The Flux authors
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package canary
|
|
|
|
import (
|
|
"fmt"
|
|
"hash/fnv"
|
|
|
|
"github.com/davecgh/go-spew/spew"
|
|
"k8s.io/apimachinery/pkg/util/rand"
|
|
|
|
flaggerv1 "github.com/fluxcd/flagger/pkg/apis/flagger/v1beta1"
|
|
)
|
|
|
|
// hasSpecChanged computes the hash of the spec and compares it with the
|
|
// last applied spec, if the last applied hash is different but not equal
|
|
// to last promoted one the it returns true
|
|
func hasSpecChanged(cd *flaggerv1.Canary, spec interface{}) (bool, error) {
|
|
if cd.Status.LastAppliedSpec == "" {
|
|
return true, nil
|
|
}
|
|
|
|
newHash := ComputeHash(spec)
|
|
|
|
// do not trigger a canary deployment on manual rollback
|
|
if cd.Status.LastPromotedSpec == newHash {
|
|
return false, nil
|
|
}
|
|
|
|
if cd.Status.LastAppliedSpec != newHash {
|
|
return true, nil
|
|
}
|
|
|
|
return false, nil
|
|
}
|
|
|
|
// ComputeHash returns a hash value calculated from a spec using the spew library
|
|
// which follows pointers and prints actual values of the nested objects
|
|
// ensuring the hash does not change when a pointer changes.
|
|
func ComputeHash(spec interface{}) string {
|
|
hasher := fnv.New32a()
|
|
printer := spew.ConfigState{
|
|
Indent: " ",
|
|
SortKeys: true,
|
|
DisableMethods: true,
|
|
SpewKeys: true,
|
|
}
|
|
printer.Fprintf(hasher, "%#v", spec)
|
|
|
|
return rand.SafeEncodeString(fmt.Sprint(hasher.Sum32()))
|
|
}
|