testutils

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2026 License: Apache-2.0 Imports: 38 Imported by: 0

Documentation

Overview

Package testutils provides test utilities for crossplane-diff.

Index

Constants

View Source 
const (
	ColorRed    = "\x1b[31m"
	ColorGreen  = "\x1b[32m"
	ColorYellow = "\x1b[33m"
	ColorReset  = "\x1b[0m"
)

Colors for terminal output.

Variables

This section is empty.

Functions

func AssertStructuredCompDiff added in v0.7.0 

func AssertStructuredCompDiff(t *testing.T, jsonOutput string, e CompDiffExpectation)

AssertStructuredCompDiff compares actual JSON output against expected. Accepts CompDiffExpectation interface so callers don't need to call And()/AndXR()/AndComp().

func AssertStructuredDiff added in v0.7.0 

func AssertStructuredDiff(t *testing.T, jsonOutput string, e DiffExpectation)

AssertStructuredDiff compares actual JSON output against expected. Accepts DiffExpectation interface so callers don't need to call And() to return to root.

func CompareIgnoringAnsi 

func CompareIgnoringAnsi(expected, actual string) bool

CompareIgnoringAnsi compares two strings after stripping ANSI special characters.

func CreateFakeDiscoveryClient 

func CreateFakeDiscoveryClient(resources map[string][]metav1.APIResource) discovery.DiscoveryInterface

CreateFakeDiscoveryClient is a helper function to create a fake discovery client for testing. The fake discovery client automatically derives API groups from the provided resources, enabling both ServerResourcesForGroupVersion() and ServerGroups() to work correctly.

func Green 

func Green(input string) string

Green takes a multiline string, splits it by line, and adds green coloring to each line. It returns a single string with all lines joined back together.

func Red 

func Red(input string) string

Red takes a multiline string, splits it by line, and adds red coloring to each line. It returns a single string with all lines joined back together.

func SetupKubeTestLogger 

func SetupKubeTestLogger(t *testing.T)

SetupKubeTestLogger sets the global logger for use of the Kube environment to the T.Log of this test.

func TestLogger 

func TestLogger(t *testing.T, verbose bool) logging.Logger

TestLogger coerces the T.Log into the shape of a Logr logger.

func Yellow added in v0.5.0 

func Yellow(input string) string

Yellow takes a multiline string, splits it by line, and adds yellow coloring to each line. It returns a single string with all lines joined back together.

Types

type AffectedResourcesSummary added in v0.7.0 

type AffectedResourcesSummary struct {
	Total            int `json:"total"`
	WithChanges      int `json:"withChanges"`
	Unchanged        int `json:"unchanged"`
	WithErrors       int `json:"withErrors"`
	FilteredByPolicy int `json:"filteredByPolicy,omitempty"`
}

AffectedResourcesSummary mirrors renderer.AffectedResourcesSummary.

type CRDBuilder added in v0.2.0 

type CRDBuilder struct {
	// contains filtered or unexported fields
}

CRDBuilder helps construct CRD resources for testing.

func NewCRD added in v0.2.0 

func NewCRD(name, group, kind string) *CRDBuilder

NewCRD creates a new CRDBuilder.

func (*CRDBuilder) Build added in v0.2.0 

func (b *CRDBuilder) Build() *extv1.CustomResourceDefinition

Build returns the built CRD.

func (*CRDBuilder) WithClusterScope added in v0.2.0 

func (b *CRDBuilder) WithClusterScope() *CRDBuilder

WithClusterScope sets the CRD to be cluster-scoped.

func (*CRDBuilder) WithDefaultVersion added in v0.3.0 

func (b *CRDBuilder) WithDefaultVersion() *CRDBuilder

WithDefaultVersion adds a default "v1" version to the CRD.

func (*CRDBuilder) WithListKind added in v0.2.0 

func (b *CRDBuilder) WithListKind(listKind string) *CRDBuilder

WithListKind sets the ListKind name for the CRD.

func (*CRDBuilder) WithNamespaceScope added in v0.2.0 

func (b *CRDBuilder) WithNamespaceScope() *CRDBuilder

WithNamespaceScope sets the CRD to be namespace-scoped.

func (*CRDBuilder) WithPlural added in v0.2.0 

func (b *CRDBuilder) WithPlural(plural string) *CRDBuilder

WithPlural sets the plural name for the CRD.

func (*CRDBuilder) WithSchema added in v0.2.0 

func (b *CRDBuilder) WithSchema(schema *extv1.JSONSchemaProps) *CRDBuilder

WithSchema adds an OpenAPI v3 schema to the last added version.

func (*CRDBuilder) WithScope added in v0.2.0 

func (b *CRDBuilder) WithScope(scope extv1.ResourceScope) *CRDBuilder

WithScope sets the scope (Namespaced or Cluster) for the CRD.

func (*CRDBuilder) WithSingular added in v0.2.0 

func (b *CRDBuilder) WithSingular(singular string) *CRDBuilder

WithSingular sets the singular name for the CRD.

func (*CRDBuilder) WithStandardSchema added in v0.2.0 

func (b *CRDBuilder) WithStandardSchema(specFieldName string) *CRDBuilder

WithStandardSchema adds a standard schema with common Kubernetes fields and a spec field.

func (*CRDBuilder) WithStringFieldSchema added in v0.2.0 

func (b *CRDBuilder) WithStringFieldSchema(fieldName string) *CRDBuilder

WithStringFieldSchema adds a simple string field schema to the CRD.

func (*CRDBuilder) WithVersion added in v0.2.0 

func (b *CRDBuilder) WithVersion(name string, served, storage bool) *CRDBuilder

WithVersion adds a version to the CRD.

type ChangeDetail added in v0.7.0 

type ChangeDetail struct {
	Type       string         `json:"type"`
	APIVersion string         `json:"apiVersion"`
	Kind       string         `json:"kind"`
	Name       string         `json:"name"`
	Namespace  string         `json:"namespace,omitempty"`
	Diff       map[string]any `json:"diff"`
}

ChangeDetail mirrors renderer.ChangeDetail.

type CompDiffExpectation added in v0.7.0 

type CompDiffExpectation interface {
	// contains filtered or unexported methods
}

CompDiffExpectation is an interface that allows AssertStructuredCompDiff to accept any level of the builder hierarchy, eliminating the need for And()/AndXR()/AndComp().

type CompositionBuilder 

type CompositionBuilder struct {
	// contains filtered or unexported fields
}

CompositionBuilder helps construct Composition objects for testing.

func NewComposition 

func NewComposition(name string) *CompositionBuilder

NewComposition creates a new CompositionBuilder.

func (*CompositionBuilder) Build 

func (b *CompositionBuilder) Build() *xpextv1.Composition

Build returns the built Composition.

func (*CompositionBuilder) BuildAsUnstructured added in v0.2.0 

func (b *CompositionBuilder) BuildAsUnstructured() *un.Unstructured

BuildAsUnstructured returns the built Composition as an unstructured object.

func (*CompositionBuilder) WithCompositeTypeRef 

func (b *CompositionBuilder) WithCompositeTypeRef(apiVersion, kind string) *CompositionBuilder

WithCompositeTypeRef sets the composite type reference.

func (*CompositionBuilder) WithPipelineMode 

func (b *CompositionBuilder) WithPipelineMode() *CompositionBuilder

WithPipelineMode sets the composition mode to pipeline.

func (*CompositionBuilder) WithPipelineStep 

func (b *CompositionBuilder) WithPipelineStep(step, functionName string, input map[string]any, opts ...PipelineStepOption) *CompositionBuilder

WithPipelineStep adds a pipeline step to the composition.

type CompositionDiffJSON added in v0.7.0 

type CompositionDiffJSON struct {
	Name               string                   `json:"name"`
	Error              string                   `json:"error,omitempty"`
	CompositionChanges *ChangeDetail            `json:"compositionChanges,omitempty"`
	AffectedResources  AffectedResourcesSummary `json:"affectedResources"`
	ImpactAnalysis     []XRImpactJSON           `json:"impactAnalysis"`
}

CompositionDiffJSON mirrors compositionDiffJSON from the renderer.

type CompositionExpectation added in v0.7.0 

type CompositionExpectation struct {
	// contains filtered or unexported fields
}

CompositionExpectation defines expectations for a single composition in the diff.

func (*CompositionExpectation) And added in v0.7.0 

func (c *CompositionExpectation) And() *ExpectedCompDiff

And returns to parent to chain more composition expectations. Not needed at the end of a chain - AssertStructuredCompDiff accepts CompositionExpectation directly.

func (*CompositionExpectation) WithAffectedResources added in v0.7.0 

func (c *CompositionExpectation) WithAffectedResources(total, withChanges, unchanged, withErrors int) *CompositionExpectation

WithAffectedResources sets the expected affected resources counts.

func (*CompositionExpectation) WithCompositionFieldChange added in v0.7.0 

func (c *CompositionExpectation) WithCompositionFieldChange(path string, oldValue, newValue any) *CompositionExpectation

WithCompositionFieldChange asserts a specific field in the composition changed from old to new value.

func (*CompositionExpectation) WithCompositionModified added in v0.7.0 

func (c *CompositionExpectation) WithCompositionModified() *CompositionExpectation

WithCompositionModified asserts that the composition itself is modified.

func (*CompositionExpectation) WithXRImpact added in v0.7.0 

func (c *CompositionExpectation) WithXRImpact(kind, name, namespace, status string) *XRImpactExpectation

WithXRImpact adds an expectation for an XR impact.

type DiffExpectation added in v0.7.0 

type DiffExpectation interface {
	// contains filtered or unexported methods
}

DiffExpectation is an interface that allows AssertStructuredDiff to accept either *ExpectedDiff or *ResourceExpectation, eliminating the need for And().

type DiffProcessor 

type DiffProcessor interface {
	Initialize(ctx context.Context) error
	ProcessAll(stdout io.Writer, ctx context.Context, resources []*un.Unstructured) error
	ProcessResource(stdout io.Writer, ctx context.Context, res *un.Unstructured) error
}

DiffProcessor defines the interface for processing resources for diffing.

type DiffProcessorBuilder 

type DiffProcessorBuilder struct {
	// contains filtered or unexported fields
}

DiffProcessorBuilder helps build mock DiffProcessor instances.

func NewMockDiffProcessor 

func NewMockDiffProcessor() *DiffProcessorBuilder

NewMockDiffProcessor creates a new DiffProcessorBuilder.

func (*DiffProcessorBuilder) Build 

func (b *DiffProcessorBuilder) Build() *MockDiffProcessor

Build creates and returns the configured mock DiffProcessor.

func (*DiffProcessorBuilder) WithDiffOutput 

func (b *DiffProcessorBuilder) WithDiffOutput(output string) *DiffProcessorBuilder

WithDiffOutput sets a PerformDiff implementation that writes a specific output.

func (*DiffProcessorBuilder) WithFailedInitialize 

func (b *DiffProcessorBuilder) WithFailedInitialize(errMsg string) *DiffProcessorBuilder

WithFailedInitialize sets a failing Initialize implementation.

func (*DiffProcessorBuilder) WithFailedPerformDiff 

func (b *DiffProcessorBuilder) WithFailedPerformDiff(errMsg string) *DiffProcessorBuilder

WithFailedPerformDiff sets a failing PerformDiff implementation.

func (*DiffProcessorBuilder) WithInitialize 

func (b *DiffProcessorBuilder) WithInitialize(fn func(context.Context) error) *DiffProcessorBuilder

