in pkg/plugin/healthz.go [142:168]
func (h *HealthZ) checkRPC(
ctx context.Context,
kmsV1Client kmsv1.KeyManagementServiceClient,
kmsV2Client kmsv2.KeyManagementServiceClient,
) error {
v, err := kmsV1Client.Version(ctx, &kmsv1.VersionRequest{})
if err != nil {
return err
}
if v.Version != version.KMSv1APIVersion || v.RuntimeName != version.Runtime || v.RuntimeVersion != version.BuildVersion {
return fmt.Errorf("failed to get correct version response")
}
v2Status, err := kmsV2Client.Status(ctx, &kmsv2.StatusRequest{})
if err != nil {
return err
}
if v2Status.Version != version.KMSv2APIVersion {
return fmt.Errorf(
"failed to get correct version response for v2 expected: %s, got: %s",
version.KMSv2APIVersion,
v2Status.Version,
)
}
return nil
}