testcommon

package

Go to main page

Versions in this module

v2

v2.12.0

Feb 12, 2025

v2.11.0

Nov 12, 2024

v2.10.0

Oct 21, 2024

Changes in this version

+ func PathContains(path string, matches []string) bool

v2.9.0

Aug 22, 2024

Changes in this version

type KubePerTestContext

+ func (tc *KubePerTestContext) CreateSimpleSecret(name string, key string, secretData string) genruntime.SecretReference

type PerTestContext

+ func (tc PerTestContext) WithLiteralRedaction(redactionValue string, replacementValue string)

+ func (tc PerTestContext) WithRegexpRedaction(pattern string, replacementValue string)

type ResourceNamer

+ func (n ResourceNamer) GenerateNameOfLength(length int) string

+ func (n ResourceNamer) GenerateSecretOfLength(length int) string

v2.8.0

Jun 24, 2024

v2.7.0

Apr 24, 2024

v2.6.0

Feb 21, 2024

Changes in this version

type KubePerTestContext

+ MatchAzure *matchers.Azure

+ func (tc *KubePerTestContext) CreateResourcesAndWaitWithoutCleanup(objs ...client.Object)

+ func (tc *KubePerTestContext) ExportAsSampleNamed(resource client.Object, name string)

+ func (tc KubePerTestContext) MakeObjectMetaWithNameAndCredentialFrom(name string, credentialFrom string) ctrl.ObjectMeta

v2.5.0

Dec 7, 2023

v2.4.0

Nov 14, 2023

Changes in this version

type KubePerTestContext

+ func (tc *KubePerTestContext) LogSectionf(section string, args ...any)

+ func (tc *KubePerTestContext) LogSubsectionf(subsection string, args ...any)

type SimpleExtensionResource

+ func (r *SimpleExtensionResource) GetSupportedOperations() []genruntime.ResourceOperation

v2.3.0

Sep 4, 2023

Changes in this version

+ func AsARMIDOwner(id string) *genruntime.KnownResourceReference

+ func AsKubernetesOwner(obj client.Object) *genruntime.KubernetesOwnerReference

+ func NewScopedManagedIdentitySecret(subscriptionID, tenantID, clientID, name, namespace string) *v1.Secret

+ func NewScopedServicePrincipalCertificateSecret(subscriptionID, tenantID, clientID, clientCert, name, namespace string) *v1.Secret

+ func NewScopedServicePrincipalSecret(subscriptionID, tenantID, clientID, clientSecret, name, namespace string) *v1.Secret

type KubePerTestContext

+ func (tc *KubePerTestContext) PatchResourceAndWaitForState(old client.Object, new client.Object, status metav1.ConditionStatus, ...)

v2.2.0

Jul 20, 2023

v2.1.0

May 31, 2023

Changes in this version

type SampleObject

+ func (s *SampleObject) HasSamples() bool

v2.0.0

Apr 14, 2023

Changes in this version

+ const DummyBillingId

+ const LiveResourcePrefix

+ const ResourceNamerModeRandom

+ const ResourceNamerModeRandomBasedOnTestName

+ const ResourcePrefix

+ const TestBillingIDVar

+ var COUNT_HEADER string = "TEST-REQUEST-ATTEMPT"

+ var DefaultTestRegion = "westus2"

+ var LogLevel = 5

+ var OperationTimeoutRecording = 30 * time.Minute

+ var OperationTimeoutReplaying = 2 * time.Minute

+ var PollingIntervalRecording = 5 * time.Second

+ var PollingIntervalReplaying = 100 * time.Millisecond

+ var SimpleExtensionResourceGroupVersion = schema.GroupVersion

+ func AsOwner(obj client.Object) *genruntime.KnownResourceReference

+ func CreateClient(scheme *runtime.Scheme) client.Client

+ func CreateDummyResource() *batch.BatchAccount

+ func CreateResolver(scheme *runtime.Scheme, testClient client.Client) (*resolver.Resolver, error)

