func()

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
}