...
1 package healthcheck
2
3 import (
4 "context"
5 "fmt"
6
7 "github.com/linkerd/linkerd2/pkg/config"
8
9 "github.com/linkerd/linkerd2/pkg/charts/linkerd2"
10 "github.com/linkerd/linkerd2/pkg/k8s"
11 )
12
13
14 func GetServerVersion(ctx context.Context, controlPlaneNamespace string, kubeAPI *k8s.KubernetesAPI) (string, error) {
15 cm, err := config.FetchLinkerdConfigMap(ctx, kubeAPI, controlPlaneNamespace)
16 if err != nil {
17 return "", fmt.Errorf("failed to fetch linkerd-config: %w", err)
18 }
19
20 values, err := linkerd2.ValuesFromConfigMap(cm)
21 if err != nil {
22 return "", fmt.Errorf("failed to load values from linkerd-config: %w", err)
23 }
24
25 return values.LinkerdVersion, nil
26 }
27
View as plain text