+ func CreateResourceGroup() *resources.ResourceGroup

+ func CreateScheme() (*runtime.Scheme, error)

+ func CreateTestResourceGroupDefaultTags() map[string]string

+ func EqualsIgnoreCase(expected string) types.GomegaMatcher

+ func IsFolderExcluded(path string, exclusions []string) bool

+ func IsSampleExcluded(path string, exclusions []string) bool

+ func NewClient(client client.Client, indexer *Indexer) client.Client

+ func NewTestClient(config *rest.Config, options client.Options) (client.Client, error)

+ func NewTestLogger(t *testing.T) logr.Logger

+ func ReadFromEnvironmentForTest() (config.Values, error)

+ func SetupTeardownTestMain(m *testing.M, setup func() error, teardown func() error) int

+ func WaitFor(ctx context.Context, timeout time.Duration, ...) error

+ type ARMMatcher struct

+ func NewARMMatcher(client *genericarmclient.GenericClient) *ARMMatcher

+ func (m *ARMMatcher) BeDeleted(ctx context.Context) types.GomegaMatcher

+ func (m *ARMMatcher) BeProvisioned(ctx context.Context) types.GomegaMatcher

+ type AzureBeDeletedMatcher struct

+ func (m *AzureBeDeletedMatcher) FailureMessage(actual interface{}) string

+ func (m *AzureBeDeletedMatcher) Match(actual interface{}) (bool, error)

+ func (m *AzureBeDeletedMatcher) MatchMayChangeInTheFuture(actual interface{}) bool

+ func (m *AzureBeDeletedMatcher) NegatedFailureMessage(actual interface{}) string

+ type AzureBeProvisionedMatcher struct

+ func (m *AzureBeProvisionedMatcher) FailureMessage(actual interface{}) string

+ func (m *AzureBeProvisionedMatcher) Match(actual interface{}) (bool, error)

+ func (m *AzureBeProvisionedMatcher) MatchMayChangeInTheFuture(actual interface{}) bool

+ func (m *AzureBeProvisionedMatcher) NegatedFailureMessage(actual interface{}) string

+ type AzureIDs struct

+ type BaseTestContextFactory func(PerTestContext, config.Values) (*KubeBaseTestContext, error)

+ type BeDeletedMatcher struct

+ func (m *BeDeletedMatcher) FailureMessage(actual interface{}) string

+ func (m *BeDeletedMatcher) Match(actual interface{}) (bool, error)

+ func (m *BeDeletedMatcher) MatchMayChangeInTheFuture(actual interface{}) bool

+ func (m *BeDeletedMatcher) NegatedFailureMessage(actual interface{}) string

+ type DesiredStateMatcher struct

+ func (m *DesiredStateMatcher) FailureMessage(actual interface{}) string

+ func (m *DesiredStateMatcher) Match(actual interface{}) (bool, error)

+ func (m *DesiredStateMatcher) MatchMayChangeInTheFuture(actual interface{}) bool

+ func (m *DesiredStateMatcher) NegatedFailureMessage(actual interface{}) string

+ type Indexer struct

+ func NewIndexer(scheme *runtime.Scheme) *Indexer

+ func (i *Indexer) IndexField(_ context.Context, obj client.Object, field string, ...) error

+ type KubeBaseTestContext struct

+ KubeConfig *rest.Config

+ type KubeGlobalContext struct

+ func NewKubeContext(useEnvTest bool, recordReplay bool, region string, ...) (KubeGlobalContext, error)

+ func (ctx KubeGlobalContext) Cleanup() error

+ func (ctx KubeGlobalContext) ForTest(t *testing.T) *KubePerTestContext

+ func (ctx KubeGlobalContext) ForTestWithConfig(t *testing.T, cfg config.Values) *KubePerTestContext

+ type KubeMatcher struct

+ func NewKubeMatcher(verify *Verify, ctx context.Context) *KubeMatcher

