hooks

Documentation

Index

• Constants
• Variables
• func DnsPatchForK3dSuiteHook(t testcontext.Testsuite) func() error
• func DnsPatchForK3dSuiteHookTeardown(t testcontext.Testsuite) func() error
• func ExtAuthorizerInstallHook(t testcontext.Testsuite) func() error
• func ExtAuthorizerRemoveHook(t testcontext.Testsuite) func() error
• func IstioSkipVerifyJwksResolverSuiteHook(t testcontext.Testsuite) func() error
• func IstioSkipVerifyJwksResolverSuiteHookTeardown(t testcontext.Testsuite) func() error

Constants

const ApiGatewayCRName string = "default"

Variables

var ApiGatewayCrTearDownScenarioHook = func(ctx context.Context, sc *godog.Scenario, _ error) (context.Context, error) {
	if apiGateways, ok := testcontext.GetApiGatewayCRsFromContext(ctx); ok {

		for _, apiGateway := range apiGateways {
			_ = retry.Do(func() error {
				err := removeObjectFromCluster(ctx, apiGateway)
				if err != nil {
					return fmt.Errorf("failed to delete ApiGateway CR %s", apiGateway.GetName())
				}
				return nil
			}, testcontext.GetRetryOpts()...)
			err := forceApiGatewayCrRemoval(ctx, apiGateway)
			if err != nil {
				return ctx, err
			}
		}
	}
	return ctx, nil
}

var ApiGatewayCrTearDownSuiteHook = func() error {
	k8sClient := k8sclient.GetK8sClient()

	apiGateway, err := createApiGatewayCRObjectFromTemplate(ApiGatewayCRName)
	if err != nil {
		return err
	}

	err = retry.Do(func() error {
		err := k8sClient.Delete(context.Background(), &apiGateway)
		if err != nil {
			return err
		}
		return nil
	}, testcontext.GetRetryOpts()...)
	if err != nil {
		return err
	}

	err = retry.Do(func() error {
		err := k8sClient.Get(context.Background(), client.ObjectKey{
			Namespace: apiGateway.GetNamespace(),
			Name:      apiGateway.GetName(),
		}, &apiGateway)

		if err == nil {
			return fmt.Errorf("ApiGatewayCrTearDownSuiteHook did not delete APIGateway CR, state: %s description: %s", apiGateway.Status.State, apiGateway.Status.Description)
		}

		return nil
	})
	if err != nil {
		return err
	}

	return nil
}

var ApplyAndVerifyApiGatewayCrSuiteHook = func() error {
	return applyAndVerifyApiGateway(false)
}

var ApplyAndVerifyApiGatewayWithoutOathkeeperCrSuiteHook = func() error {
	return applyAndVerifyApiGateway(true)
}

var ApplyApiGatewayCrScenarioHook = func(ctx context.Context, sc *godog.Scenario) (context.Context, error) {
	k8sClient, err := testcontext.GetK8sClientFromContext(ctx)
	if err != nil {
		return ctx, err
	}

	if err := createDeprecatedV1ConfigMap(context.Background(), k8sClient); err != nil {
		return ctx, err
	}

	apiGateway, err := createApiGatewayCRObjectFromTemplate(ApiGatewayCRName)
	if err != nil {
		return ctx, err
	}
	err = retry.Do(func() error {
		err := k8sClient.Create(ctx, &apiGateway)
		if err != nil {
			return err
		}
		ctx = testcontext.AddApiGatewayCRIntoContext(ctx, &apiGateway)
		return nil
	}, testcontext.GetRetryOpts()...)
	return ctx, err
}

var DeleteBlockingResourcesScenarioHook = func(ctx context.Context, sc *godog.Scenario, _ error) (context.Context, error) {
	return ctx, deleteBlockingResources(ctx)
}

var DeleteBlockingResourcesSuiteHook = func() error {
	return deleteBlockingResources(context.Background())
}

var DisableV2Alpha1RequiredFieldsHook = func() error {
	err := patch.Removev2alpha1VersionRequiredFields(k8sclient.GetK8sClient())
	if err != nil {
		log.Printf("Failed to disable v2alpha1 required fields: %v", err)
	}
	return err
}

var Removev2alpha1VersionRequiredFieldsHook = func(ctx context.Context, sc *godog.Scenario) (context.Context, error) {
	k8sClient, err := testcontext.GetK8sClientFromContext(ctx)
	if err != nil {
		return ctx, err
	}

	return ctx, patch.Removev2alpha1VersionRequiredFields(k8sClient)
}

var WaitUntilApiGatewayDepsAreRemovedHook = func(ctx context.Context, sc *godog.Scenario, _ error) (context.Context, error) {
	err := waitUntilObjectIsRemoved(ctx, dnsKind, kymaDNSName, kymaDNSNamespace)
	if err != nil {
		return ctx, err
	}

	err = waitUntilObjectIsRemoved(ctx, gatewayKind, kymaGatewayName, kymaGatewayNamespace)
	if err != nil {
		return ctx, err
	}

	err = waitUntilObjectIsRemoved(ctx, certKind, kymaCertName, kymaCertNamespace)
	if err != nil {
		return ctx, err
	}

	return ctx, nil
}

Functions

func DnsPatchForK3dSuiteHook

func DnsPatchForK3dSuiteHook(t testcontext.Testsuite) func() error

func DnsPatchForK3dSuiteHookTeardown

func DnsPatchForK3dSuiteHookTeardown(t testcontext.Testsuite) func() error

func ExtAuthorizerInstallHook

func ExtAuthorizerInstallHook(t testcontext.Testsuite) func() error

func ExtAuthorizerRemoveHook

func ExtAuthorizerRemoveHook(t testcontext.Testsuite) func() error

func IstioSkipVerifyJwksResolverSuiteHook

func IstioSkipVerifyJwksResolverSuiteHook(t testcontext.Testsuite) func() error

func IstioSkipVerifyJwksResolverSuiteHookTeardown

func IstioSkipVerifyJwksResolverSuiteHookTeardown(t testcontext.Testsuite) func() error