Documentation ¶
Index ¶
- Constants
- Variables
- func AddFinalizerToManifest(ctx context.Context, clnt client.Client, ...) error
- func AddFinalizerToModuleCR(ctx context.Context, clnt client.Client, moduleCR *unstructured.Unstructured, ...) error
- func AllModuleTemplatesExists(ctx context.Context, clnt client.Client, kyma *v1beta2.Kyma) error
- func AppendExternalCRDs(path string, files ...string) ([]*apiextensionsv1.CustomResourceDefinition, error)
- func ApplyYAML(ctx context.Context, clnt client.Client, yamlFilePath string) error
- func AssertKymaStateMetricNotFound(ctx context.Context, kymaName string, state shared.State) error
- func CRExists(obj apimetav1.Object, clientError error) error
- func CRIsInState(ctx context.Context, group, version, kind, name, namespace string, ...) error
- func CertificateSecretExists(ctx context.Context, secretName types.NamespacedName, k8sClient client.Client) error
- func CertificateSecretIsCreatedAfter(ctx context.Context, secretName types.NamespacedName, k8sClient client.Client, ...) error
- func CertificateSecretIsSyncedToSkrCluster(ctx context.Context, kcpSecretName types.NamespacedName, ...) error
- func CheckManifestIsInState(ctx context.Context, kymaName, kymaNamespace, moduleName string, ...) error
- func CheckModuleState(ctx context.Context, clnt client.Client, ...) error
- func CheckPodLogs(ctx context.Context, namespace, podPrefix, container, logMsg string, ...) error
- func ConditionExists(ctx context.Context, clnt client.Client, ...) error
- func ContainsKymaManagerField(ctx context.Context, clnt client.Client, ...) (bool, error)
- func ContainsModuleInSpec(ctx context.Context, clnt client.Client, ...) error
- func CreateCR(ctx context.Context, clnt client.Client, obj client.Object) error
- func CreateImageSpecLayer(manifestFilePath string) (containerregistryv1.Layer, error)
- func CreateNamespace(ctx context.Context, clnt client.Client, name string) error
- func CreateOCIImageSpecFromFile(name, repo, manifestFilePath string, enableCredSecretSelector bool) (v1beta2.ImageSpec, error)
- func CreateOCIImageSpecFromTar(name, repo, manifestTarPath string, enableCredSecretSelector bool) (v1beta2.ImageSpec, error)
- func CredSecretLabelSelector(labelValue string) *apimetav1.LabelSelector
- func DeleteCR(ctx context.Context, clnt client.Client, obj client.Object) error
- func DeleteCRWithGVK(ctx context.Context, clnt client.Client, ...) error
- func DeleteCertificateSecret(ctx context.Context, secret types.NamespacedName, k8sClient client.Client) error
- func DeleteKyma(ctx context.Context, clnt client.Client, kyma *v1beta2.Kyma, ...) error
- func DeleteKymaByForceRemovePurgeFinalizer(ctx context.Context, clnt client.Client, kyma *v1beta2.Kyma) error
- func DeleteManifest(ctx context.Context, clnt client.Client, ...) error
- func DeleteManifestAndVerify(ctx context.Context, clnt client.Client, manifest *v1beta2.Manifest) func() error
- func DeleteModule(ctx context.Context, clnt client.Client, kyma *v1beta2.Kyma, moduleName string) error
- func DeleteModuleReleaseMeta(ctx context.Context, moduleName, namespace string, clnt client.Client) error
- func DeleteModuleTemplate(ctx context.Context, clnt client.Client, module v1beta2.Module, ...) error
- func DeletionTimeStampExists(ctx context.Context, group, version, kind, name, namespace string, ...) (bool, error)
- func DeploymentIsReady(ctx context.Context, clnt client.Client, name, namespace string) error
- func DisableModule(ctx context.Context, clnt client.Client, ...) error
- func EnableDeployment(ctx context.Context, clnt client.Client, name, namespace string) error
- func EnableModule(ctx context.Context, clnt client.Client, kymaName, kymaNamespace string, ...) error
- func ExpectManifestLastOperationMessageContains(ctx context.Context, clnt client.Client, manifestName, message string) error
- func ExpectManifestStateIn(ctx context.Context, clnt client.Client, state shared.State) func(manifestName string) error
- func ExpectOCISyncRefAnnotationExists(ctx context.Context, clnt client.Client, mustExist bool) func(manifestName string) error
- func FinalizerIsRemoved(ctx context.Context, clnt client.Client, moduleCR *unstructured.Unstructured, ...) error
- func GetCACertificate(ctx context.Context, namespacedCertName types.NamespacedName, ...) (*certmanagerv1.Certificate, error)
- func GetCR(ctx context.Context, clnt client.Client, objectKey client.ObjectKey, ...) (*unstructured.Unstructured, error)
- func GetClusterRoleBindingPolicyRules(ctx context.Context, clnt client.Client, roleName string, ...) ([]apirbacv1.PolicyRule, error)
- func GetDeployment(ctx context.Context, clnt client.Client, name, namespace string) (*apiappsv1.Deployment, error)
- func GetKyma(ctx context.Context, clnt client.Client, name, namespace string) (*v1beta2.Kyma, error)
- func GetKymaStateMetricCount(ctx context.Context, kymaName string, state shared.State) (int, error)
- func GetMandatoryModuleStateMetric(ctx context.Context, kymaName, moduleName, state string) (int, error)
- func GetMandatoryModuleTemplateCountMetric(ctx context.Context) (int, error)
- func GetManifest(ctx context.Context, clnt client.Client, ...) (*v1beta2.Manifest, error)
- func GetManifestResource(ctx context.Context, clnt client.Client, ...) (*unstructured.Unstructured, error)
- func GetManifestSpecRemote(ctx context.Context, clnt client.Client, ...) (bool, error)
- func GetManifestStatus(ctx context.Context, clnt client.Client, manifestName string) (shared.Status, error)
- func GetManifestWithMetadata(ctx context.Context, clnt client.Client, ...) (*v1beta2.Manifest, error)
- func GetManifestWithName(ctx context.Context, clnt client.Client, manifestName string) (*v1beta2.Manifest, error)
- func GetModuleCRWarningConditionMetric(ctx context.Context, kymaName, moduleName string) (int, error)
- func GetModuleReleaseMeta(ctx context.Context, moduleName, namespace string, clnt client.Client) (*v1beta2.ModuleReleaseMeta, error)
- func GetModuleStateMetricCount(ctx context.Context, kymaName, moduleName string, state shared.State) (int, error)
- func GetModuleTemplate(ctx context.Context, clnt client.Client, module v1beta2.Module, ...) (*v1beta2.ModuleTemplate, error)
- func GetRequeueReasonCount(ctx context.Context, requeueReason, requeueType string) (int, error)
- func GetRoleBindingRolePolicyRules(ctx context.Context, clnt client.Client, roleName, namespace string, ...) ([]apirbacv1.PolicyRule, error)
- func GetRoleBindingwithClusterRolePolicyRules(ctx context.Context, clnt client.Client, roleName string, ...) ([]apirbacv1.PolicyRule, error)
- func GetSelfSignedCertNotRenewMetricsGauge(ctx context.Context, kymaName string) (int, error)
- func GetStatefulSet(ctx context.Context, clnt client.Client, name, namespace string) (*apiappsv1.StatefulSet, error)
- func HasExpectedLabel(ctx context.Context, clnt client.Client, objectKey client.ObjectKey, ...) error
- func InstallManifest(ctx context.Context, clnt client.Client, manifest *v1beta2.Manifest, ...) error
- func IsManifestRequeueReasonCountIncreased(ctx context.Context, requeueReason, requeueType string) (bool, error)
- func IsResourceVersionSame(ctx context.Context, clnt client.Client, objectKey client.ObjectKey, ...) (bool, error)
- func KymaDeleted(ctx context.Context, kymaName string, kymaNamespace string, ...) error
- func KymaExists(ctx context.Context, clnt client.Client, name, namespace string) error
- func KymaHasDeletionTimestamp(ctx context.Context, clnt client.Client, kymaName string, kymaNamespace string) bool
- func KymaIsInState(ctx context.Context, name, namespace string, clnt client.Client, ...) error
- func ListKlmClusterRoleBindings(clnt client.Client, ctx context.Context, serviceAccountName string) (apirbacv1.ClusterRoleBindingList, error)
- func ListKlmRoleBindings(clnt client.Client, ctx context.Context, serviceAccountName, namespace string) (apirbacv1.RoleBindingList, error)
- func MandatoryManifestExistsWithLabelAndAnnotation(ctx context.Context, clnt client.Client, annotationKey, annotationValue string) error
- func MandatoryModuleTemplateHasExpectedLabel(ctx context.Context, clnt client.Client, moduleName, key, value string) error
- func ManifestExists(ctx context.Context, clnt client.Client, ...) error
- func ManifestExistsByMetadata(ctx context.Context, clnt client.Client, ...) error
- func ManifestNoDeletionTimeStampSet(ctx context.Context, kymaName, kymaNamespace, moduleName string, ...) error
- func ManifestStatusLastUpdateTimeIsNotChanged(ctx context.Context, clnt client.Client, ...) error
- func ManifestStatusOperationContainsMessage(ctx context.Context, clnt client.Client, ...) error
- func ManifestVersionIsCorrect(ctx context.Context, clnt client.Client, ...) error
- func ModuleCRExists(ctx context.Context, clnt client.Client, moduleCR *unstructured.Unstructured) error
- func ModuleCRIsInExpectedState(ctx context.Context, clnt client.Client, moduleCR *unstructured.Unstructured, ...) bool
- func ModuleCRWarningConditionMetricNotFound(ctx context.Context, kymaName, moduleName string) error
- func ModuleMessageInKymaStatusIsCorrect(ctx context.Context, clnt client.Client, ...) error
- func ModuleReleaseMetaContainsCorrectChannelVersion(ctx context.Context, moduleName, namespace, channel, version string, ...) error
- func ModuleReleaseMetaExists(ctx context.Context, moduleName, namespace string, clnt client.Client) error
- func ModuleTemplateExists(ctx context.Context, clnt client.Client, module v1beta2.Module, ...) error
- func ModuleVersionInKymaStatusIsCorrect(ctx context.Context, clnt client.Client, ...) error
- func NewKymaWithSyncLabel(name, namespace, channel string) *v1beta2.Kyma
- func NewTemplateOperator(channel string) v1beta2.Module
- func NewTemplateOperatorWithVersion(version string) v1beta2.Module
- func NewTestIssuer(namespace string) *certmanagerv1.Issuer
- func NewTestKyma(name string) *v1beta2.Kyma
- func NewTestManifest(prefix string) *v1beta2.Manifest
- func NewTestModule(name, channel string) v1beta2.Module
- func NewTestModuleCR(namespace string) *unstructured.Unstructured
- func NewTestModuleWithChannelVersion(name, channel, version string) v1beta2.Module
- func NewTestModuleWithFixName(name, channel, version string) v1beta2.Module
- func NewTestNamespace(namespace string) *apicorev1.Namespace
- func NoManifestExist(ctx context.Context, clnt client.Client) error
- func NotContainsModuleInSpec(ctx context.Context, clnt client.Client, ...) error
- func PurgeMetricsAreAsExpected(ctx context.Context, timeShouldBeMoreThan float64, expectedRequests int) bool
- func PushToRemoteOCIRegistry(server *httptest.Server, manifestFilePath, layerName string) error
- func ReadModuleVersionFromModuleTemplate(ctx context.Context, clnt client.Client, module v1beta2.Module, channel string, ...) (string, error)
- func SampleCRDeletionTimeStampSet(ctx context.Context, name, namespace string, clnt client.Client) error
- func SampleCRNoDeletionTimeStampSet(ctx context.Context, name, namespace string, clnt client.Client) error
- func SetKymaState(ctx context.Context, kyma *v1beta2.Kyma, clnt client.Client, ...) error
- func SetModuleManaged(ctx context.Context, clnt client.Client, ...) error
- func SetSkipLabelToMandatoryManifests(ctx context.Context, clnt client.Client, ifSkip bool) error
- func SetSkipLabelToManifest(ctx context.Context, clnt client.Client, ...) error
- func SkipLabelExistsInManifest(ctx context.Context, clnt client.Client, ...) bool
- func StatefulSetIsReady(ctx context.Context, clnt client.Client, name, namespace string) error
- func StopDeployment(ctx context.Context, clnt client.Client, name, namespace string) error
- func SyncKyma(ctx context.Context, clnt client.Client, kyma *v1beta2.Kyma) error
- func UpdateAllModuleReleaseMetaChannelVersions(ctx context.Context, client client.Client, namespace, name, version string) error
- func UpdateChannelVersionIfModuleReleaseMetaExists(ctx context.Context, clnt client.Client, ...) error
- func UpdateKymaLabel(ctx context.Context, clnt client.Client, ...) error
- func UpdateKymaModuleChannel(ctx context.Context, clnt client.Client, ...) error
- func UpdateManifestSpec(cxt context.Context, clnt client.Client, manifestName string, ...) error
- func UpdateManifestState(ctx context.Context, clnt client.Client, ...) error
- func UpdateModuleTemplateSpec(ctx context.Context, clnt client.Client, module v1beta2.Module, ...) error
- func WithInvalidInstallImageSpec(ctx context.Context, clnt client.Client, enableResource bool, ...) func(manifest *v1beta2.Manifest) error
- func WithValidInstallImageSpecFromFile(ctx context.Context, clnt client.Client, ...) func(manifest *v1beta2.Manifest) error
- func WithValidInstallImageSpecFromTar(ctx context.Context, clnt client.Client, ...) func(manifest *v1beta2.Manifest) error
Constants ¶
View Source
const ( KLMPodPrefix = "klm-controller-manager" KLMPodContainer = "manager" )
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" )
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 (
OCIRegistryCredLabelKeyForTest = shared.OperatorGroup + shared.Separator + "oci-registry-cred"
)
Variables ¶
View Source
var ( ErrDeploymentNotReady = errors.New("deployment is not ready") ErrDeploymentUpdating = errors.New("deployment is still updating") )
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 ( ErrPodNotFound = errors.New("could not find pod") ErrLogNotFound = errors.New("logMsg was not found in log") )
View Source
var ( ErrManifestResourceIsNil = errors.New("manifest spec.resource is nil") ErrManifestsExist = errors.New("cluster contains manifest CRs") )
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")
View Source
var ErrMetricNotFound = errors.New("metric was not found")
View Source
var ErrNotExpectedChannelVersion = errors.New("channel-version pair not found")
View Source
var ErrStatefulSetNotReady = errors.New("statefulset is not ready")
Functions ¶
func AddFinalizerToManifest ¶
func AddFinalizerToModuleCR ¶
func AddFinalizerToModuleCR(ctx context.Context, clnt client.Client, moduleCR *unstructured.Unstructured, finalizer string, ) error
func AppendExternalCRDs ¶
func AppendExternalCRDs(path string, files ...string) ([]*apiextensionsv1.CustomResourceDefinition, error)
func CRIsInState ¶
func CertificateSecretExists ¶
func CheckManifestIsInState ¶
func CheckModuleState ¶
func CheckPodLogs ¶
func ConditionExists ¶
func ContainsModuleInSpec ¶
func CreateImageSpecLayer ¶
func CreateImageSpecLayer(manifestFilePath string) (containerregistryv1.Layer, error)
func CreateNamespace ¶
func CredSecretLabelSelector ¶
func CredSecretLabelSelector(labelValue string) *apimetav1.LabelSelector
func DeleteCRWithGVK ¶
func DeleteCertificateSecret ¶
func DeleteKyma ¶
func DeleteManifest ¶
func DeleteManifestAndVerify ¶
func DeleteModule ¶
func DeleteModuleReleaseMeta ¶
func DeleteModuleTemplate ¶
func DeletionTimeStampExists ¶
func DeploymentIsReady ¶
func DisableModule ¶
func EnableDeployment ¶
func EnableModule ¶
func ExpectManifestStateIn ¶
func FinalizerIsRemoved ¶
func FinalizerIsRemoved(ctx context.Context, clnt client.Client, moduleCR *unstructured.Unstructured, finalizer string, ) error
func GetCACertificate ¶
func GetCACertificate(ctx context.Context, namespacedCertName types.NamespacedName, k8sClient client.Client, ) (*certmanagerv1.Certificate, error)
func GetCR ¶
func GetCR(ctx context.Context, clnt client.Client, objectKey client.ObjectKey, gvk schema.GroupVersionKind, ) (*unstructured.Unstructured, error)
func GetClusterRoleBindingPolicyRules ¶
func GetClusterRoleBindingPolicyRules(ctx context.Context, clnt client.Client, roleName string, clusterRoleBindings apirbacv1.ClusterRoleBindingList, ) ([]apirbacv1.PolicyRule, error)
func GetDeployment ¶
func GetKymaStateMetricCount ¶
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 GetManifestStatus ¶
func GetManifestWithMetadata ¶
func GetManifestWithName ¶
func GetModuleReleaseMeta ¶
func GetModuleTemplate ¶
func GetRequeueReasonCount ¶
func GetRoleBindingRolePolicyRules ¶
func GetRoleBindingRolePolicyRules(ctx context.Context, clnt client.Client, roleName, namespace string, roleBindings apirbacv1.RoleBindingList, ) ([]apirbacv1.PolicyRule, error)
func GetRoleBindingwithClusterRolePolicyRules ¶
func GetRoleBindingwithClusterRolePolicyRules(ctx context.Context, clnt client.Client, roleName string, roleBindings apirbacv1.RoleBindingList, ) ([]apirbacv1.PolicyRule, error)
func GetStatefulSet ¶
func HasExpectedLabel ¶
func InstallManifest ¶
func IsResourceVersionSame ¶
func KymaDeleted ¶
func KymaExists ¶
func KymaIsInState ¶
func ListKlmRoleBindings ¶
func ManifestExists ¶
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 ModuleReleaseMetaExists ¶
func ModuleTemplateExists ¶
func NewKymaWithSyncLabel ¶
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 NewTestIssuer ¶
func NewTestIssuer(namespace string) *certmanagerv1.Issuer
func NewTestKyma ¶
func NewTestManifest ¶
func NewTestModule ¶
func NewTestModuleCR ¶
func NewTestModuleCR(namespace string) *unstructured.Unstructured
NewTestModuleCR init one module cr used by template-operator.
func NewTestNamespace ¶
func NotContainsModuleInSpec ¶
func PushToRemoteOCIRegistry ¶
func SetKymaState ¶
func SetModuleManaged ¶
func SetSkipLabelToManifest ¶
func StatefulSetIsReady ¶
func StopDeployment ¶
func UpdateKymaLabel ¶
func UpdateKymaModuleChannel ¶
func UpdateManifestSpec ¶
func UpdateManifestState ¶
Types ¶
This section is empty.
Source Files ¶
Click to show internal directories.
Click to hide internal directories.