WithInitialize adds an implementation for the Initialize method.

func (*DiffProcessorBuilder) WithPerformDiff 

func (b *DiffProcessorBuilder) WithPerformDiff(fn func(context.Context, io.Writer, []*un.Unstructured, dtypes.CompositionProvider) (bool, error)) *DiffProcessorBuilder

WithPerformDiff adds an implementation for the PerformDiff method.

func (*DiffProcessorBuilder) WithSuccessfulInitialize 

func (b *DiffProcessorBuilder) WithSuccessfulInitialize() *DiffProcessorBuilder

WithSuccessfulInitialize sets a successful Initialize implementation.

func (*DiffProcessorBuilder) WithSuccessfulPerformDiff 

func (b *DiffProcessorBuilder) WithSuccessfulPerformDiff() *DiffProcessorBuilder

WithSuccessfulPerformDiff sets a successful PerformDiff implementation with no diffs.

func (*DiffProcessorBuilder) WithSuccessfulPerformDiffWithChanges added in v0.6.0 

func (b *DiffProcessorBuilder) WithSuccessfulPerformDiffWithChanges() *DiffProcessorBuilder

WithSuccessfulPerformDiffWithChanges sets a successful PerformDiff implementation with diffs.

type DownstreamChanges added in v0.7.0 

type DownstreamChanges struct {
	Summary Summary        `json:"summary"`
	Changes []ChangeDetail `json:"changes"`
}

DownstreamChanges mirrors renderer.DownstreamChanges.

type DownstreamResourceExpectation added in v0.7.0 

type DownstreamResourceExpectation struct {
	// contains filtered or unexported fields
}

DownstreamResourceExpectation defines expectations for a downstream resource change.

func (*DownstreamResourceExpectation) AndXR added in v0.7.0 

func (d *DownstreamResourceExpectation) AndXR() *XRImpactExpectation

AndXR returns to parent to chain more downstream resource expectations. Not needed at the end of a chain - AssertStructuredCompDiff accepts DownstreamResourceExpectation directly.

func (*DownstreamResourceExpectation) WithAnyName added in v0.7.0 

func (d *DownstreamResourceExpectation) WithAnyName() *DownstreamResourceExpectation

WithAnyName allows any resource name (useful for generated names).

func (*DownstreamResourceExpectation) WithField added in v0.7.0 

func (d *DownstreamResourceExpectation) WithField(path string, value any) *DownstreamResourceExpectation

WithField asserts a specific field exists with exact value (for added/removed resources).

func (*DownstreamResourceExpectation) WithFieldAdded added in v0.7.0 

func (d *DownstreamResourceExpectation) WithFieldAdded(path string, value any) *DownstreamResourceExpectation

WithFieldAdded asserts a field was added (for modified resources). Equivalent to WithFieldChange(path, nil, value).

func (*DownstreamResourceExpectation) WithFieldChange added in v0.7.0 

func (d *DownstreamResourceExpectation) WithFieldChange(path string, oldValue, newValue any) *DownstreamResourceExpectation

WithFieldChange asserts a field changed from old to new value (for modified resources).

func (*DownstreamResourceExpectation) WithFieldRemoved added in v0.7.0 

func (d *DownstreamResourceExpectation) WithFieldRemoved(path string, value any) *DownstreamResourceExpectation

WithFieldRemoved asserts a field was removed (for modified resources). Equivalent to WithFieldChange(path, value, nil).

func (*DownstreamResourceExpectation) WithFieldValuePattern added in v0.7.0 

func (d *DownstreamResourceExpectation) WithFieldValuePattern(path, pattern string) *DownstreamResourceExpectation

WithFieldValuePattern asserts a field value matches a regex pattern. Use this for fields with generated/dynamic values like resource names with random suffixes.

func (*DownstreamResourceExpectation) WithNamePattern added in v0.7.0 

func (d *DownstreamResourceExpectation) WithNamePattern(pattern string) *DownstreamResourceExpectation

WithNamePattern matches resource name against a regex pattern.

type ExpectedCompDiff added in v0.7.0 

type ExpectedCompDiff struct {
	// contains filtered or unexported fields
}

ExpectedCompDiff is a fluent builder for test expectations on composition diff output.

func ExpectCompDiff added in v0.7.0 

func ExpectCompDiff() *ExpectedCompDiff

ExpectCompDiff creates a new ExpectedCompDiff builder.

func (*ExpectedCompDiff) WithComposition added in v0.7.0 

func (e *ExpectedCompDiff) WithComposition(name string) *CompositionExpectation

WithComposition adds an expectation for a composition.

type ExpectedDiff added in v0.7.0 

type ExpectedDiff struct {
	// contains filtered or unexported fields
}

ExpectedDiff is a fluent builder for test expectations on structured diff output.

func ExpectDiff added in v0.7.0 

func ExpectDiff() *ExpectedDiff

ExpectDiff creates a new ExpectedDiff builder.

func (*ExpectedDiff) WithAddedResource added in v0.7.0 

func (e *ExpectedDiff) WithAddedResource(kind, name, namespace string) *ResourceExpectation

WithAddedResource adds an expectation for an added resource.

func (*ExpectedDiff) WithModifiedResource added in v0.7.0 

func (e *ExpectedDiff) WithModifiedResource(kind, name, namespace string) *ResourceExpectation

WithModifiedResource adds an expectation for a modified resource.

func (*ExpectedDiff) WithRemovedResource added in v0.7.0 

func (e *ExpectedDiff) WithRemovedResource(kind, name, namespace string) *ResourceExpectation

WithRemovedResource adds an expectation for a removed resource.

func (*ExpectedDiff) WithSummary added in v0.7.0 

func (e *ExpectedDiff) WithSummary(added, modified, removed int) *ExpectedDiff

WithSummary sets the expected summary counts.

type MockApplyClient 

type MockApplyClient struct {
	InitializeFn  func(ctx context.Context) error
	ApplyFn       func(ctx context.Context, obj *un.Unstructured) (*un.Unstructured, error)
	DryRunApplyFn func(ctx context.Context, obj *un.Unstructured, fieldOwner string) (*un.Unstructured, error)
}

MockApplyClient implements the kubernetes.ApplyClient interface.

func (*MockApplyClient) Apply 

func (m *MockApplyClient) Apply(ctx context.Context, obj *un.Unstructured) (*un.Unstructured, error)

Apply implements kubernetes.ApplyClient.

func (*MockApplyClient) DryRunApply 

func (m *MockApplyClient) DryRunApply(ctx context.Context, obj *un.Unstructured, fieldOwner string) (*un.Unstructured, error)

DryRunApply implements kubernetes.ApplyClient.

func (*MockApplyClient) Initialize 

func (m *MockApplyClient) Initialize(ctx context.Context) error

Initialize implements kubernetes.ApplyClient.

type MockApplyClientBuilder 

type MockApplyClientBuilder struct {
	// contains filtered or unexported fields
}

MockApplyClientBuilder helps build kubernetes.ApplyClient mocks.

func NewMockApplyClient 

func NewMockApplyClient() *MockApplyClientBuilder

NewMockApplyClient creates a new MockApplyClientBuilder.

func (*MockApplyClientBuilder) Build 

func (b *MockApplyClientBuilder) Build() *MockApplyClient

Build returns the built mock.

func (*MockApplyClientBuilder) WithApply 

func (b *MockApplyClientBuilder) WithApply(fn func(context.Context, *un.Unstructured) (*un.Unstructured, error)) *MockApplyClientBuilder

WithApply sets the Apply behavior.

func (*MockApplyClientBuilder) WithDryRunApply 

func (b *MockApplyClientBuilder) WithDryRunApply(fn func(context.Context, *un.Unstructured, string) (*un.Unstructured, error)) *MockApplyClientBuilder

WithDryRunApply sets the DryRunApply behavior.

func (*MockApplyClientBuilder) WithFailedDryRun 

func (b *MockApplyClientBuilder) WithFailedDryRun(errMsg string) *MockApplyClientBuilder

WithFailedDryRun sets DryRunApply to return an error.

func (*MockApplyClientBuilder) WithInitialize 

func (b *MockApplyClientBuilder) WithInitialize(fn func(context.Context) error) *MockApplyClientBuilder

WithInitialize sets the Initialize behavior.

func (*MockApplyClientBuilder) WithSuccessfulDryRun 

func (b *MockApplyClientBuilder) WithSuccessfulDryRun() *MockApplyClientBuilder

WithSuccessfulDryRun sets DryRunApply to return the input resource.

type MockCompositionClient 

type MockCompositionClient struct {
	InitializeFn                     func(ctx context.Context) error
	FindMatchingCompositionFn        func(ctx context.Context, res *un.Unstructured) (*xpextv1.Composition, error)
	ListCompositionsFn               func(ctx context.Context) ([]*xpextv1.Composition, error)
	GetCompositionFn                 func(ctx context.Context, name string) (*xpextv1.Composition, error)
	FindCompositesUsingCompositionFn func(ctx context.Context, compositionName string, namespace string) ([]*un.Unstructured, error)
}

MockCompositionClient implements the crossplane.CompositionClient interface.

func (*MockCompositionClient) FindCompositesUsingComposition added in v0.5.0 

func (m *MockCompositionClient) FindCompositesUsingComposition(ctx context.Context, compositionName string, namespace string) ([]*un.Unstructured, error)

FindCompositesUsingComposition implements crossplane.CompositionClient.

func (*MockCompositionClient) FindMatchingComposition 

func (m *MockCompositionClient) FindMatchingComposition(ctx context.Context, res *un.Unstructured) (*xpextv1.Composition, error)

FindMatchingComposition implements crossplane.CompositionClient.

func (*MockCompositionClient) GetComposition 

func (m *MockCompositionClient) GetComposition(ctx context.Context, name string) (*xpextv1.Composition, error)

GetComposition implements crossplane.CompositionClient.

func (*MockCompositionClient) Initialize 

func (m *MockCompositionClient) Initialize(ctx context.Context) error

Initialize implements crossplane.CompositionClient.

func (*MockCompositionClient) ListCompositions 

func (m *MockCompositionClient) ListCompositions(ctx context.Context) ([]*xpextv1.Composition, error)

ListCompositions implements crossplane.CompositionClient.

type MockCompositionClientBuilder 

type MockCompositionClientBuilder struct {
	// contains filtered or unexported fields
}

MockCompositionClientBuilder helps build crossplane.CompositionClient mocks.

func NewMockCompositionClient 

func NewMockCompositionClient() *MockCompositionClientBuilder

NewMockCompositionClient creates a new MockCompositionClientBuilder.

func (*MockCompositionClientBuilder) Build 

func (b *MockCompositionClientBuilder) Build() *MockCompositionClient

Build returns the built mock.

func (*MockCompositionClientBuilder) WithComposition added in v0.3.0 

func (b *MockCompositionClientBuilder) WithComposition(comp *xpextv1.Composition) *MockCompositionClientBuilder

WithComposition is an alias for WithSuccessfulCompositionMatch for convenience.

func (*MockCompositionClientBuilder) WithFailedInitialize 

func (b *MockCompositionClientBuilder) WithFailedInitialize(errMsg string) *MockCompositionClientBuilder

WithFailedInitialize mocks a failed call to Initialize.

func (*MockCompositionClientBuilder) WithFindCompositesUsingComposition added in v0.5.0 

func (b *MockCompositionClientBuilder) WithFindCompositesUsingComposition(fn func(context.Context, string, string) ([]*un.Unstructured, error)) *MockCompositionClientBuilder

