-
Notifications
You must be signed in to change notification settings - Fork 2.7k
/
versioncheck.go
57 lines (44 loc) · 1.64 KB
/
versioncheck.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
// SPDX-License-Identifier: Apache-2.0
// Copyright Authors of Cilium
package envoy
import (
"errors"
"fmt"
"strings"
"github.com/cilium/cilium/pkg/time"
)
// requiredEnvoyVersionSHA is set during build
// Running Envoy version will be checked against `requiredEnvoyVersionSHA`.
// By default, cilium-agent will fail to start if there is a version mismatch.
var requiredEnvoyVersionSHA string
func checkEnvoyVersion(envoyVersionFunc func() (string, error)) error {
envoyVersion, err := envoyVersionFunc()
if err != nil {
return fmt.Errorf("failed to retrieve Envoy version: %w", err)
}
log.Infof("Envoy: Version %s", envoyVersion)
// Make sure Envoy version matches the required one
if !strings.HasPrefix(envoyVersion, requiredEnvoyVersionSHA) {
return fmt.Errorf("envoy version %s does not match with required version %s", envoyVersion, requiredEnvoyVersionSHA)
}
log.Debugf("Envoy: Envoy version %s is matching required version %s", envoyVersion, requiredEnvoyVersionSHA)
return nil
}
func getRemoteEnvoyVersion(envoyAdminClient *EnvoyAdminClient) (string, error) {
const versionRetryAttempts = 20
const versionRetryWait = 500 * time.Millisecond
// Retry is necessary because Envoy might not be ready yet
for i := 0; i <= versionRetryAttempts; i++ {
envoyVersion, err := envoyAdminClient.GetEnvoyVersion()
if err != nil {
if i < versionRetryAttempts {
log.Info("Envoy: Unable to retrieve Envoy version - retry")
time.Sleep(versionRetryWait)
continue
}
return "", fmt.Errorf("failed to retrieve Envoy version: %w", err)
}
return envoyVersion, nil
}
return "", errors.New("failed to retrieve Envoy version")
}