+ func (m *KubeMatcher) BeDeleted() types.GomegaMatcher

+ func (m *KubeMatcher) BeFailed(originalGeneration int64) types.GomegaMatcher

+ func (m *KubeMatcher) BeInState(status metav1.ConditionStatus, severity conditions.ConditionSeverity) types.GomegaMatcher

+ func (m *KubeMatcher) BeProvisioned(originalGeneration int64) types.GomegaMatcher

+ type KubePerTestContext struct

+ G gomega.Gomega

+ Match *KubeMatcher

+ Verify *Verify

+ func (tc *KubePerTestContext) AsExtensionOwner(obj client.Object) *genruntime.ArbitraryOwnerReference

+ func (tc *KubePerTestContext) CheckIfResourceExists(obj client.Object) error

+ func (tc *KubePerTestContext) CreateResource(obj client.Object)

+ func (tc *KubePerTestContext) CreateResourceAndWait(obj client.Object)

+ func (tc *KubePerTestContext) CreateResourceAndWaitForFailure(obj client.Object)

+ func (tc *KubePerTestContext) CreateResourceAndWaitForState(obj client.Object, status metav1.ConditionStatus, ...)

+ func (tc *KubePerTestContext) CreateResourceAndWaitWithoutCleanup(obj client.Object)

+ func (tc *KubePerTestContext) CreateResourceExpectRequestFailure(obj client.Object) error

+ func (tc *KubePerTestContext) CreateResourceGroup(rg *resources.ResourceGroup) (*resources.ResourceGroup, error)

+ func (tc *KubePerTestContext) CreateResourceGroupAndWait(rg *resources.ResourceGroup) *resources.ResourceGroup

+ func (tc *KubePerTestContext) CreateResourceUntracked(obj client.Object)

+ func (tc *KubePerTestContext) CreateResourcesAndWait(objs ...client.Object)

+ func (tc *KubePerTestContext) CreateTestNamespaces(names ...string) error

+ func (tc *KubePerTestContext) CreateTestResourceGroupAndWait() *resources.ResourceGroup

+ func (tc *KubePerTestContext) DefaultOperationTimeout() time.Duration

+ func (tc *KubePerTestContext) DeleteResource(obj client.Object)

+ func (tc *KubePerTestContext) DeleteResourceAndWait(obj client.Object)

+ func (tc *KubePerTestContext) DeleteResourcesAndWait(objs ...client.Object)

+ func (tc *KubePerTestContext) Eventually(actual interface{}, intervals ...interface{}) gomega.AsyncAssertion

+ func (tc *KubePerTestContext) Expect(actual interface{}) gomega.Assertion

+ func (tc *KubePerTestContext) ExpectConfigMapHasKeys(name string, expectedKeys ...string)

+ func (tc *KubePerTestContext) ExpectConfigMapHasKeysAndValues(name string, expectedKeysAndValues ...string)

+ func (tc *KubePerTestContext) ExpectResourceDoesNotExist(key types.NamespacedName, obj client.Object)

+ func (tc *KubePerTestContext) ExpectResourceIsDeletedInAzure(armId string, apiVersion string)

+ func (tc *KubePerTestContext) ExpectSecretHasKeys(name string, expectedKeys ...string)

+ func (tc *KubePerTestContext) ExportAsSample(resource client.Object)

+ func (tc *KubePerTestContext) GetResource(key types.NamespacedName, obj client.Object)

+ func (tc *KubePerTestContext) GetScheme() *runtime.Scheme

+ func (tc *KubePerTestContext) GetSecret(name string) *corev1.Secret

+ func (tc *KubePerTestContext) KubeClient() client.Client

+ func (tc *KubePerTestContext) ListResources(list client.ObjectList, opts ...client.ListOption)

+ func (tc *KubePerTestContext) LogSection(section string)

+ func (tc *KubePerTestContext) OperationTimeout() time.Duration