WithFindCompositesUsingComposition sets the FindCompositesUsingComposition behavior.

func (*MockCompositionClientBuilder) WithFindMatchingComposition 

func (b *MockCompositionClientBuilder) WithFindMatchingComposition(fn func(context.Context, *un.Unstructured) (*xpextv1.Composition, error)) *MockCompositionClientBuilder

WithFindMatchingComposition sets the FindMatchingComposition behavior.

func (*MockCompositionClientBuilder) WithFindResourcesError added in v0.5.0 

func (b *MockCompositionClientBuilder) WithFindResourcesError(errMsg string) *MockCompositionClientBuilder

WithFindResourcesError sets FindCompositesUsingComposition to return an error.

func (*MockCompositionClientBuilder) WithGetComposition 

func (b *MockCompositionClientBuilder) WithGetComposition(fn func(context.Context, string) (*xpextv1.Composition, error)) *MockCompositionClientBuilder

WithGetComposition sets the GetComposition behavior.

func (*MockCompositionClientBuilder) WithInitialize 

func (b *MockCompositionClientBuilder) WithInitialize(fn func(context.Context) error) *MockCompositionClientBuilder

WithInitialize sets the Initialize behavior.

func (*MockCompositionClientBuilder) WithListCompositions 

func (b *MockCompositionClientBuilder) WithListCompositions(fn func(context.Context) ([]*xpextv1.Composition, error)) *MockCompositionClientBuilder

WithListCompositions sets the ListCompositions behavior.

func (*MockCompositionClientBuilder) WithNoMatchingComposition 

func (b *MockCompositionClientBuilder) WithNoMatchingComposition() *MockCompositionClientBuilder

WithNoMatchingComposition sets FindMatchingComposition to return "not found".

func (*MockCompositionClientBuilder) WithResourcesForComposition added in v0.5.0 

func (b *MockCompositionClientBuilder) WithResourcesForComposition(compositionName, namespace string, resources []*un.Unstructured) *MockCompositionClientBuilder

WithResourcesForComposition sets FindCompositesUsingComposition to return specific resources for a given composition name and namespace.

func (*MockCompositionClientBuilder) WithSuccessfulCompositionFetch added in v0.2.0 

func (b *MockCompositionClientBuilder) WithSuccessfulCompositionFetch(comp *xpextv1.Composition) *MockCompositionClientBuilder

WithSuccessfulCompositionFetch sets up a successful composition fetch.

func (*MockCompositionClientBuilder) WithSuccessfulCompositionFetches added in v0.2.0 

func (b *MockCompositionClientBuilder) WithSuccessfulCompositionFetches(comps []*xpextv1.Composition) *MockCompositionClientBuilder

WithSuccessfulCompositionFetches sets up successful composition fetches for multiple compositions.

func (*MockCompositionClientBuilder) WithSuccessfulCompositionMatch 

func (b *MockCompositionClientBuilder) WithSuccessfulCompositionMatch(comp *xpextv1.Composition) *MockCompositionClientBuilder

WithSuccessfulCompositionMatch sets FindMatchingComposition to return a specific composition.

func (*MockCompositionClientBuilder) WithSuccessfulInitialize 

func (b *MockCompositionClientBuilder) WithSuccessfulInitialize() *MockCompositionClientBuilder

WithSuccessfulInitialize mocks a successful call to Initialize.

type MockCompositionProvider added in v0.5.0 

type MockCompositionProvider struct {
	GetCompositionFn func() (*xpextv1.Composition, error)
}

MockCompositionProvider provides a mock implementation for CompositionProvider.

func (*MockCompositionProvider) GetComposition added in v0.5.0 

func (m *MockCompositionProvider) GetComposition() (*xpextv1.Composition, error)

GetComposition implements GetComposition from the CompositionProvider interface.

type MockCredentialClient added in v0.6.0 

type MockCredentialClient struct {
	FetchCompositionCredentialsFn func(ctx context.Context, comp *xpextv1.Composition) []corev1.Secret
}

MockCredentialClient implements the crossplane.CredentialClient interface.

func (*MockCredentialClient) FetchCompositionCredentials added in v0.6.0 

func (m *MockCredentialClient) FetchCompositionCredentials(ctx context.Context, comp *xpextv1.Composition) []corev1.Secret

FetchCompositionCredentials implements crossplane.CredentialClient.

type MockDefinitionClient 

type MockDefinitionClient struct {
	InitializeFn      func(ctx context.Context) error
	GetXRDsFn         func(ctx context.Context) ([]*un.Unstructured, error)
	GetXRDForClaimFn  func(ctx context.Context, gvk schema.GroupVersionKind) (*un.Unstructured, error)
	GetXRDForXRFn     func(ctx context.Context, gvk schema.GroupVersionKind) (*un.Unstructured, error)
	IsClaimResourceFn func(ctx context.Context, resource *un.Unstructured) bool
}

MockDefinitionClient implements the crossplane.DefinitionClient interface.

func (*MockDefinitionClient) GetXRDForClaim 

func (m *MockDefinitionClient) GetXRDForClaim(ctx context.Context, gvk schema.GroupVersionKind) (*un.Unstructured, error)

GetXRDForClaim implements crossplane.DefinitionClient.

func (*MockDefinitionClient) GetXRDForXR 

func (m *MockDefinitionClient) GetXRDForXR(ctx context.Context, gvk schema.GroupVersionKind) (*un.Unstructured, error)

GetXRDForXR implements crossplane.DefinitionClient.

func (*MockDefinitionClient) GetXRDs 

func (m *MockDefinitionClient) GetXRDs(ctx context.Context) ([]*un.Unstructured, error)

GetXRDs implements crossplane.DefinitionClient.

func (*MockDefinitionClient) Initialize 

func (m *MockDefinitionClient) Initialize(ctx context.Context) error

Initialize implements crossplane.DefinitionClient.

func (*MockDefinitionClient) IsClaimResource added in v0.2.0 

func (m *MockDefinitionClient) IsClaimResource(ctx context.Context, resource *un.Unstructured) bool

IsClaimResource implements crossplane.DefinitionClient.

type MockDefinitionClientBuilder 

type MockDefinitionClientBuilder struct {
	// contains filtered or unexported fields
}

MockDefinitionClientBuilder helps build crossplane.DefinitionClient mocks.

func NewMockDefinitionClient 

func NewMockDefinitionClient() *MockDefinitionClientBuilder

NewMockDefinitionClient creates a new MockDefinitionClientBuilder.

func (*MockDefinitionClientBuilder) Build 

func (b *MockDefinitionClientBuilder) Build() *MockDefinitionClient

Build returns the built mock. If WithXRDForGVK was used to add XRD mappings, this will configure GetXRDForXR to use those mappings.

func (*MockDefinitionClientBuilder) WithEmptyXRDsFetch 

func (b *MockDefinitionClientBuilder) WithEmptyXRDsFetch() *MockDefinitionClientBuilder

WithEmptyXRDsFetch sets GetXRDs to return an empty set of XRDs.

func (*MockDefinitionClientBuilder) WithFailedInitialize 

func (b *MockDefinitionClientBuilder) WithFailedInitialize(errMsg string) *MockDefinitionClientBuilder

WithFailedInitialize mocks a failed call to Initialize.

func (*MockDefinitionClientBuilder) WithFailedXRDsFetch 

func (b *MockDefinitionClientBuilder) WithFailedXRDsFetch(errMsg string) *MockDefinitionClientBuilder

WithFailedXRDsFetch sets GetXRDs to return an error.

func (*MockDefinitionClientBuilder) WithGetXRDForClaim 

func (b *MockDefinitionClientBuilder) WithGetXRDForClaim(fn func(context.Context, schema.GroupVersionKind) (*un.Unstructured, error)) *MockDefinitionClientBuilder

WithGetXRDForClaim sets the GetXRDForClaim behavior.

func (*MockDefinitionClientBuilder) WithGetXRDForXR 

func (b *MockDefinitionClientBuilder) WithGetXRDForXR(fn func(context.Context, schema.GroupVersionKind) (*un.Unstructured, error)) *MockDefinitionClientBuilder

WithGetXRDForXR sets the GetXRDForXR behavior.

func (*MockDefinitionClientBuilder) WithGetXRDs 

func (b *MockDefinitionClientBuilder) WithGetXRDs(fn func(context.Context) ([]*un.Unstructured, error)) *MockDefinitionClientBuilder

WithGetXRDs sets the GetXRDs behavior.

func (*MockDefinitionClientBuilder) WithInitialize 

func (b *MockDefinitionClientBuilder) WithInitialize(fn func(context.Context) error) *MockDefinitionClientBuilder

WithInitialize sets the Initialize behavior.

func (*MockDefinitionClientBuilder) WithIsClaimResource added in v0.2.0 

func (b *MockDefinitionClientBuilder) WithIsClaimResource(fn func(context.Context, *un.Unstructured) bool) *MockDefinitionClientBuilder

WithIsClaimResource sets the IsClaimResource behavior.

func (*MockDefinitionClientBuilder) WithSuccessfulInitialize 

func (b *MockDefinitionClientBuilder) WithSuccessfulInitialize() *MockDefinitionClientBuilder

WithSuccessfulInitialize mocks a successful call to Initialize.

func (*MockDefinitionClientBuilder) WithSuccessfulXRDsFetch 

func (b *MockDefinitionClientBuilder) WithSuccessfulXRDsFetch(xrds []*un.Unstructured) *MockDefinitionClientBuilder

WithSuccessfulXRDsFetch sets GetXRDs to return specific XRDs.

func (*MockDefinitionClientBuilder) WithV1XRDForXR 

func (b *MockDefinitionClientBuilder) WithV1XRDForXR() *MockDefinitionClientBuilder

WithV1XRDForXR sets the GetXRDForXR behavior to return a v1 XRD.

func (*MockDefinitionClientBuilder) WithV2XRDForXR 

func (b *MockDefinitionClientBuilder) WithV2XRDForXR() *MockDefinitionClientBuilder

WithV2XRDForXR sets the GetXRDForXR behavior to return a v1 XRD.

func (*MockDefinitionClientBuilder) WithXRD added in v0.3.0 

func (b *MockDefinitionClientBuilder) WithXRD(xrd *xpextv1.CompositeResourceDefinition) *MockDefinitionClientBuilder

WithXRD sets the GetXRDForXR behavior to return the specified XRD for any GVK matching its group/kind.

func (*MockDefinitionClientBuilder) WithXRDForClaim 

func (b *MockDefinitionClientBuilder) WithXRDForClaim(unstructured *un.Unstructured) *MockDefinitionClientBuilder

WithXRDForClaim sets the GetXRDForXR behavior to return the specified XR.

func (*MockDefinitionClientBuilder) WithXRDForGVK added in v0.3.0 

func (b *MockDefinitionClientBuilder) WithXRDForGVK(gvk schema.GroupVersionKind, xrd *un.Unstructured) *MockDefinitionClientBuilder

WithXRDForGVK adds an XRD to be returned for a specific GVK. This method can be called multiple times to add different XRDs for different GVKs. When Build() is called, GetXRDForXR will use the accumulated XRD mappings.

func (*MockDefinitionClientBuilder) WithXRDForXR 

func (b *MockDefinitionClientBuilder) WithXRDForXR(unstructured *un.Unstructured) *MockDefinitionClientBuilder

WithXRDForXR sets the GetXRDForXR behavior to return the specified XR.

func (*MockDefinitionClientBuilder) WithXRDForXRError added in v0.3.0 

