diffprocessor

package

Go to main page

Versions in this module

v0

v0.5.0

Jan 18, 2026

Changes in this version

+ const LabelClaimName

+ const LabelClaimNamespace

+ const LabelComposite

+ func CopyCompositionRef(source, target *un.Unstructured)

+ func CopyLabels(source, target *un.Unstructured, keys ...string)

+ type CachedFunctionProvider struct

+ func (p *CachedFunctionProvider) Cleanup(ctx context.Context) error

+ func (p *CachedFunctionProvider) GetFunctionsForComposition(comp *apiextensionsv1.Composition) ([]pkgv1.Function, error)

type ComponentFactories

+ FunctionProvider func(fnClient xp.FunctionClient, logger logging.Logger) FunctionProvider

type DefaultDiffCalculator

+ func (c *DefaultDiffCalculator) CalculateNonRemovalDiffs(ctx context.Context, xr *cmp.Unstructured, parentComposite *un.Unstructured, ...) (map[string]*dt.ResourceDiff, map[string]bool, error)

+ type DefaultFunctionProvider struct

+ func (p *DefaultFunctionProvider) Cleanup(_ context.Context) error

+ func (p *DefaultFunctionProvider) GetFunctionsForComposition(comp *apiextensionsv1.Composition) ([]pkgv1.Function, error)

type DefaultResourceManager

+ func (m *DefaultResourceManager) FetchObservedResources(ctx context.Context, xr *cmp.Unstructured) ([]cpd.Unstructured, error)

type DiffCalculator

+ CalculateNonRemovalDiffs func(ctx context.Context, xr *cmp.Unstructured, parentComposite *un.Unstructured, ...) (map[string]*dt.ResourceDiff, map[string]bool, error)

type DiffProcessor

+ DiffSingleResource func(ctx context.Context, res *un.Unstructured, ...) (map[string]*dt.ResourceDiff, error)

+ type FunctionProvider interface

+ Cleanup func(ctx context.Context) error

+ GetFunctionsForComposition func(comp *apiextensionsv1.Composition) ([]pkgv1.Function, error)

+ func NewCachedFunctionProvider(fnClient xp.FunctionClient, logger logging.Logger) FunctionProvider

+ func NewDefaultFunctionProvider(fnClient xp.FunctionClient, logger logging.Logger) FunctionProvider

type ProcessorConfig

+ IgnorePaths []string

type ProcessorOption

+ func WithFunctionProviderFactory(factory func(xp.FunctionClient, logging.Logger) FunctionProvider) ProcessorOption

+ func WithIgnorePaths(ignorePaths []string) ProcessorOption

type ResourceManager

+ FetchObservedResources func(ctx context.Context, xr *cmp.Unstructured) ([]cpd.Unstructured, error)

+ type XRDiffResult struct

+ Diffs map[string]*dt.ResourceDiff

+ Error error

+ func (r *XRDiffResult) HasChanges() bool

+ func (r *XRDiffResult) HasError() bool

v0.5.0-rc1

Dec 9, 2025

v0.3.1

Oct 16, 2025

v0.3.0

Oct 16, 2025

Changes in this version

type DefaultDiffProcessor

+ func (p *DefaultDiffProcessor) ProcessNestedXRs(ctx context.Context, composedResources []cpd.Unstructured, ...) (map[string]*dt.ResourceDiff, error)

type ProcessorConfig

+ IncludeManual bool

+ MaxNestedDepth int

type ProcessorOption

+ func WithIncludeManual(includeManual bool) ProcessorOption

+ func WithMaxNestedDepth(depth int) ProcessorOption

v0.2.1

Oct 8, 2025

Changes in this version

type ProcessorConfig

+ RenderMutex *sync.Mutex

type ProcessorOption

+ func WithRenderMutex(mu *sync.Mutex) ProcessorOption

v0.2.0

Sep 30, 2025

Changes in this version

+ type CompDiffProcessor interface

+ DiffComposition func(ctx context.Context, stdout io.Writer, compositions []*un.Unstructured, ...) error

+ Initialize func(ctx context.Context) error

+ func NewCompDiffProcessor(xrProc DiffProcessor, compositionClient xp.CompositionClient, ...) CompDiffProcessor

+ type DefaultCompDiffProcessor struct

+ func (p *DefaultCompDiffProcessor) DiffComposition(ctx context.Context, stdout io.Writer, compositions []*un.Unstructured, ...) error

+ func (p *DefaultCompDiffProcessor) Initialize(ctx context.Context) error

v0.1.0

Sep 17, 2025

Changes in this version

+ type ComponentFactories struct

+ DiffCalculator func(apply k8.ApplyClient, tree xp.ResourceTreeClient, ...) DiffCalculator

+ DiffRenderer func(logger logging.Logger, diffOptions renderer.DiffOptions) renderer.DiffRenderer

+ RequirementsProvider func(res k8.ResourceClient, def xp.EnvironmentClient, renderFunc RenderFunc, ...) *RequirementsProvider

+ ResourceManager func(client k8.ResourceClient, logger logging.Logger) ResourceManager

+ SchemaValidator func(schema k8.SchemaClient, def xp.DefinitionClient, logger logging.Logger) SchemaValidator

+ type DefaultDiffCalculator struct