+ func (tc *KubePerTestContext) Patch(old client.Object, new client.Object)

+ func (tc *KubePerTestContext) PatchAndExpectError(old client.Object, new client.Object) error

+ func (tc *KubePerTestContext) PatchResourceAndWait(old client.Object, new client.Object)

+ func (tc *KubePerTestContext) PatchStatus(old client.Object, new client.Object)

+ func (tc *KubePerTestContext) PollingInterval() time.Duration

+ func (tc *KubePerTestContext) RunParallelSubtests(tests ...Subtest)

+ func (tc *KubePerTestContext) RunSubtests(tests ...Subtest)

+ func (tc *KubePerTestContext) Subtest(t *testing.T) *KubePerTestContext

+ func (tc *KubePerTestContext) UpdateResource(obj client.Object)

+ func (tc KubePerTestContext) CreateTestNamespace(namespaceName string) error

+ func (tc KubePerTestContext) MakeObjectMeta(prefix string) ctrl.ObjectMeta

+ func (tc KubePerTestContext) MakeObjectMetaWithName(name string) ctrl.ObjectMeta

+ func (tc KubePerTestContext) MakeReferenceFromResource(resource client.Object) *genruntime.ResourceReference

+ func (tc KubePerTestContext) NewTestResourceGroup() *resources.ResourceGroup

+ type MockTokenCredential struct

+ func (MockTokenCredential) GetToken(context.Context, policy.TokenRequestOptions) (azcore.AccessToken, error)

+ func (MockTokenCredential) NewAuthenticationPolicy() policy.Policy

+ type PerTestContext struct

+ AzureBillingInvoiceID string

+ AzureClient *genericarmclient.GenericClient

+ AzureClientRecorder *recorder.Recorder

+ AzureMatch *ARMMatcher

+ AzureSubscription string

+ AzureTenant string

+ CountsTowardsParallelLimits bool

+ Ctx context.Context

+ HttpClient *http.Client

+ Namer ResourceNamer

+ Namespace string

+ NoSpaceNamer ResourceNamer

+ T *testing.T

+ TestName string

+ func (tc PerTestContext) GenerateSSHKey(size int) (*string, error)

+ func (tc PerTestContext) NewTestResourceGroup() *resources.ResourceGroup

+ type PolicyFunc func(*policy.Request) (*http.Response, error)

+ func (pf PolicyFunc) Do(req *policy.Request) (*http.Response, error)

+ type ResourceNameConfig struct

+ func NewResourceNameConfig(prefix string, separator string, randomChars int, mode ResourceNamerMode) *ResourceNameConfig

+ func (rnc ResourceNameConfig) NewResourceNamer(testName string) ResourceNamer

+ type ResourceNamer struct

+ func (n ResourceNamer) GenerateName(prefix string) string

+ func (n ResourceNamer) GeneratePassword() string

+ func (n ResourceNamer) GeneratePasswordOfLength(length int) string

+ func (n ResourceNamer) GenerateUUID() (uuid.UUID, error)

+ func (n ResourceNamer) WithNumRandomChars(num int) ResourceNamer

+ func (n ResourceNamer) WithSeparator(separator string) ResourceNamer

+ func (n ResourceNamer) WithTestName(testName string) ResourceNamer

+ type ResourceNamerMode string

+ type ResourceTracker struct

+ func (r *ResourceTracker) Resources() []client.Object

+ func (r *ResourceTracker) Track(obj client.Object)

+ type SampleObject struct

+ RefsMap map[string]genruntime.ARMMetaObject

+ SamplesMap map[string]genruntime.ARMMetaObject

+ func NewSampleObject() *SampleObject

+ type SamplesTester struct

+ func NewSamplesTester(noSpaceNamer ResourceNamer, scheme *runtime.Scheme, groupVersionPath string, ...) *SamplesTester

+ func (t *SamplesTester) LoadSamples() (*SampleObject, error)

+ type SimpleExtensionResource struct