func (b *MockDefinitionClientBuilder) WithXRDForXRError(err error) *MockDefinitionClientBuilder

WithXRDForXRError sets GetXRDForXR to return the specified error.

func (*MockDefinitionClientBuilder) WithXRDForXRNotFound added in v0.3.0 

func (b *MockDefinitionClientBuilder) WithXRDForXRNotFound() *MockDefinitionClientBuilder

WithXRDForXRNotFound sets GetXRDForXR to return not found error for any GVK.

func (*MockDefinitionClientBuilder) WithXRDForXRNotFoundForGVK added in v0.3.0 

func (b *MockDefinitionClientBuilder) WithXRDForXRNotFoundForGVK(notFoundGVK schema.GroupVersionKind) *MockDefinitionClientBuilder

WithXRDForXRNotFoundForGVK sets GetXRDForXR to return not found for a specific GVK.

type MockDiffCalculator 

type MockDiffCalculator struct {
	CalculateDiffFn                 func(context.Context, *un.Unstructured, *un.Unstructured) (*dt.ResourceDiff, error)
	CalculateDiffsFn                func(context.Context, *cmp.Unstructured, render.Outputs) (map[string]*dt.ResourceDiff, error)
	CalculateNonRemovalDiffsFn      func(context.Context, *cmp.Unstructured, *un.Unstructured, render.Outputs) (map[string]*dt.ResourceDiff, map[string]bool, error)
	CalculateRemovedResourceDiffsFn func(context.Context, *un.Unstructured, map[string]bool) (map[string]*dt.ResourceDiff, error)
}

MockDiffCalculator is a mock implementation of DiffCalculator for testing.

func (*MockDiffCalculator) CalculateDiff 

func (m *MockDiffCalculator) CalculateDiff(ctx context.Context, composite *un.Unstructured, desired *un.Unstructured) (*dt.ResourceDiff, error)

CalculateDiff implements DiffCalculator.

func (*MockDiffCalculator) CalculateDiffs 

func (m *MockDiffCalculator) CalculateDiffs(ctx context.Context, xr *cmp.Unstructured, desired render.Outputs) (map[string]*dt.ResourceDiff, error)

CalculateDiffs implements DiffCalculator.

func (*MockDiffCalculator) CalculateNonRemovalDiffs added in v0.5.0 

func (m *MockDiffCalculator) CalculateNonRemovalDiffs(ctx context.Context, xr *cmp.Unstructured, parentComposite *un.Unstructured, desired render.Outputs) (map[string]*dt.ResourceDiff, map[string]bool, error)

CalculateNonRemovalDiffs implements DiffCalculator.

func (*MockDiffCalculator) CalculateRemovedResourceDiffs 

func (m *MockDiffCalculator) CalculateRemovedResourceDiffs(ctx context.Context, xr *un.Unstructured, renderedResources map[string]bool) (map[string]*dt.ResourceDiff, error)

CalculateRemovedResourceDiffs implements DiffCalculator.

type MockDiffProcessor 

type MockDiffProcessor struct {
	// Function fields for mocking behavior
	InitializeFn         func(ctx context.Context) error
	PerformDiffFn        func(ctx context.Context, stdout io.Writer, resources []*un.Unstructured, compositionProvider types.CompositionProvider) (bool, error)
	DiffSingleResourceFn func(ctx context.Context, res *un.Unstructured, compositionProvider types.CompositionProvider) (map[string]*dt.ResourceDiff, error)
	CleanupFn            func(ctx context.Context) error
}

MockDiffProcessor implements the DiffProcessor interface for testing.

func (*MockDiffProcessor) Cleanup added in v0.7.0 

func (m *MockDiffProcessor) Cleanup(ctx context.Context) error

Cleanup implements the DiffProcessor.Cleanup method.

func (*MockDiffProcessor) DiffSingleResource added in v0.5.0 

func (m *MockDiffProcessor) DiffSingleResource(ctx context.Context, res *un.Unstructured, compositionProvider types.CompositionProvider) (map[string]*dt.ResourceDiff, error)

DiffSingleResource implements the DiffProcessor.DiffSingleResource method.

func (*MockDiffProcessor) Initialize 

func (m *MockDiffProcessor) Initialize(ctx context.Context) error

Initialize implements the DiffProcessor interface.

func (*MockDiffProcessor) PerformDiff 

func (m *MockDiffProcessor) PerformDiff(ctx context.Context, stdout io.Writer, resources []*un.Unstructured, compositionProvider types.CompositionProvider) (bool, error)

PerformDiff implements the DiffProcessor.PerformDiff method.

type MockDiffRenderer 

type MockDiffRenderer struct {
	RenderDiffsFn func(io.Writer, map[string]*dt.ResourceDiff, []dt.OutputError) error
}

MockDiffRenderer provides a mock implementation for DiffRenderer.

func (*MockDiffRenderer) RenderDiffs 

func (m *MockDiffRenderer) RenderDiffs(w io.Writer, diffs map[string]*dt.ResourceDiff, errs []dt.OutputError) error

RenderDiffs implements RenderDiffs from the DiffRenderer interface.

type MockDynamicClient 

type MockDynamicClient struct {
	ResourceFn func(gvr schema.GroupVersionResource) dynamic.NamespaceableResourceInterface
}

MockDynamicClient mocks the dynamic.Interface.

func (*MockDynamicClient) Resource 

func (m *MockDynamicClient) Resource(gvr schema.GroupVersionResource) dynamic.NamespaceableResourceInterface

Resource implements the dynamic.Interface method.

type MockEnvironmentClient 

type MockEnvironmentClient struct {
	InitializeFn            func(ctx context.Context) error
	GetEnvironmentConfigsFn func(ctx context.Context) ([]*un.Unstructured, error)
	GetEnvironmentConfigFn  func(ctx context.Context, name string) (*un.Unstructured, error)
}

MockEnvironmentClient implements the crossplane.EnvironmentClient interface.

func (*MockEnvironmentClient) GetEnvironmentConfig 

func (m *MockEnvironmentClient) GetEnvironmentConfig(ctx context.Context, name string) (*un.Unstructured, error)

GetEnvironmentConfig implements crossplane.EnvironmentClient.

func (*MockEnvironmentClient) GetEnvironmentConfigs 

func (m *MockEnvironmentClient) GetEnvironmentConfigs(ctx context.Context) ([]*un.Unstructured, error)

GetEnvironmentConfigs implements crossplane.EnvironmentClient.

func (*MockEnvironmentClient) Initialize 

func (m *MockEnvironmentClient) Initialize(ctx context.Context) error

Initialize implements crossplane.EnvironmentClient.

type MockEnvironmentClientBuilder 

type MockEnvironmentClientBuilder struct {
	// contains filtered or unexported fields
}

MockEnvironmentClientBuilder helps build crossplane.EnvironmentClient mocks.

func NewMockEnvironmentClient 

func NewMockEnvironmentClient() *MockEnvironmentClientBuilder

NewMockEnvironmentClient creates a new MockEnvironmentClientBuilder.

func (*MockEnvironmentClientBuilder) Build 

func (b *MockEnvironmentClientBuilder) Build() *MockEnvironmentClient

Build returns the built mock.

func (*MockEnvironmentClientBuilder) WithFailedInitialize 

func (b *MockEnvironmentClientBuilder) WithFailedInitialize(errMsg string) *MockEnvironmentClientBuilder

WithFailedInitialize mocks a failed call to Initialize.

func (*MockEnvironmentClientBuilder) WithGetEnvironmentConfig 

func (b *MockEnvironmentClientBuilder) WithGetEnvironmentConfig(fn func(context.Context, string) (*un.Unstructured, error)) *MockEnvironmentClientBuilder

WithGetEnvironmentConfig sets the GetEnvironmentConfig behavior.

func (*MockEnvironmentClientBuilder) WithGetEnvironmentConfigs 

func (b *MockEnvironmentClientBuilder) WithGetEnvironmentConfigs(fn func(context.Context) ([]*un.Unstructured, error)) *MockEnvironmentClientBuilder

WithGetEnvironmentConfigs sets the GetEnvironmentConfigs behavior.

func (*MockEnvironmentClientBuilder) WithInitialize 

func (b *MockEnvironmentClientBuilder) WithInitialize(fn func(context.Context) error) *MockEnvironmentClientBuilder

WithInitialize sets the Initialize behavior.

func (*MockEnvironmentClientBuilder) WithNoEnvironmentConfigs added in v0.5.0 

func (b *MockEnvironmentClientBuilder) WithNoEnvironmentConfigs() *MockEnvironmentClientBuilder

WithNoEnvironmentConfigs sets GetEnvironmentConfigs to return an empty list.

func (*MockEnvironmentClientBuilder) WithSuccessfulEnvironmentConfigsFetch 

func (b *MockEnvironmentClientBuilder) WithSuccessfulEnvironmentConfigsFetch(configs []*un.Unstructured) *MockEnvironmentClientBuilder

WithSuccessfulEnvironmentConfigsFetch sets GetEnvironmentConfigs to return specific configs.

func (*MockEnvironmentClientBuilder) WithSuccessfulInitialize 

func (b *MockEnvironmentClientBuilder) WithSuccessfulInitialize() *MockEnvironmentClientBuilder

WithSuccessfulInitialize mocks a successful call to Initialize.

type MockFunctionClient 

type MockFunctionClient struct {
	InitializeFn               func(ctx context.Context) error
	GetFunctionsFromPipelineFn func(comp *xpextv1.Composition) ([]pkgv1.Function, error)
	ListFunctionsFn            func(ctx context.Context) ([]pkgv1.Function, error)
}

MockFunctionClient implements the crossplane.FunctionClient interface.

func (*MockFunctionClient) GetFunctionsFromPipeline 

func (m *MockFunctionClient) GetFunctionsFromPipeline(comp *xpextv1.Composition) ([]pkgv1.Function, error)

GetFunctionsFromPipeline implements crossplane.FunctionClient.

func (*MockFunctionClient) Initialize 

func (m *MockFunctionClient) Initialize(ctx context.Context) error

Initialize implements crossplane.FunctionClient.

func (*MockFunctionClient) ListFunctions 

func (m *MockFunctionClient) ListFunctions(ctx context.Context) ([]pkgv1.Function, error)

ListFunctions implements crossplane.FunctionClient.

type MockFunctionClientBuilder 

type MockFunctionClientBuilder struct {
	// contains filtered or unexported fields
}

MockFunctionClientBuilder helps build crossplane.FunctionClient mocks.

func NewMockFunctionClient 

func NewMockFunctionClient() *MockFunctionClientBuilder

NewMockFunctionClient creates a new MockFunctionClientBuilder.

func (*MockFunctionClientBuilder) Build 

func (b *MockFunctionClientBuilder) Build() *MockFunctionClient

Build returns the built mock.

func (*MockFunctionClientBuilder) WithFailedFunctionsFetch 

func (b *MockFunctionClientBuilder) WithFailedFunctionsFetch(errMsg string) *MockFunctionClientBuilder

WithFailedFunctionsFetch sets GetFunctionsFromPipeline to return an error.

func (*MockFunctionClientBuilder) WithFailedInitialize 

func (b *MockFunctionClientBuilder) WithFailedInitialize(errMsg string) *MockFunctionClientBuilder

WithFailedInitialize mocks a failed call to Initialize.

func (*MockFunctionClientBuilder) WithFunctionsFetchCallback added in v0.5.0 

func (b *MockFunctionClientBuilder) WithFunctionsFetchCallback(callback func() ([]pkgv1.Function, error)) *MockFunctionClientBuilder