+ func (c *DefaultDiffCalculator) CalculateDiff(ctx context.Context, composite *un.Unstructured, desired *un.Unstructured) (*dt.ResourceDiff, error)

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

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

+ func (c *DefaultDiffCalculator) SetDiffOptions(options renderer.DiffOptions)

+ type DefaultDiffProcessor struct

+ func (p *DefaultDiffProcessor) DiffSingleResource(ctx context.Context, res *un.Unstructured) (map[string]*dt.ResourceDiff, error)

+ func (p *DefaultDiffProcessor) Initialize(ctx context.Context) error

+ func (p *DefaultDiffProcessor) PerformDiff(ctx context.Context, stdout io.Writer, resources []*un.Unstructured) error

+ func (p *DefaultDiffProcessor) RenderWithRequirements(ctx context.Context, xr *cmp.Unstructured, comp *apiextensionsv1.Composition, ...) (render.Outputs, error)

+ func (p *DefaultDiffProcessor) SanitizeXR(res *un.Unstructured, resourceID string) (*cmp.Unstructured, bool, error)

+ type DefaultResourceManager struct

+ func (m *DefaultResourceManager) FetchCurrentObject(ctx context.Context, composite *un.Unstructured, desired *un.Unstructured) (*un.Unstructured, bool, error)

+ func (m *DefaultResourceManager) UpdateOwnerRefs(parent *un.Unstructured, child *un.Unstructured)

+ type DefaultSchemaValidator struct

+ func (v *DefaultSchemaValidator) EnsureComposedResourceCRDs(ctx context.Context, resources []*un.Unstructured) error

+ func (v *DefaultSchemaValidator) GetCRDs() []*extv1.CustomResourceDefinition

+ func (v *DefaultSchemaValidator) IsClaimResource(ctx context.Context, resource *un.Unstructured) bool

+ func (v *DefaultSchemaValidator) LoadCRDs(ctx context.Context) error

+ func (v *DefaultSchemaValidator) SetCRDs(crds []*extv1.CustomResourceDefinition)

+ func (v *DefaultSchemaValidator) ValidateResources(ctx context.Context, xr *un.Unstructured, composed []cpd.Unstructured) error

+ func (v *DefaultSchemaValidator) ValidateScopeConstraints(ctx context.Context, resource *un.Unstructured, expectedNamespace string, ...) error

+ type DiffCalculator interface

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

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

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

+ func NewDiffCalculator(apply k8.ApplyClient, tree xp.ResourceTreeClient, ...) DiffCalculator

+ type DiffProcessor interface

+ Initialize func(ctx context.Context) error

+ PerformDiff func(ctx context.Context, stdout io.Writer, resources []*un.Unstructured) error

+ func NewDiffProcessor(k8cs k8.Clients, xpcs xp.Clients, opts ...ProcessorOption) DiffProcessor

+ type ProcessorConfig struct

+ Colorize bool

+ Compact bool

+ Factories ComponentFactories

+ Logger logging.Logger

+ Namespace string

+ RenderFunc RenderFunc

+ func (c *ProcessorConfig) GetDiffOptions() renderer.DiffOptions

+ func (c *ProcessorConfig) SetDefaultFactories()

+ type ProcessorOption func(*ProcessorConfig)

+ func WithColorize(colorize bool) ProcessorOption

+ func WithCompact(compact bool) ProcessorOption

+ func WithDiffCalculatorFactory(...) ProcessorOption

+ func WithDiffRendererFactory(factory func(logging.Logger, renderer.DiffOptions) renderer.DiffRenderer) ProcessorOption

+ func WithLogger(logger logging.Logger) ProcessorOption

+ func WithNamespace(namespace string) ProcessorOption

+ func WithRenderFunc(renderFn RenderFunc) ProcessorOption

+ func WithRequirementsProviderFactory(...) ProcessorOption

+ func WithResourceManagerFactory(factory func(k8.ResourceClient, logging.Logger) ResourceManager) ProcessorOption

+ func WithSchemaValidatorFactory(...) ProcessorOption

+ type RenderFunc func(ctx context.Context, log logging.Logger, in render.Inputs) (render.Outputs, error)

+ type RequirementsProvider struct

+ func NewRequirementsProvider(res k8.ResourceClient, env xp.EnvironmentClient, renderFn RenderFunc, ...) *RequirementsProvider

+ func (p *RequirementsProvider) ClearCache()

+ func (p *RequirementsProvider) Initialize(ctx context.Context) error

+ func (p *RequirementsProvider) ProvideRequirements(ctx context.Context, requirements map[string]v1.Requirements, ...) ([]*un.Unstructured, error)

+ type ResourceManager interface

+ FetchCurrentObject func(ctx context.Context, composite *un.Unstructured, desired *un.Unstructured) (*un.Unstructured, bool, error)

+ UpdateOwnerRefs func(parent *un.Unstructured, child *un.Unstructured)

+ func NewResourceManager(client k8.ResourceClient, logger logging.Logger) ResourceManager

+ type SchemaValidator interface

+ EnsureComposedResourceCRDs func(ctx context.Context, resources []*un.Unstructured) error

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

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

+ ValidateScopeConstraints func(ctx context.Context, resource *un.Unstructured, expectedNamespace string, ...) error

+ func NewSchemaValidator(sClient k8.SchemaClient, dClient xp.DefinitionClient, logger logging.Logger) SchemaValidator

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