+ Spec SimpleExtensionResourceSpec

+ Status SimpleExtensionResourceStatus

+ func (r *SimpleExtensionResource) AzureName() string

+ func (r *SimpleExtensionResource) DeepCopyObject() runtime.Object

+ func (r *SimpleExtensionResource) Default()

+ func (r *SimpleExtensionResource) GetAPIVersion() string

+ func (r *SimpleExtensionResource) GetConditions() conditions.Conditions

+ func (r *SimpleExtensionResource) GetResourceScope() genruntime.ResourceScope

+ func (r *SimpleExtensionResource) GetSpec() genruntime.ConvertibleSpec

+ func (r *SimpleExtensionResource) GetStatus() genruntime.ConvertibleStatus

+ func (r *SimpleExtensionResource) GetType() string

+ func (r *SimpleExtensionResource) NewEmptyStatus() genruntime.ConvertibleStatus

+ func (r *SimpleExtensionResource) Owner() *genruntime.ResourceReference

+ func (r *SimpleExtensionResource) SetConditions(conditions conditions.Conditions)

+ func (r *SimpleExtensionResource) SetStatus(status genruntime.ConvertibleStatus) error

+ type SimpleExtensionResourceSpec struct

+ AzureName string

+ Owner genruntime.ResourceReference

+ func (s SimpleExtensionResourceSpec) ConvertSpecFrom(source genruntime.ConvertibleSpec) error

+ func (s SimpleExtensionResourceSpec) ConvertSpecTo(destination genruntime.ConvertibleSpec) error

+ type SimpleExtensionResourceStatus struct

+ Conditions []conditions.Condition

+ func (s SimpleExtensionResourceStatus) ConvertStatusFrom(source genruntime.ConvertibleStatus) error

+ func (s SimpleExtensionResourceStatus) ConvertStatusTo(destination genruntime.ConvertibleStatus) error

+ type Subtest struct

+ Name string

+ Test func(testContext *KubePerTestContext)

+ type TestContext struct

+ AzureRegion *string

+ NameConfig *ResourceNameConfig

+ RecordReplay bool

+ func NewTestContext(region string, recordReplay bool, nameConfig *ResourceNameConfig) TestContext

+ func (tc TestContext) ForTest(t *testing.T, cfg config.Values) (PerTestContext, error)

+ type TestLogger struct

+ func (_ TestLogger) Init(info logr.RuntimeInfo)

+ func (t *TestLogger) Enabled(_level int) bool

+ func (t *TestLogger) Error(err error, msg string, keysAndValues ...interface{})

+ func (t *TestLogger) Info(level int, msg string, keysAndValues ...interface{})

+ func (t *TestLogger) V(level int) logr.Logger

+ func (t *TestLogger) WithName(name string) logr.LogSink

+ func (t *TestLogger) WithValues(keysAndValues ...interface{}) logr.LogSink

+ type Verify struct

+ func NewVerify(c client.Client) *Verify

+ func (e *Verify) AllDeleted(ctx context.Context, objs []client.Object) (bool, error)

+ func (e *Verify) Deleted(ctx context.Context, obj client.Object) (bool, error)

+ func (e *Verify) HasState(ctx context.Context, obj client.Object, desiredState metav1.ConditionStatus, ...) (bool, error)

+ type WaitCondition bool

+ const DoNotWait

+ const WaitForCreation

v2.0.0-beta.5

Feb 28, 2023

v2.0.0-beta.4

Dec 15, 2022

v2.0.0-beta.3

Oct 21, 2022

v2.0.0-beta.2

Aug 15, 2022

v2.0.0-beta.1

Jun 29, 2022

v2.0.0-beta.0

Apr 12, 2022

v2.0.0-alpha.6

Feb 15, 2022

v2.0.0-alpha.5

Dec 20, 2021

v2.0.0-alpha.4

Dec 8, 2021

v2.0.0-alpha.3

Nov 2, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL