testutils

package
v0.0.0-...-de4dd0d Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 10, 2025 License: Apache-2.0 Imports: 46 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TestModuleCRName                   = "sample-yaml"
	TestModuleName                     = "template-operator"
	TestModuleResourceNamespace        = "template-operator-system"
	ModuleResourceName                 = "template-operator-controller-manager"
	ModuleServiceAccountName           = "template-operator-controller-manager"
	ModuleManagedCRName                = "template-operator-managed-resource"
	ModuleDeploymentNameInNewerVersion = "template-operator-v2-controller-manager"
	ModuleDeploymentNameInOlderVersion = "template-operator-v1-controller-manager"
)
View Source 
const (
	RemoteNamespace       = shared.DefaultRemoteNamespace
	ControlPlaneNamespace = "kcp-system"
	IstioNamespace        = "istio-system"
)
View Source 
const (
	Timeout                = time.Second * 10
	ConsistentCheckTimeout = time.Second * 10
	Interval               = time.Millisecond * 250
)
View Source 
const DefaultFQDN = "kyma-project.io/module/template-operator"
View Source 
const (
	FastChannel = "fast"
)
View Source 
const (
	OCIRegistryCredLabelKeyForTest = shared.OperatorGroup + shared.Separator + "oci-registry-cred"
)

Variables

View Source 
var (
	ErrStatusModuleStateMismatch        = errors.New("status.modules.state not match")
	ErrContainsUnexpectedModules        = errors.New("kyma CR contains unexpected modules")
	ErrNotContainsExpectedModules       = errors.New("kyma CR not contains expected modules")
	ErrModuleVersionInStatusIsIncorrect = errors.New("status.modules.version is incorrect")
	ErrModuleMessageInStatusIsIncorrect = errors.New("status.modules.message is incorrect")
)
View Source 
var (
	ErrManifestResourceIsNil = errors.New("manifest spec.resource is nil")
	ErrManifestsExist        = errors.New("cluster contains manifest CRs")
)
View Source 
var (
	ErrNotExpectedChannelVersion = errors.New("channel-version pair not found")
	ErrBetaValueNotCorrect       = errors.New("beta value not correct")
	ErrInternalValueNotCorrect   = errors.New("internal value not correct")
)
View Source 
var (
	ErrLabelNotFound        = errors.New("label is not found")
	ErrLabelValueNotCorrect = errors.New("label value is not as expected")
)
View Source 
var (
	ErrNotFound                   = errors.New("resource does not exist")
	ErrNotDeleted                 = errors.New("resource has not been deleted")
	ErrDeletionTimestampFound     = errors.New("deletion timestamp not nil")
	ErrSampleCrNotInExpectedState = errors.New("resource not in expected state")
	ErrFetchingStatus             = errors.New("could not fetch status from resource")
)
View Source 
var ErrManifestStateMisMatch = errors.New("ManifestState mismatch")

Functions

func AddFinalizerToManifest 

func AddFinalizerToManifest(ctx context.Context, clnt client.Client, kymaName,
	kymaNamespace,
	moduleName, finalizer string,
) error

func AddFinalizerToModuleCR 

func AddFinalizerToModuleCR(ctx context.Context, clnt client.Client, moduleCR *unstructured.Unstructured,
	finalizer string,
) error

func AllModuleTemplatesExists 

func AllModuleTemplatesExists(ctx context.Context, clnt client.Client, kyma *v1beta2.Kyma) error

func AppendExternalCRDs 

func AppendExternalCRDs(path string, files ...string) ([]*apiextensionsv1.CustomResourceDefinition, error)

func ApplyYAML 

func ApplyYAML(ctx context.Context, clnt client.Client, yamlFilePath string) error

func CRExists 

func CRExists(obj apimetav1.Object, clientError error) error

func CRIsInState 

func CRIsInState(ctx context.Context, group, version, kind, name, namespace string, statusPath []string,
	clnt client.Client, expectedState shared.State,
) error

func CheckManifestIsInState 

func CheckManifestIsInState(
	ctx context.Context,
	kymaName, kymaNamespace, moduleName string,
	clnt client.Client,
	expectedState shared.State,
) error

func CheckModuleState 

func CheckModuleState(ctx context.Context, clnt client.Client,
	kymaName, kymaNamespace, moduleName string,
	state shared.State,
) error

func ConditionExists 