WithFunctionsFetchCallback sets a callback that's called when GetFunctionsFromPipeline is invoked. This is useful for testing caching behavior by tracking how many times functions are fetched.

func (*MockFunctionClientBuilder) WithGetFunctionsFromPipeline 

func (b *MockFunctionClientBuilder) WithGetFunctionsFromPipeline(fn func(*xpextv1.Composition) ([]pkgv1.Function, error)) *MockFunctionClientBuilder

WithGetFunctionsFromPipeline sets the GetFunctionsFromPipeline behavior.

func (*MockFunctionClientBuilder) WithInitialize 

func (b *MockFunctionClientBuilder) WithInitialize(fn func(context.Context) error) *MockFunctionClientBuilder

WithInitialize sets the Initialize behavior.

func (*MockFunctionClientBuilder) WithListFunctions 

func (b *MockFunctionClientBuilder) WithListFunctions(fn func(context.Context) ([]pkgv1.Function, error)) *MockFunctionClientBuilder

WithListFunctions sets the ListFunctions behavior.

func (*MockFunctionClientBuilder) WithNoFunctions added in v0.5.0 

func (b *MockFunctionClientBuilder) WithNoFunctions() *MockFunctionClientBuilder

WithNoFunctions sets GetFunctionsFromPipeline to return an empty function list.

func (*MockFunctionClientBuilder) WithSuccessfulFunctionsFetch 

func (b *MockFunctionClientBuilder) WithSuccessfulFunctionsFetch(functions []pkgv1.Function) *MockFunctionClientBuilder

WithSuccessfulFunctionsFetch sets GetFunctionsFromPipeline to return specific functions.

func (*MockFunctionClientBuilder) WithSuccessfulInitialize 

func (b *MockFunctionClientBuilder) WithSuccessfulInitialize() *MockFunctionClientBuilder

WithSuccessfulInitialize mocks a successful call to Initialize.

type MockFunctionProvider added in v0.7.0 

type MockFunctionProvider struct {
	GetFunctionsForCompositionFn func(comp *xpextv1.Composition) ([]pkgv1.Function, error)
	CleanupFn                    func(ctx context.Context) error
}

MockFunctionProvider provides a mock implementation for FunctionProvider.

func (*MockFunctionProvider) Cleanup added in v0.7.0 

func (m *MockFunctionProvider) Cleanup(ctx context.Context) error

Cleanup implements FunctionProvider.

func (*MockFunctionProvider) GetFunctionsForComposition added in v0.7.0 

func (m *MockFunctionProvider) GetFunctionsForComposition(comp *xpextv1.Composition) ([]pkgv1.Function, error)

GetFunctionsForComposition implements FunctionProvider.

type MockNamespaceableResourceInterface 

type MockNamespaceableResourceInterface struct {
	NamespaceFn func(namespace string) dynamic.ResourceInterface
	GetFn       func(ctx context.Context, name string, options metav1.GetOptions, subresources ...string) (*un.Unstructured, error)
	ListFn      func(ctx context.Context, opts metav1.ListOptions) (*un.UnstructuredList, error)
	CreateFn    func(ctx context.Context, obj *un.Unstructured, options metav1.CreateOptions, subresources ...string) (*un.Unstructured, error)
	UpdateFn    func(ctx context.Context, obj *un.Unstructured, options metav1.UpdateOptions, subresources ...string) (*un.Unstructured, error)
	DeleteFn    func(ctx context.Context, name string, options metav1.DeleteOptions, subresources ...string) error
	PatchFn     func(ctx context.Context, name string, pt k8stypes.PatchType, data []byte, options metav1.PatchOptions, subresources ...string) (*un.Unstructured, error)
}

MockNamespaceableResourceInterface implements dynamic.NamespaceableResourceInterface.

func (*MockNamespaceableResourceInterface) Apply 

func (m *MockNamespaceableResourceInterface) Apply(_ context.Context, _ string, _ *un.Unstructured, _ metav1.ApplyOptions, _ ...string) (*un.Unstructured, error)

Apply implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) ApplyStatus 

func (m *MockNamespaceableResourceInterface) ApplyStatus(_ context.Context, _ string, _ *un.Unstructured, _ metav1.ApplyOptions) (*un.Unstructured, error)

ApplyStatus implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) Create 

func (m *MockNamespaceableResourceInterface) Create(ctx context.Context, obj *un.Unstructured, options metav1.CreateOptions, subresources ...string) (*un.Unstructured, error)

Create implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) Delete 

func (m *MockNamespaceableResourceInterface) Delete(ctx context.Context, name string, options metav1.DeleteOptions, subresources ...string) error

Delete implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) DeleteCollection 

func (m *MockNamespaceableResourceInterface) DeleteCollection(_ context.Context, _ metav1.DeleteOptions, _ metav1.ListOptions) error

DeleteCollection implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) Get 

func (m *MockNamespaceableResourceInterface) Get(ctx context.Context, name string, options metav1.GetOptions, subresources ...string) (*un.Unstructured, error)

Get implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) List 

func (m *MockNamespaceableResourceInterface) List(ctx context.Context, opts metav1.ListOptions) (*un.UnstructuredList, error)

List implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) Namespace 

func (m *MockNamespaceableResourceInterface) Namespace(namespace string) dynamic.ResourceInterface

Namespace implements dynamic.NamespaceableResourceInterface.

func (*MockNamespaceableResourceInterface) Patch 

func (m *MockNamespaceableResourceInterface) Patch(ctx context.Context, name string, pt k8stypes.PatchType, data []byte, options metav1.PatchOptions, subresources ...string) (*un.Unstructured, error)

Patch implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) Update 

func (m *MockNamespaceableResourceInterface) Update(ctx context.Context, obj *un.Unstructured, options metav1.UpdateOptions, subresources ...string) (*un.Unstructured, error)

Update implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) UpdateStatus 

func (m *MockNamespaceableResourceInterface) UpdateStatus(_ context.Context, _ *un.Unstructured, _ metav1.UpdateOptions) (*un.Unstructured, error)

UpdateStatus implements dynamic.ResourceInterface.

func (*MockNamespaceableResourceInterface) Watch 

func (m *MockNamespaceableResourceInterface) Watch(_ context.Context, _ metav1.ListOptions) (watch.Interface, error)

Watch implements dynamic.ResourceInterface.

type MockResourceClient 

type MockResourceClient struct {
	InitializeFn              func(ctx context.Context) error
	GetResourceFn             func(ctx context.Context, gvk schema.GroupVersionKind, namespace, name string) (*un.Unstructured, error)
	ListResourcesFn           func(ctx context.Context, gvk schema.GroupVersionKind, namespace string) ([]*un.Unstructured, error)
	GetResourcesByLabelFn     func(ctx context.Context, gvk schema.GroupVersionKind, namespace string, sel metav1.LabelSelector) ([]*un.Unstructured, error)
	GetAllResourcesByLabelsFn func(ctx context.Context, gvks []schema.GroupVersionKind, selectors []metav1.LabelSelector) ([]*un.Unstructured, error)
	GetGVKsForGroupKindFn     func(ctx context.Context, group, kind string) ([]schema.GroupVersionKind, error)
	IsNamespacedResourceFn    func(ctx context.Context, gvk schema.GroupVersionKind) (bool, error)
}

MockResourceClient implements the kubernetes.ResourceClient interface.

func (*MockResourceClient) GetAllResourcesByLabels 

func (m *MockResourceClient) GetAllResourcesByLabels(ctx context.Context, gvks []schema.GroupVersionKind, selectors []metav1.LabelSelector) ([]*un.Unstructured, error)

GetAllResourcesByLabels implements kubernetes.ResourceClient.

func (*MockResourceClient) GetGVKsForGroupKind 

func (m *MockResourceClient) GetGVKsForGroupKind(ctx context.Context, group, kind string) ([]schema.GroupVersionKind, error)

GetGVKsForGroupKind implements kubernetes.ResourceClient.

func (*MockResourceClient) GetResource 

func (m *MockResourceClient) GetResource(ctx context.Context, gvk schema.GroupVersionKind, namespace, name string) (*un.Unstructured, error)

GetResource implements kubernetes.ResourceClient.

func (*MockResourceClient) GetResourcesByLabel 

func (m *MockResourceClient) GetResourcesByLabel(ctx context.Context, gvk schema.GroupVersionKind, namespace string, sel metav1.LabelSelector) ([]*un.Unstructured, error)

GetResourcesByLabel implements kubernetes.ResourceClient.

func (*MockResourceClient) Initialize 

func (m *MockResourceClient) Initialize(ctx context.Context) error

Initialize implements kubernetes.ResourceClient.

func (*MockResourceClient) IsNamespacedResource 

func (m *MockResourceClient) IsNamespacedResource(ctx context.Context, gvk schema.GroupVersionKind) (bool, error)

IsNamespacedResource implements kubernetes.ResourceClient.

func (*MockResourceClient) ListResources 

func (m *MockResourceClient) ListResources(ctx context.Context, gvk schema.GroupVersionKind, namespace string) ([]*un.Unstructured, error)

ListResources implements kubernetes.ResourceClient.

type MockResourceClientBuilder 

type MockResourceClientBuilder struct {
	// contains filtered or unexported fields
}

MockResourceClientBuilder helps build kubernetes.ResourceClient mocks.

func NewMockResourceClient 

func NewMockResourceClient() *MockResourceClientBuilder

NewMockResourceClient creates a new MockResourceClientBuilder.

func (*MockResourceClientBuilder) Build 

func (b *MockResourceClientBuilder) Build() *MockResourceClient

Build returns the built mock.

func (*MockResourceClientBuilder) WithClusterScopedResource 

func (b *MockResourceClientBuilder) WithClusterScopedResource(gvks ...schema.GroupVersionKind) *MockResourceClientBuilder

WithClusterScopedResource sets specific GVKs to be cluster-scoped.

func (*MockResourceClientBuilder) WithEmptyListResources 

func (b *MockResourceClientBuilder) WithEmptyListResources() *MockResourceClientBuilder

WithEmptyListResources mimics an empty but successful response.

func (*MockResourceClientBuilder) WithFoundGVKs 

func (b *MockResourceClientBuilder) WithFoundGVKs(gvks []schema.GroupVersionKind) *MockResourceClientBuilder

WithFoundGVKs sets the GetGVKsForGroupKind behavior.

func (*MockResourceClientBuilder) WithGetAllResourcesByLabels 

func (b *MockResourceClientBuilder) WithGetAllResourcesByLabels(fn func(context.Context, []schema.GroupVersionKind, []metav1.LabelSelector) ([]*un.Unstructured, error)) *MockResourceClientBuilder

WithGetAllResourcesByLabels sets the GetAllResourcesByLabels behavior.

func (*MockResourceClientBuilder) WithGetResource 

func (b *MockResourceClientBuilder) WithGetResource(fn func(context.Context, schema.GroupVersionKind, string, string) (*un.Unstructured, error)) *MockResourceClientBuilder

WithGetResource sets the GetResource behavior.

func (*MockResourceClientBuilder) WithGetResourcesByLabel 

func (b *MockResourceClientBuilder) WithGetResourcesByLabel(fn func(context.Context, schema.GroupVersionKind, string, metav1.LabelSelector) ([]*un.Unstructured, error)) *MockResourceClientBuilder

WithGetResourcesByLabel sets the GetResourcesByLabel behavior.

func (*MockResourceClientBuilder) WithInitialize 

func (b *MockResourceClientBuilder) WithInitialize(fn func(context.Context) error) *MockResourceClientBuilder

WithInitialize sets the Initialize behavior.

func (*MockResourceClientBuilder) WithIsNamespacedResource 

func (b *MockResourceClientBuilder) WithIsNamespacedResource(fn func(context.Context, schema.GroupVersionKind) (bool, error)) *MockResourceClientBuilder

WithIsNamespacedResource sets the IsNamespacedResource behavior.

func (*MockResourceClientBuilder) WithListResources 

func (b *MockResourceClientBuilder) WithListResources(fn func(context.Context, schema.GroupVersionKind, string) ([]*un.Unstructured, error)) *MockResourceClientBuilder

WithListResources sets the ListResources behavior.

func (*MockResourceClientBuilder) WithListResourcesFailure 

func (b *MockResourceClientBuilder) WithListResourcesFailure(errorStr string) *MockResourceClientBuilder

WithListResourcesFailure mimics a failed response.

func (*MockResourceClientBuilder) WithNamespacedResource 

func (b *MockResourceClientBuilder) WithNamespacedResource(gvks ...schema.GroupVersionKind) *MockResourceClientBuilder

WithNamespacedResource sets specific GVKs to be namespaced.

func (*MockResourceClientBuilder) WithResourceNotFound 

func (b *MockResourceClientBuilder) WithResourceNotFound() *MockResourceClientBuilder

WithResourceNotFound sets GetResource to always return "not found".

func (*MockResourceClientBuilder) WithResourcesExist 

func (b *MockResourceClientBuilder) WithResourcesExist(resources ...*un.Unstructured) *MockResourceClientBuilder

WithResourcesExist sets up GetResource to return resources from a map. Resources are keyed using MakeDiffKey (apiVersion/kind/namespace/name) to correctly handle same-named resources in different namespaces.

func (*MockResourceClientBuilder) WithResourcesFoundByLabel 

func (b *MockResourceClientBuilder) WithResourcesFoundByLabel(resources []*un.Unstructured, label, value string) *MockResourceClientBuilder

WithResourcesFoundByLabel sets GetResourcesByLabel to return resources for a specific label value. This method is stateful - multiple calls accumulate mappings for different label values. The label parameter specifies which label key to match on (e.g., "crossplane.io/composition-name").

func (*MockResourceClientBuilder) WithSuccessfulInitialize 

func (b *MockResourceClientBuilder) WithSuccessfulInitialize() *MockResourceClientBuilder

WithSuccessfulInitialize sets a successful Initialize implementation.

func (*MockResourceClientBuilder) WithoutFoundGVKs 

func (b *MockResourceClientBuilder) WithoutFoundGVKs(err string) *MockResourceClientBuilder

WithoutFoundGVKs sets the GetGVKsForGroupKind behavior.

type MockResourceInterface 

type MockResourceInterface struct {
	GetFn    func(ctx context.Context, name string, options metav1.GetOptions, subresources ...string) (*un.Unstructured, error)
	ListFn   func(ctx context.Context, opts metav1.ListOptions) (*un.UnstructuredList, error)
	CreateFn func(ctx context.Context, obj *un.Unstructured, options metav1.CreateOptions, subresources ...string) (*un.Unstructured, error)
	UpdateFn func(ctx context.Context, obj *un.Unstructured, options metav1.UpdateOptions, subresources ...string) (*un.Unstructured, error)
	DeleteFn func(ctx context.Context, name string, options metav1.DeleteOptions, subresources ...string) error
	PatchFn  func(ctx context.Context, name string, pt k8stypes.PatchType, data []byte, options metav1.PatchOptions, subresources ...string) (*un.Unstructured, error)
}

MockResourceInterface mocks dynamic.ResourceInterface for namespaced resources.

func (*MockResourceInterface) Apply 

func (m *MockResourceInterface) Apply(_ context.Context, _ string, _ *un.Unstructured, _ metav1.ApplyOptions, _ ...string) (*un.Unstructured, error)

Apply implements dynamic.ResourceInterface.

func (*MockResourceInterface) ApplyStatus 

func (m *MockResourceInterface) ApplyStatus(_ context.Context, _ string, _ *un.Unstructured, _ metav1.ApplyOptions) (*un.Unstructured, error)

ApplyStatus implements dynamic.ResourceInterface.

func (*MockResourceInterface) Create 

func (m *MockResourceInterface) Create(ctx context.Context, obj *un.Unstructured, options metav1.CreateOptions, subresources ...string) (*un.Unstructured, error)

Create implements dynamic.ResourceInterface.

func (*MockResourceInterface) Delete 

func (m *MockResourceInterface) Delete(ctx context.Context, name string, options metav1.DeleteOptions, subresources ...string) error

Delete implements dynamic.ResourceInterface.

func (*MockResourceInterface) DeleteCollection 

func (m *MockResourceInterface) DeleteCollection(_ context.Context, _ metav1.DeleteOptions, _ metav1.ListOptions) error

DeleteCollection implements dynamic.ResourceInterface.

func (*MockResourceInterface) Get 

func (m *MockResourceInterface) Get(ctx context.Context, name string, options metav1.GetOptions, subresources ...string) (*un.Unstructured, error)

Get implements dynamic.ResourceInterface.

func (*MockResourceInterface) List 

func (m *MockResourceInterface) List(ctx context.Context, opts metav1.ListOptions) (*un.UnstructuredList, error)

List implements dynamic.ResourceInterface.

func (*MockResourceInterface) Patch 

func (m *MockResourceInterface) Patch(ctx context.Context, name string, pt k8stypes.PatchType, data []byte, options metav1.PatchOptions, subresources ...string) (*un.Unstructured, error)

Patch implements dynamic.ResourceInterface.

func (*MockResourceInterface) Update 

func (m *MockResourceInterface) Update(ctx context.Context, obj *un.Unstructured, options metav1.UpdateOptions, subresources ...string) (*un.Unstructured, error)

Update implements dynamic.ResourceInterface.

func (*MockResourceInterface) UpdateStatus 

func (m *MockResourceInterface) UpdateStatus(_ context.Context, _ *un.Unstructured, _ metav1.UpdateOptions) (*un.Unstructured, error)

UpdateStatus implements dynamic.ResourceInterface.

func (*MockResourceInterface) Watch 

func (m *MockResourceInterface) Watch(_ context.Context, _ metav1.ListOptions) (watch.Interface, error)

Watch implements dynamic.ResourceInterface.

type MockResourceTreeClient 

type MockResourceTreeClient struct {
	InitializeFn      func(ctx context.Context) error
	GetResourceTreeFn func(ctx context.Context, root *un.Unstructured) (*resource.Resource, error)
}

MockResourceTreeClient implements the crossplane.ResourceTreeClient interface.

func (*MockResourceTreeClient) GetResourceTree 

func (m *MockResourceTreeClient) GetResourceTree(ctx context.Context, root *un.Unstructured) (*resource.Resource, error)

GetResourceTree implements crossplane.ResourceTreeClient.

func (*MockResourceTreeClient) Initialize 

func (m *MockResourceTreeClient) Initialize(ctx context.Context) error

Initialize implements crossplane.ResourceTreeClient.

type MockResourceTreeClientBuilder 

type MockResourceTreeClientBuilder struct {
	// contains filtered or unexported fields
}

MockResourceTreeClientBuilder helps build crossplane.ResourceTreeClient mocks.

func NewMockResourceTreeClient 

func NewMockResourceTreeClient() *MockResourceTreeClientBuilder

NewMockResourceTreeClient creates a new MockResourceTreeClientBuilder.

func (*MockResourceTreeClientBuilder) Build 

func (b *MockResourceTreeClientBuilder) Build() *MockResourceTreeClient

Build returns the built mock.

func (*MockResourceTreeClientBuilder) WithEmptyResourceTree 

func (b *MockResourceTreeClientBuilder) WithEmptyResourceTree() *MockResourceTreeClientBuilder

WithEmptyResourceTree sets GetResourceTree to return just the root with no children.

func (*MockResourceTreeClientBuilder) WithFailedInitialize 

func (b *MockResourceTreeClientBuilder) WithFailedInitialize(errMsg string) *MockResourceTreeClientBuilder

WithFailedInitialize mocks a failed call to Initialize.

func (*MockResourceTreeClientBuilder) WithFailedResourceTreeFetch 

func (b *MockResourceTreeClientBuilder) WithFailedResourceTreeFetch(errMsg string) *MockResourceTreeClientBuilder

WithFailedResourceTreeFetch sets GetResourceTree to return an error.

func (*MockResourceTreeClientBuilder) WithGetResourceTree 

func (b *MockResourceTreeClientBuilder) WithGetResourceTree(fn func(context.Context, *un.Unstructured) (*resource.Resource, error)) *MockResourceTreeClientBuilder

WithGetResourceTree sets the GetResourceTree behavior.

func (*MockResourceTreeClientBuilder) WithInitialize 

func (b *MockResourceTreeClientBuilder) WithInitialize(fn func(context.Context) error) *MockResourceTreeClientBuilder

WithInitialize sets the Initialize behavior.

func (*MockResourceTreeClientBuilder) WithResourceTreeFromXRAndComposed 

func (b *MockResourceTreeClientBuilder) WithResourceTreeFromXRAndComposed(xr *un.Unstructured, composed []*un.Unstructured) *MockResourceTreeClientBuilder

WithResourceTreeFromXRAndComposed creates a basic resource tree from an XR and composed resources.

func (*MockResourceTreeClientBuilder) WithSuccessfulInitialize 

func (b *MockResourceTreeClientBuilder) WithSuccessfulInitialize() *MockResourceTreeClientBuilder

WithSuccessfulInitialize mocks a successful call to Initialize.

func (*MockResourceTreeClientBuilder) WithSuccessfulResourceTreeFetch 

func (b *MockResourceTreeClientBuilder) WithSuccessfulResourceTreeFetch(resourceTree *resource.Resource) *MockResourceTreeClientBuilder

WithSuccessfulResourceTreeFetch sets GetResourceTree to return a specific tree.

type MockSchemaClient 

type MockSchemaClient struct {
	InitializeFn       func(ctx context.Context) error
	GetCRDFn           func(ctx context.Context, gvk schema.GroupVersionKind) (*extv1.CustomResourceDefinition, error)
	GetCRDByNameFn     func(name string) (*extv1.CustomResourceDefinition, error)
	IsCRDRequiredFn    func(ctx context.Context, gvk schema.GroupVersionKind) bool
	ValidateResourceFn func(ctx context.Context, resource *un.Unstructured) error
	LoadCRDsFromXRDsFn func(ctx context.Context, xrds []*un.Unstructured) error
	GetAllCRDsFn       func() []*extv1.CustomResourceDefinition
}

MockSchemaClient implements the kubernetes.SchemaClient interface.

func (*MockSchemaClient) GetAllCRDs added in v0.2.0 

func (m *MockSchemaClient) GetAllCRDs() []*extv1.CustomResourceDefinition

GetAllCRDs implements kubernetes.SchemaClient.

func (*MockSchemaClient) GetCRD 

func (m *MockSchemaClient) GetCRD(ctx context.Context, gvk schema.GroupVersionKind) (*extv1.CustomResourceDefinition, error)

GetCRD implements kubernetes.SchemaClient.

func (*MockSchemaClient) GetCRDByName added in v0.2.0 

func (m *MockSchemaClient) GetCRDByName(name string) (*extv1.CustomResourceDefinition, error)

