Versions in this module Expand all Collapse all v0 v0.2.1 Oct 8, 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 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, defClient xp.DefinitionClient, logger logging.Logger) ResourceManager + SchemaValidator func(schema k8.SchemaClient, def xp.DefinitionClient, logger logging.Logger) SchemaValidator + 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 + 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(ctx context.Context, 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) LoadCRDs(ctx context.Context) error + 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 + RenderMutex *sync.Mutex + 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 WithRenderMutex(mu *sync.Mutex) ProcessorOption + func WithRequirementsProviderFactory(...) ProcessorOption + func WithResourceManagerFactory(...) 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(ctx context.Context, parent *un.Unstructured, child *un.Unstructured) + func NewResourceManager(client k8.ResourceClient, defClient xp.DefinitionClient, logger logging.Logger) ResourceManager + type SchemaValidator interface + EnsureComposedResourceCRDs func(ctx context.Context, resources []*un.Unstructured) error + 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