func ConditionExists(ctx context.Context,
	clnt client.Client,
	kymaName,
	kymaNamespace,
	moduleName,
	expectedConditionType,
	expectedConditionReason string,
	expectedConditionStatus apimetav1.ConditionStatus,
) error

func ContainsKymaManagerField 

func ContainsKymaManagerField(
	ctx context.Context, clnt client.Client,
	kymaName, kymaNamespace, managerName string,
) (bool, error)

func ContainsModuleInSpec 

func ContainsModuleInSpec(ctx context.Context,
	clnt client.Client,
	kymaName, kymaNamespace,
	moduleName string,
) error

func CreateCR 

func CreateCR(ctx context.Context, clnt client.Client, obj client.Object) error

func CreateImageSpecLayer 

func CreateImageSpecLayer(manifestFilePath string) (containerregistryv1.Layer, error)

func CreateModuleTemplate 

func CreateModuleTemplate(ctx context.Context,
	clnt client.Client,
	moduleTemplate *v1beta2.ModuleTemplate,
) error

func CreateNamespace 

func CreateNamespace(ctx context.Context, clnt client.Client, name string) error

func CreateOCIImageSpecFromFile 

func CreateOCIImageSpecFromFile(name, repo, manifestFilePath string, enableCredSecretSelector bool) (v1beta2.ImageSpec,
	error,
)

func CreateOCIImageSpecFromTar 

func CreateOCIImageSpecFromTar(name, repo, manifestTarPath string, enableCredSecretSelector bool) (v1beta2.ImageSpec,
	error,
)

func CredSecretLabelSelector 

func CredSecretLabelSelector(labelValue string) *apimetav1.LabelSelector

func DeleteCR 

func DeleteCR(ctx context.Context, clnt client.Client, obj client.Object) error

func DeleteCRWithGVK 

func DeleteCRWithGVK(ctx context.Context, clnt client.Client, name, namespace, group, version, kind string) error

func DeleteKyma 

func DeleteKyma(ctx context.Context,
	clnt client.Client,
	kyma *v1beta2.Kyma,
	deletionPropagation apimetav1.DeletionPropagation,
) error

func DeleteKymaByForceRemovePurgeFinalizer 

func DeleteKymaByForceRemovePurgeFinalizer(ctx context.Context, clnt client.Client, kyma *v1beta2.Kyma) error

func DeleteManifest 

func DeleteManifest(ctx context.Context, clnt client.Client, kymaName, kymaNamespace, moduleName string) error

func DeleteManifestAndVerify 

func DeleteManifestAndVerify(ctx context.Context, clnt client.Client, manifest *v1beta2.Manifest) func() error

func DeleteModule 

func DeleteModule(ctx context.Context, clnt client.Client, kyma *v1beta2.Kyma, moduleName string) error

func DeleteModuleReleaseMeta 

func DeleteModuleReleaseMeta(ctx context.Context, moduleName, namespace string, clnt client.Client) error

func DeleteModuleTemplate 

func DeleteModuleTemplate(ctx context.Context,
	clnt client.Client,
	module v1beta2.Module,
	kyma *v1beta2.Kyma,
) error

func DeletionTimeStampExists 

func DeletionTimeStampExists(ctx context.Context, group, version, kind, name, namespace string,
	clnt client.Client,
) (bool, error)

func DisableModule 

func DisableModule(ctx context.Context, clnt client.Client,
	kymaName, kymaNamespace, moduleName string,
) error

func EnableModule 

func EnableModule(ctx context.Context,
	clnt client.Client,
	kymaName, kymaNamespace string,
	module v1beta2.Module,
) error

func ExpectManifestLastOperationMessageContains 

func ExpectManifestLastOperationMessageContains(ctx context.Context, clnt client.Client,
	manifestName, message string,
) error

func ExpectManifestStateIn 

func ExpectManifestStateIn(ctx context.Context, clnt client.Client,
	state shared.State,
) func(manifestName string) error

func ExpectOCISyncRefAnnotationExists 

func ExpectOCISyncRefAnnotationExists(ctx context.Context, clnt client.Client,
	mustExist bool,
) func(manifestName string) error

func FinalizerIsRemoved 

func FinalizerIsRemoved(ctx context.Context, clnt client.Client, moduleCR *unstructured.Unstructured,
	finalizer string,
) error

func GetCR 

func GetCR(ctx context.Context, clnt client.Client,
	objectKey client.ObjectKey,
	gvk schema.GroupVersionKind,
) (*unstructured.Unstructured, error)

func GetKyma 

func GetKyma(ctx context.Context, clnt client.Client, name, namespace string) (*v1beta2.Kyma, error)

func GetManifest 

func GetManifest(ctx context.Context,
	clnt client.Client,
	kymaName,
	kymaNamespace,
	moduleName string,
) (*v1beta2.Manifest, error)

GetManifest should be only used when manifest still been tracked in kyma.status.

func GetManifestResource 

func GetManifestResource(ctx context.Context,
	clnt client.Client,
	kymaName,
	kymaNamespace,
	moduleName string,
) (*unstructured.Unstructured, error)

func GetManifestSpecRemote 

func GetManifestSpecRemote(
	ctx context.Context,
	clnt client.Client,
	kymaName,
	kymaNamespace,
	moduleName string,
) (bool, error)

func GetManifestStatus 

func GetManifestStatus(ctx context.Context, clnt client.Client, manifestName string) (shared.Status, error)

func GetManifestWithMetadata 

func GetManifestWithMetadata(ctx context.Context,
	clnt client.Client, manifestNamespace, manifestName string,
) (*v1beta2.Manifest, error)

func GetManifestWithName 

func GetManifestWithName(ctx context.Context, clnt client.Client, manifestName string) (*v1beta2.Manifest, error)

func GetModuleReleaseMeta 

func GetModuleReleaseMeta(ctx context.Context, moduleName, namespace string,
	clnt client.Client,
) (*v1beta2.ModuleReleaseMeta, error)

func GetModuleTemplate 

func GetModuleTemplate(ctx context.Context,
	clnt client.Client,
	module v1beta2.Module,
	kyma *v1beta2.Kyma,
) (*v1beta2.ModuleTemplate, error)

func HasExpectedLabel 

func HasExpectedLabel(ctx context.Context, clnt client.Client,
	objectKey client.ObjectKey,
	gvk schema.GroupVersionKind, expectedLabelKey string, expectedLabelValue string,
) error

func ImmediatelyRequeueKyma 

func ImmediatelyRequeueKyma(
	ctx context.Context,
	clnt client.Client,
	kymaName, kymaNamespace string,
) error

ImmediatelyRequeueKyma adds a dummy label to the Kyma CR to trigger a requeue.

func InstallManifest 

func InstallManifest(ctx context.Context, clnt client.Client, manifest *v1beta2.Manifest, installSpecByte []byte,
	enableResource bool,
) error

func IsResourceVersionSame 

func IsResourceVersionSame(ctx context.Context, clnt client.Client,
	objectKey client.ObjectKey,
	gvk schema.GroupVersionKind, expectedVersion string,
) (bool, error)

func KymaDeleted 

func KymaDeleted(ctx context.Context,
	kymaName string, kymaNamespace string, k8sClient client.Client,
) error

func KymaExists 

func KymaExists(ctx context.Context, clnt client.Client, name, namespace string) error

func KymaHasDeletionTimestamp 

func KymaHasDeletionTimestamp(ctx context.Context,
	clnt client.Client,
	kymaName string,
	kymaNamespace string,
) bool

func KymaIsInState 

func KymaIsInState(ctx context.Context, name, namespace string, clnt client.Client, state shared.State) error

func MandatoryManifestExistsWithLabelAndAnnotation 

func MandatoryManifestExistsWithLabelAndAnnotation(ctx context.Context, clnt client.Client,
	annotationKey, annotationValue string,
) error

func MandatoryModuleManifestExistWithCorrectVersion 

func MandatoryModuleManifestExistWithCorrectVersion(ctx context.Context, clnt client.Client,
	moduleName, expectedVersion string,
) error

func MandatoryModuleTemplateHasExpectedLabel 

func MandatoryModuleTemplateHasExpectedLabel(ctx context.Context, clnt client.Client, moduleName, key, value string,
) error

func ManifestExists 

func ManifestExists(
	ctx context.Context,
	clnt client.Client,
	kymaName,
	kymaNamespace,
	moduleName string,
) error

func ManifestExistsByMetadata 

func ManifestExistsByMetadata(
	ctx context.Context,
	clnt client.Client,
	manifestNamespace,
	manifestName string,
) error

func ManifestNoDeletionTimeStampSet 

func ManifestNoDeletionTimeStampSet(ctx context.Context,
	kymaName, kymaNamespace, moduleName string,
	clnt client.Client,
) error