GetCRDByName implements kubernetes.SchemaClient.

func (*MockSchemaClient) Initialize 

func (m *MockSchemaClient) Initialize(ctx context.Context) error

Initialize implements kubernetes.SchemaClient.

func (*MockSchemaClient) IsCRDRequired 

func (m *MockSchemaClient) IsCRDRequired(ctx context.Context, gvk schema.GroupVersionKind) bool

IsCRDRequired implements kubernetes.SchemaClient.

func (*MockSchemaClient) LoadCRDsFromXRDs added in v0.2.0 

func (m *MockSchemaClient) LoadCRDsFromXRDs(ctx context.Context, xrds []*un.Unstructured) error

LoadCRDsFromXRDs implements kubernetes.SchemaClient.

func (*MockSchemaClient) ValidateResource 

func (m *MockSchemaClient) ValidateResource(ctx context.Context, resource *un.Unstructured) error

ValidateResource implements kubernetes.SchemaClient.

type MockSchemaClientBuilder 

type MockSchemaClientBuilder struct {
	// contains filtered or unexported fields
}

MockSchemaClientBuilder helps build kubernetes.SchemaClient mocks.

func NewMockSchemaClient 

func NewMockSchemaClient() *MockSchemaClientBuilder

NewMockSchemaClient creates a new MockSchemaClientBuilder.

func (*MockSchemaClientBuilder) Build 

func (b *MockSchemaClientBuilder) Build() *MockSchemaClient

Build returns the built mock.

func (*MockSchemaClientBuilder) WithAllResourcesRequiringCRDs 

func (b *MockSchemaClientBuilder) WithAllResourcesRequiringCRDs() *MockSchemaClientBuilder

WithAllResourcesRequiringCRDs sets all resources to require CRDs.

func (*MockSchemaClientBuilder) WithCRDNotFound 

func (b *MockSchemaClientBuilder) WithCRDNotFound() *MockSchemaClientBuilder

WithCRDNotFound sets GetCRD to return a not found error.

func (*MockSchemaClientBuilder) WithCachingBehavior added in v0.2.0 

func (b *MockSchemaClientBuilder) WithCachingBehavior() *MockSchemaClientBuilder

WithCachingBehavior creates a mock that simulates caching CRDs when GetCRD or LoadCRDsFromXRDs is called.

func (*MockSchemaClientBuilder) WithFoundCRD added in v0.2.0 

func (b *MockSchemaClientBuilder) WithFoundCRD(group, kind string, crd *extv1.CustomResourceDefinition) *MockSchemaClientBuilder

WithFoundCRD sets GetCRD to return a specific CRD when the group and kind match.

func (*MockSchemaClientBuilder) WithFoundCRDs added in v0.2.0 

func (b *MockSchemaClientBuilder) WithFoundCRDs(crdMappings map[schema.GroupKind]*extv1.CustomResourceDefinition) *MockSchemaClientBuilder

WithFoundCRDs sets GetCRD to return specific CRDs when the group and kind match, with a fallback error.

func (*MockSchemaClientBuilder) WithGetAllCRDs added in v0.2.0 

func (b *MockSchemaClientBuilder) WithGetAllCRDs(fn func() []*extv1.CustomResourceDefinition) *MockSchemaClientBuilder

WithGetAllCRDs sets the GetAllCRDs behavior.

func (*MockSchemaClientBuilder) WithGetCRD 

func (b *MockSchemaClientBuilder) WithGetCRD(fn func(context.Context, schema.GroupVersionKind) (*extv1.CustomResourceDefinition, error)) *MockSchemaClientBuilder

WithGetCRD sets the GetCRD behavior.

func (*MockSchemaClientBuilder) WithGetCRDByName added in v0.2.0 

func (b *MockSchemaClientBuilder) WithGetCRDByName(fn func(string) (*extv1.CustomResourceDefinition, error)) *MockSchemaClientBuilder

WithGetCRDByName sets the GetCRDByName behavior.

func (*MockSchemaClientBuilder) WithInitialize 

func (b *MockSchemaClientBuilder) WithInitialize(fn func(context.Context) error) *MockSchemaClientBuilder

WithInitialize sets the Initialize behavior.

func (*MockSchemaClientBuilder) WithIsCRDRequired 

func (b *MockSchemaClientBuilder) WithIsCRDRequired(fn func(context.Context, schema.GroupVersionKind) bool) *MockSchemaClientBuilder

WithIsCRDRequired sets the IsCRDRequired behavior.

func (*MockSchemaClientBuilder) WithNoResourcesRequiringCRDs 

func (b *MockSchemaClientBuilder) WithNoResourcesRequiringCRDs() *MockSchemaClientBuilder

WithNoResourcesRequiringCRDs sets all resources to not require CRDs.

func (*MockSchemaClientBuilder) WithResourcesRequiringCRDs 

func (b *MockSchemaClientBuilder) WithResourcesRequiringCRDs(crdsRequiredGVKs ...schema.GroupVersionKind) *MockSchemaClientBuilder

WithResourcesRequiringCRDs sets only the specified GVKs to require CRDs.

func (*MockSchemaClientBuilder) WithSuccessfulCRDByNameFetch added in v0.2.0 

func (b *MockSchemaClientBuilder) WithSuccessfulCRDByNameFetch(name string, crd *extv1.CustomResourceDefinition) *MockSchemaClientBuilder

WithSuccessfulCRDByNameFetch sets GetCRDByName to return a specific CRD for a given name.

func (*MockSchemaClientBuilder) WithSuccessfulCRDFetch 

func (b *MockSchemaClientBuilder) WithSuccessfulCRDFetch(crd *extv1.CustomResourceDefinition) *MockSchemaClientBuilder

WithSuccessfulCRDFetch sets GetCRD to return a specific CRD.

func (*MockSchemaClientBuilder) WithValidateResource 

func (b *MockSchemaClientBuilder) WithValidateResource(fn func(context.Context, *un.Unstructured) error) *MockSchemaClientBuilder

WithValidateResource sets the ValidateResource behavior.

type MockSchemaValidator 

type MockSchemaValidator struct {
	ValidateResourcesFn        func(ctx context.Context, xr *un.Unstructured, composed []cpd.Unstructured) error
	ValidateScopeConstraintsFn func(ctx context.Context, resource *un.Unstructured, expectedNamespace string, isClaimRoot bool) error
}

MockSchemaValidator Mock schema validator.

func (*MockSchemaValidator) EnsureComposedResourceCRDs 

func (m *MockSchemaValidator) EnsureComposedResourceCRDs(_ context.Context, _ []*un.Unstructured) error

EnsureComposedResourceCRDs Implement other required methods of the SchemaValidator interface.

func (*MockSchemaValidator) ValidateResources 

func (m *MockSchemaValidator) ValidateResources(ctx context.Context, xr *un.Unstructured, composed []cpd.Unstructured) error

ValidateResources validates a set of resources against schemas from the cluster.

func (*MockSchemaValidator) ValidateScopeConstraints 

func (m *MockSchemaValidator) ValidateScopeConstraints(ctx context.Context, resource *un.Unstructured, expectedNamespace string, isClaimRoot bool) error

ValidateScopeConstraints validates that a resource has the appropriate namespace for its scope.

type MockTypeConverter 

type MockTypeConverter struct {
	GVKToGVRFn              func(ctx context.Context, gvk schema.GroupVersionKind) (schema.GroupVersionResource, error)
	GetResourceNameForGVKFn func(ctx context.Context, gvk schema.GroupVersionKind) (string, error)
}

MockTypeConverter implements the kubernetes.TypeConverter interface.

func (*MockTypeConverter) GVKToGVR 

func (m *MockTypeConverter) GVKToGVR(ctx context.Context, gvk schema.GroupVersionKind) (schema.GroupVersionResource, error)

GVKToGVR implements kubernetes.TypeConverter.

func (*MockTypeConverter) GetResourceNameForGVK 

func (m *MockTypeConverter) GetResourceNameForGVK(ctx context.Context, gvk schema.GroupVersionKind) (string, error)

GetResourceNameForGVK implements kubernetes.TypeConverter.

type MockTypeConverterBuilder 

type MockTypeConverterBuilder struct {
	// contains filtered or unexported fields
}

MockTypeConverterBuilder helps build kubernetes.TypeConverter mocks.

func NewMockTypeConverter 

func NewMockTypeConverter() *MockTypeConverterBuilder

NewMockTypeConverter creates a new MockTypeConverterBuilder.

func (*MockTypeConverterBuilder) Build 

func (b *MockTypeConverterBuilder) Build() *MockTypeConverter

Build returns the built mock.

func (*MockTypeConverterBuilder) WithDefaultGVKToGVR 

func (b *MockTypeConverterBuilder) WithDefaultGVKToGVR() *MockTypeConverterBuilder

WithDefaultGVKToGVR sets a default implementation for GVKToGVR.

func (*MockTypeConverterBuilder) WithDefaultGetResourceNameForGVK 

func (b *MockTypeConverterBuilder) WithDefaultGetResourceNameForGVK() *MockTypeConverterBuilder

WithDefaultGetResourceNameForGVK sets a default implementation for GetResourceNameForGVK.

func (*MockTypeConverterBuilder) WithGVKToGVR 

func (b *MockTypeConverterBuilder) WithGVKToGVR(fn func(context.Context, schema.GroupVersionKind) (schema.GroupVersionResource, error)) *MockTypeConverterBuilder

WithGVKToGVR sets the GVKToGVR behavior.

func (*MockTypeConverterBuilder) WithGetResourceNameForGVK 

func (b *MockTypeConverterBuilder) WithGetResourceNameForGVK(fn func(context.Context, schema.GroupVersionKind) (string, error)) *MockTypeConverterBuilder

WithGetResourceNameForGVK sets the GetResourceNameForGVK behavior.

func (*MockTypeConverterBuilder) WithResourceNameForGVK added in v0.2.0 

func (b *MockTypeConverterBuilder) WithResourceNameForGVK(gvk schema.GroupVersionKind, resourceName string) *MockTypeConverterBuilder

WithResourceNameForGVK sets GetResourceNameForGVK to return a specific resource name for a given GVK.

func (*MockTypeConverterBuilder) WithResourceNameForGVKs added in v0.2.0 

func (b *MockTypeConverterBuilder) WithResourceNameForGVKs(gvkMappings map[schema.GroupVersionKind]string) *MockTypeConverterBuilder

WithResourceNameForGVKs sets GetResourceNameForGVK to return specific resource names for given GVKs, with a fallback error.

type OutputError added in v0.7.0 

type OutputError struct {
	ResourceID string `json:"resourceID,omitempty"`
	Message    string `json:"message"`
}

OutputError mirrors dt.OutputError.

type PipelineStepOption added in v0.6.0 

type PipelineStepOption func(*xpextv1.PipelineStep)

PipelineStepOption is a functional option for configuring a pipeline step.

func WithCredentials added in v0.6.0 

func WithCredentials(name, namespace, secretName string) PipelineStepOption

WithCredentials adds credentials to a pipeline step.

type ResourceBuilder 

type ResourceBuilder struct {
	// contains filtered or unexported fields
}

ResourceBuilder helps construct unstructured resources for testing.

func NewResource 

func NewResource(apiVersion, kind, name string) *ResourceBuilder

NewResource creates a new ResourceBuilder.

func (*ResourceBuilder) Build 

func (b *ResourceBuilder) Build() *un.Unstructured

Build returns the built unstructured resource.

func (*ResourceBuilder) BuildTyped added in v0.6.0 

func (b *ResourceBuilder) BuildTyped(into runtime.Object)

BuildTyped converts the built unstructured resource into a typed Kubernetes object. The 'into' parameter should be a pointer to the target type (e.g., &corev1.Secret{}).

func (*ResourceBuilder) BuildUComposed 

func (b *ResourceBuilder) BuildUComposed() *cpd.Unstructured

BuildUComposed returns the built unstructured resource as a *cpd.Unstructured.

func (*ResourceBuilder) BuildUComposite 

func (b *ResourceBuilder) BuildUComposite() *cmp.Unstructured

BuildUComposite returns the built unstructured resource as a *cmp.Unstructured.

func (*ResourceBuilder) InNamespace 

func (b *ResourceBuilder) InNamespace(namespace string) *ResourceBuilder

InNamespace sets the namespace for the resource.

func (*ResourceBuilder) WithAnnotations 

func (b *ResourceBuilder) WithAnnotations(annotations map[string]string) *ResourceBuilder

WithAnnotations adds annotations to the resource.

func (*ResourceBuilder) WithCompositeOwner 

func (b *ResourceBuilder) WithCompositeOwner(owner string) *ResourceBuilder

WithCompositeOwner sets up the resource as a cpd resource with the given composite owner.

func (*ResourceBuilder) WithCompositionResourceName 

func (b *ResourceBuilder) WithCompositionResourceName(name string) *ResourceBuilder

WithCompositionResourceName sets the composition resource name annotation.

func (*ResourceBuilder) WithData added in v0.6.0 

func (b *ResourceBuilder) WithData(data map[string][]byte) *ResourceBuilder

WithData sets the data field for Secret resources. The byte slices are base64-encoded as they would be in Kubernetes.

func (*ResourceBuilder) WithFieldManagers added in v0.5.0 

func (b *ResourceBuilder) WithFieldManagers(managers ...string) *ResourceBuilder

WithFieldManagers sets the managed fields on the resource using the provided manager names.

func (*ResourceBuilder) WithGenerateName 

func (b *ResourceBuilder) WithGenerateName(generateName string) *ResourceBuilder

WithGenerateName sets the namespace for the resource.

func (*ResourceBuilder) WithLabels 

func (b *ResourceBuilder) WithLabels(labels map[string]string) *ResourceBuilder

WithLabels adds labels to the resource.

func (*ResourceBuilder) WithNamespace added in v0.2.0 

func (b *ResourceBuilder) WithNamespace(namespace string) *ResourceBuilder

WithNamespace sets the namespace for the resource.

func (*ResourceBuilder) WithNestedField added in v0.3.0 

func (b *ResourceBuilder) WithNestedField(value any, fields ...string) *ResourceBuilder

WithNestedField sets a field at an arbitrary nested path in the resource. The path is a sequence of field names to traverse (e.g., "spec", "crossplane", "compositionUpdatePolicy").

func (*ResourceBuilder) WithOwnerReference 

func (b *ResourceBuilder) WithOwnerReference(kind, name, apiVersion, uid string) *ResourceBuilder

WithOwnerReference appends an owner ref to a resource.

func (*ResourceBuilder) WithSpec 

func (b *ResourceBuilder) WithSpec(spec map[string]any) *ResourceBuilder

WithSpec sets the spec field of the resource.

func (*ResourceBuilder) WithSpecField 

func (b *ResourceBuilder) WithSpecField(name string, value any) *ResourceBuilder

WithSpecField sets a specific field in the spec.

func (*ResourceBuilder) WithStatus 

func (b *ResourceBuilder) WithStatus(status map[string]any) *ResourceBuilder

WithStatus sets the status field of the resource.

func (*ResourceBuilder) WithStatusField 

func (b *ResourceBuilder) WithStatusField(name string, value any) *ResourceBuilder

WithStatusField sets a specific field in the status.

type ResourceExpectation added in v0.7.0 

type ResourceExpectation struct {
	// contains filtered or unexported fields
}

ResourceExpectation defines expectations for a single resource change.

func (*ResourceExpectation) And added in v0.7.0 

func (r *ResourceExpectation) And() *ExpectedDiff

And returns to parent to chain more resource expectations. Not needed at the end of a chain - AssertStructuredDiff accepts ResourceExpectation directly.

func (*ResourceExpectation) WithAnyName added in v0.7.0 

func (r *ResourceExpectation) WithAnyName() *ResourceExpectation

WithAnyName allows any resource name (useful for generated names).

func (*ResourceExpectation) WithField added in v0.7.0 

func (r *ResourceExpectation) WithField(path string, value any) *ResourceExpectation

WithField asserts a specific field exists with exact value (for added/removed resources).

func (*ResourceExpectation) WithFieldAdded added in v0.7.0 

func (r *ResourceExpectation) WithFieldAdded(path string, value any) *ResourceExpectation

WithFieldAdded asserts a field was added (for modified resources). Equivalent to WithFieldChange(path, nil, value).

func (*ResourceExpectation) WithFieldChange added in v0.7.0 

func (r *ResourceExpectation) WithFieldChange(path string, oldValue, newValue any) *ResourceExpectation

WithFieldChange asserts a field changed from old to new value (for modified resources).

func (*ResourceExpectation) WithFieldRemoved added in v0.7.0 

func (r *ResourceExpectation) WithFieldRemoved(path string, value any) *ResourceExpectation

WithFieldRemoved asserts a field was removed (for modified resources). Equivalent to WithFieldChange(path, value, nil).

func (*ResourceExpectation) WithFieldValuePattern added in v0.7.0 

func (r *ResourceExpectation) WithFieldValuePattern(path, pattern string) *ResourceExpectation

WithFieldValuePattern asserts a field value matches a regex pattern. Use this for fields with generated/dynamic values like resource names with random suffixes.

func (*ResourceExpectation) WithNamePattern added in v0.7.0 

func (r *ResourceExpectation) WithNamePattern(pattern string) *ResourceExpectation

WithNamePattern matches resource name against a regex pattern instead of exact name.

func (*ResourceExpectation) WithSpec added in v0.7.0 

func (r *ResourceExpectation) WithSpec(spec map[string]any) *ResourceExpectation

WithSpec asserts the entire spec matches (for strict equality).

type StructuredCompDiffOutput added in v0.7.0 

type StructuredCompDiffOutput struct {
	Compositions []CompositionDiffJSON `json:"compositions"`
	Errors       []OutputError         `json:"errors,omitempty"`
}

StructuredCompDiffOutput mirrors the JSON schema for composition diffs.

func ParseStructuredCompOutput added in v0.7.0 

func ParseStructuredCompOutput(jsonOutput string) (StructuredCompDiffOutput, error)

ParseStructuredCompOutput parses JSON output into StructuredCompDiffOutput.

type StructuredDiffOutput added in v0.7.0 

type StructuredDiffOutput struct {
	Summary Summary        `json:"summary"`
	Changes []ChangeDetail `json:"changes"`
	Errors  []OutputError  `json:"errors,omitempty"`
}

StructuredDiffOutput mirrors renderer.StructuredDiffOutput to avoid import cycles. These types are used only for test assertions.

func ParseStructuredOutput added in v0.7.0 

func ParseStructuredOutput(jsonOutput string) (StructuredDiffOutput, error)

ParseStructuredOutput parses JSON output into StructuredDiffOutput.

type Summary added in v0.7.0 

type Summary struct {
	Added    int `json:"added"`
	Modified int `json:"modified"`
	Removed  int `json:"removed"`
}

Summary mirrors renderer.Summary.

type XRDBuilder added in v0.2.0 

type XRDBuilder struct {
	// contains filtered or unexported fields
}

XRDBuilder helps construct XRD resources for testing.

func NewXRD added in v0.2.0 

func NewXRD(name, group, kind string) *XRDBuilder

NewXRD creates a new XRDBuilder.

func (*XRDBuilder) Build added in v0.2.0 

func (b *XRDBuilder) Build() *xpextv1.CompositeResourceDefinition

Build returns the built XRD.

func (*XRDBuilder) BuildAsUnstructured added in v0.2.0 

func (b *XRDBuilder) BuildAsUnstructured() *un.Unstructured

BuildAsUnstructured returns the built XRD as an unstructured object.

func (*XRDBuilder) WithClaimNames added in v0.2.0 

func (b *XRDBuilder) WithClaimNames(kind, plural string) *XRDBuilder

WithClaimNames sets the claim names for the XRD.

func (*XRDBuilder) WithDefaultVersion added in v0.3.0 

func (b *XRDBuilder) WithDefaultVersion() *XRDBuilder

WithDefaultVersion adds a default "v1" version to the XRD.

func (*XRDBuilder) WithPlural added in v0.2.0 

func (b *XRDBuilder) WithPlural(plural string) *XRDBuilder

WithPlural sets the plural name for the XRD.

func (*XRDBuilder) WithRawSchema added in v0.2.0 

func (b *XRDBuilder) WithRawSchema(rawJSON []byte) *XRDBuilder

WithRawSchema adds a raw JSON schema to the last added version.

func (*XRDBuilder) WithSchema added in v0.2.0 

func (b *XRDBuilder) WithSchema(schema *extv1.JSONSchemaProps) *XRDBuilder

WithSchema adds an OpenAPI v3 schema to the last added version.

func (*XRDBuilder) WithSingular added in v0.2.0 

func (b *XRDBuilder) WithSingular(singular string) *XRDBuilder

WithSingular sets the singular name for the XRD.

func (*XRDBuilder) WithVersion added in v0.2.0 

func (b *XRDBuilder) WithVersion(name string, served, referenceable bool) *XRDBuilder

WithVersion adds a version to the XRD.

type XRImpactExpectation added in v0.7.0 

type XRImpactExpectation struct {
	// contains filtered or unexported fields
}

XRImpactExpectation defines expectations for a single XR impact.

func (*XRImpactExpectation) AndComp added in v0.7.0 

func (x *XRImpactExpectation) AndComp() *CompositionExpectation

AndComp returns to parent to chain more XR impact expectations. Not needed at the end of a chain - AssertStructuredCompDiff accepts XRImpactExpectation directly.

func (*XRImpactExpectation) WithAnyName added in v0.7.0 

func (x *XRImpactExpectation) WithAnyName() *XRImpactExpectation

WithAnyName allows any XR name (useful for generated names).

func (*XRImpactExpectation) WithDownstreamResource added in v0.7.0 

func (x *XRImpactExpectation) WithDownstreamResource(changeType, kind, name, namespace string) *DownstreamResourceExpectation

WithDownstreamResource adds an expectation for a downstream resource change. Use this to assert on specific field-level changes in downstream resources.

func (*XRImpactExpectation) WithDownstreamSummary added in v0.7.0 

func (x *XRImpactExpectation) WithDownstreamSummary(added, modified, removed int) *XRImpactExpectation

WithDownstreamSummary sets the expected downstream changes summary.

type XRImpactJSON added in v0.7.0 

type XRImpactJSON struct {
	APIVersion        string             `json:"apiVersion,omitempty"`
	Kind              string             `json:"kind,omitempty"`
	Name              string             `json:"name,omitempty"`
	Namespace         string             `json:"namespace,omitempty"`
	UID               string             `json:"uid,omitempty"`
	Status            string             `json:"status"`
	Error             string             `json:"error,omitempty"`
	DownstreamChanges *DownstreamChanges `json:"downstreamChanges,omitempty"`
}

XRImpactJSON mirrors xrImpactJSON from the renderer.

Source Files

View all Source files

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.