func ManifestStatusLastUpdateTimeIsNotChanged 

func ManifestStatusLastUpdateTimeIsNotChanged(ctx context.Context,
	clnt client.Client,
	kymaName, kymaNamespace, moduleName string,
	oldStatus shared.Status,
) error

func ManifestStatusOperationContainsMessage 

func ManifestStatusOperationContainsMessage(ctx context.Context, clnt client.Client,
	kymaName, kymaNamespace, moduleName, msg string,
) error

func ManifestVersionIsCorrect 

func ManifestVersionIsCorrect(ctx context.Context, clnt client.Client,
	kymaName, kymaNamespace, moduleName, version string,
) error

func ModuleCRExists 

func ModuleCRExists(ctx context.Context, clnt client.Client, moduleCR *unstructured.Unstructured) error

func ModuleCRIsInExpectedState 

func ModuleCRIsInExpectedState(ctx context.Context,
	clnt client.Client,
	moduleCR *unstructured.Unstructured,
	expectedState shared.State,
) bool

func ModuleMessageInKymaStatusIsCorrect 

func ModuleMessageInKymaStatusIsCorrect(ctx context.Context, clnt client.Client,
	kymaName, kymaNamespace, moduleName, message string,
) error

func ModuleReleaseMetaBetaValueIsCorrect 

func ModuleReleaseMetaBetaValueIsCorrect(ctx context.Context, client client.Client, namespace, name string,
	expectedValue bool,
) error

func ModuleReleaseMetaContainsCorrectChannelVersion 

func ModuleReleaseMetaContainsCorrectChannelVersion(ctx context.Context,
	moduleName, namespace, channel, version string, clnt client.Client,
) error

func ModuleReleaseMetaExists 

func ModuleReleaseMetaExists(ctx context.Context, moduleName, namespace string, clnt client.Client) error

func ModuleReleaseMetaInternalValueIsCorrect 

func ModuleReleaseMetaInternalValueIsCorrect(ctx context.Context, client client.Client, namespace, name string,
	expectedValue bool,
) error

func ModuleTemplateExists 

func ModuleTemplateExists(ctx context.Context,
	clnt client.Client,
	module v1beta2.Module,
	kyma *v1beta2.Kyma,
) error

func ModuleTemplateExistsByName 

func ModuleTemplateExistsByName(ctx context.Context,
	clnt client.Client,
	moduleName string,
	namespace string,
) error

func ModuleVersionInKymaStatusIsCorrect 

func ModuleVersionInKymaStatusIsCorrect(ctx context.Context,
	clnt client.Client, kymaName, kymaNamespace, moduleName, moduleVersion string,
) error

func NewKymaWithSyncLabel 

func NewKymaWithSyncLabel(name, namespace, channel string) *v1beta2.Kyma

NewKymaWithSyncLabel use this function to initialize kyma CR with SyncStrategyLocalSecret are typically used in e2e test, which expect related access secret provided.

func NewTemplateOperator 

func NewTemplateOperator(channel string) v1beta2.Module

func NewTemplateOperatorWithVersion 

func NewTemplateOperatorWithVersion(version string) v1beta2.Module

func NewTestIssuer 

func NewTestIssuer(namespace string) *certmanagerv1.Issuer

func NewTestKyma 

func NewTestKyma(name string) *v1beta2.Kyma

func NewTestManifest 

func NewTestManifest(prefix string) *v1beta2.Manifest

func NewTestModule 

func NewTestModule(name, channel string) v1beta2.Module

func NewTestModuleCR 

func NewTestModuleCR(namespace string) *unstructured.Unstructured

NewTestModuleCR init one module cr used by template-operator.

func NewTestModuleWithChannelVersion 

func NewTestModuleWithChannelVersion(name, channel, version string) v1beta2.Module

func NewTestModuleWithFixName 

func NewTestModuleWithFixName(name, channel, version string) v1beta2.Module

func NewTestNamespace 

func NewTestNamespace(namespace string) *apicorev1.Namespace

func NoManifestExist 

func NoManifestExist(ctx context.Context,
	clnt client.Client,
) error

func NotContainsModuleInSpec 

func NotContainsModuleInSpec(ctx context.Context,
	clnt client.Client,
	kymaName, kymaNamespace,
	moduleName string,
) error

func PatchServiceToTypeLoadBalancer 

func PatchServiceToTypeLoadBalancer(ctx context.Context, clnt client.Client, serviceName, namespace string) error

func PushToRemoteOCIRegistry 

func PushToRemoteOCIRegistry(server *httptest.Server, manifestFilePath, layerName string) error

func ReadModuleVersionFromModuleTemplate 

func ReadModuleVersionFromModuleTemplate(ctx context.Context,
	clnt client.Client,
	module v1beta2.Module,
	kyma *v1beta2.Kyma,
) (string, error)

func SampleCRDeletionTimeStampSet 

func SampleCRDeletionTimeStampSet(ctx context.Context, name, namespace string, clnt client.Client) error

func SampleCRNoDeletionTimeStampSet 

func SampleCRNoDeletionTimeStampSet(ctx context.Context, name, namespace string, clnt client.Client) error

func SetKymaState 

func SetKymaState(ctx context.Context, kyma *v1beta2.Kyma, clnt client.Client, state shared.State) error

func SetModuleManaged 

func SetModuleManaged(ctx context.Context, clnt client.Client,
	kymaName, kymaNamespace, moduleName string, managed bool,
) error

func SetModuleReleaseMetaBeta 

func SetModuleReleaseMetaBeta(ctx context.Context, beta bool, moduleName, namespace string, clnt client.Client) error

func SetModuleReleaseMetaInternal 

func SetModuleReleaseMetaInternal(ctx context.Context, internal bool, moduleName, namespace string,
	clnt client.Client,
) error

func SetSkipLabelToMandatoryManifests 

func SetSkipLabelToMandatoryManifests(ctx context.Context, clnt client.Client, ifSkip bool,
) error

func SetSkipLabelToManifest 

func SetSkipLabelToManifest(
	ctx context.Context,
	clnt client.Client,
	kymaName,
	kymaNamespace,
	moduleName string,
	ifSkip bool,
) error

func SkipLabelExistsInManifest 

func SkipLabelExistsInManifest(ctx context.Context,
	clnt client.Client,
	kymaName,
	kymaNamespace,
	moduleName string,
) bool

func SyncKyma 

func SyncKyma(ctx context.Context, clnt client.Client, kyma *v1beta2.Kyma) error

func UpdateAllModuleReleaseMetaChannelVersions 

func UpdateAllModuleReleaseMetaChannelVersions(ctx context.Context, client client.Client,
	namespace, name, version string,
) error

func UpdateChannelVersionInModuleReleaseMeta 

func UpdateChannelVersionInModuleReleaseMeta(ctx context.Context, clnt client.Client,
	moduleName, namespace, channel, version string,
) error

func UpdateKymaLabel 

func UpdateKymaLabel(
	ctx context.Context,
	clnt client.Client,
	kymaName, kymaNamespace,
	labelKey, labelValue string,
) error

func UpdateKymaModuleChannel 

func UpdateKymaModuleChannel(ctx context.Context, clnt client.Client,
	kymaName, kymaNamespace, channel string,
) error

func UpdateManifestSpec 

func UpdateManifestSpec(cxt context.Context, clnt client.Client, manifestName string, spec v1beta2.ManifestSpec) error

func UpdateManifestState 

func UpdateManifestState(
	ctx context.Context,
	clnt client.Client,
	kymaName,
	kymaNamespace,
	moduleName string,
	state shared.State,
) error

func UpdateModuleTemplateSpec 

func UpdateModuleTemplateSpec(ctx context.Context,
	clnt client.Client,
	module v1beta2.Module,
	key,
	newValue string,
	kyma *v1beta2.Kyma,
) error

func WithInvalidInstallImageSpec 

func WithInvalidInstallImageSpec(ctx context.Context, clnt client.Client,
	enableResource bool, manifestFilePath string,
) func(manifest *v1beta2.Manifest) error

func WithValidInstallImageSpecFromFile 

func WithValidInstallImageSpecFromFile(ctx context.Context, clnt client.Client,
	name, manifestFilePath, serverURL string,
	enableResource, enableCredSecretSelector bool,
) func(manifest *v1beta2.Manifest) error

func WithValidInstallImageSpecFromTar 

func WithValidInstallImageSpecFromTar(ctx context.Context, clnt client.Client, name, manifestTarPath, serverURL string,
	enableResource, enableCredSecretSelector bool,
) func(manifest *v1beta2.Manifest) error

Types

This section is empty.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.