crossplane

type Clients struct {
	Composition  CompositionClient
	Credential   CredentialClient
	Definition   DefinitionClient
	Environment  EnvironmentClient
	Function     FunctionClient
	ResourceTree ResourceTreeClient
}

type CompositionClient interface {
	core.Initializable

	// FindMatchingComposition finds the composition that matches the given XR or claim, and the
	// CompositionRevision it comes from when one applies. See dtypes.ResolvedComposition.
	FindMatchingComposition(ctx context.Context, res *un.Unstructured) (dtypes.ResolvedComposition, error)

	// ListCompositions lists all compositions in the cluster
	ListCompositions(ctx context.Context) ([]*apiextensionsv1.Composition, error)

	// GetComposition gets a composition by name
	GetComposition(ctx context.Context, name string) (*apiextensionsv1.Composition, error)

	// FindComposites locates composites (XRs and Claims) that reference a composition.
	// `comp` is taken as the user-supplied unstructured Composition (typically loaded from a YAML
	// file); the client converts to a typed *apiextensionsv1.Composition internally only when
	// needed (i.e. in refs-mode, which reads spec.compositeTypeRef). Default-discovery only needs
	// comp.GetName() and avoids the conversion entirely so it isn't tripped by version skew or
	// unknown fields in the input file.
	//
	// When opts.Refs is non-empty, it performs ref-based lookup: each ref is resolved against the
	// composition's XR GVK (then claim GVK on 404 if the XRD defines a claim type). A ref is included
	// in the result only when (a) the cluster lookup succeeds AND (b) the resource references this
	// composition by name. Refs that don't satisfy both are silently omitted; callers derive
	// "unmatched" from the diff between input refs and returned objects. NotFound on per-ref XR/Claim
	// lookups is tolerated; non-NotFound transport errors propagate.
	//
	// When opts.Refs is empty, it performs default discovery scoped to opts.Namespace, listing all
	// XRs (and Claims, if the XRD defines them) of the appropriate GVK and filtering by composition.
	// XR/Claim list errors are tolerated (each list is best-effort and produces an empty bucket on
	// failure). However, the composition itself must be in the cluster cache: when GetComposition
	// returns NotFound (a net-new composition not yet applied), FindComposites returns that error to
	// the caller. Callers handle that case by treating it as "no affected XRs" — see
	// DiffComposition's default-discovery branch.
	FindComposites(ctx context.Context, comp *un.Unstructured, opts dtypes.FindCompositesOptions) ([]*un.Unstructured, error)
}

type CompositionRevisionClient interface {
	core.Initializable

	// GetCompositionRevision gets a composition revision by name
	GetCompositionRevision(ctx context.Context, name string) (*apiextensionsv1.CompositionRevision, error)

	// ListCompositionRevisions lists all composition revisions in the cluster
	ListCompositionRevisions(ctx context.Context) ([]*apiextensionsv1.CompositionRevision, error)

	// GetLatestRevisionForComposition finds the latest (highest-numbered) revision for a given
	// composition whose labels match the provided selector. This mirrors how Crossplane selects a
	// revision for an XR with an Automatic compositionUpdatePolicy: with a compositionRevisionSelector
	// it picks the newest matching revision, otherwise the newest overall. A nil selector means no
	// restriction (latest overall).
	GetLatestRevisionForComposition(ctx context.Context, compositionName string, selector labels.Selector) (*apiextensionsv1.CompositionRevision, error)

	// GetCompositionFromRevision extracts a Composition from a CompositionRevision
	GetCompositionFromRevision(revision *apiextensionsv1.CompositionRevision) *apiextensionsv1.Composition
}

type CredentialClient interface {
	// FetchCompositionCredentials extracts credential refs from a composition's pipeline steps and
	// fetches the referenced secrets from the cluster. Secrets that do not exist are reported in the
	// result's Absent list rather than failing the fetch: they may be injected at runtime (e.g.
	// workload identity) or supplied by the caller via --function-credentials. Any other failure to
	// read a referenced secret is returned as an error.
	FetchCompositionCredentials(ctx context.Context, comp *apiextensionsv1.Composition) (types.CredentialFetchResult, error)
}

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

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

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

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

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

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

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

type DefinitionClient interface {
	core.Initializable

	// GetXRDs gets all XRDs in the cluster
	GetXRDs(ctx context.Context) ([]*un.Unstructured, error)

	// GetXRDForClaim finds the XRD that defines the given claim type
	GetXRDForClaim(ctx context.Context, gvk schema.GroupVersionKind) (*un.Unstructured, error)

	// GetXRDForXR finds the XRD that defines the given XR type
	GetXRDForXR(ctx context.Context, gvk schema.GroupVersionKind) (*un.Unstructured, error)

	// IsClaimResource checks if the given resource is a claim type
	IsClaimResource(ctx context.Context, resource *un.Unstructured) bool

	// GetCompositeSchema returns the composite.Schema (Legacy or Modern) that
	// applies to the given XR or claim GVK. The scope is read from the XRD's
	// spec.scope field (NOT the XRD's own apiVersion, which the apiserver may
	// rewrite during v1↔v2 conversion). spec.scope == "LegacyCluster" maps to
	// SchemaLegacy (canonical fields under spec.*); "Cluster"/"Namespaced" map
	// to SchemaModern (canonical fields under spec.crossplane.*). Mirrors the
	// rule the render binary uses (selectSchema in crossplane's
	// internal/render/composite/render.go).
	GetCompositeSchema(ctx context.Context, gvk schema.GroupVersionKind) (ucomposite.Schema, error)
}

type EnvironmentClient interface {
	core.Initializable

	// GetEnvironmentConfigs gets all environment configurations
	GetEnvironmentConfigs(ctx context.Context) ([]*un.Unstructured, error)

	// GetEnvironmentConfig gets a specific environment config by name
	GetEnvironmentConfig(ctx context.Context, name string) (*un.Unstructured, error)
}

type FunctionClient interface {
	core.Initializable

	// GetFunctionsFromPipeline gets functions used in a composition pipeline
	GetFunctionsFromPipeline(comp *apiextensionsv1.Composition) ([]pkgv1.Function, error)

	// ListFunctions lists all functions in the cluster
	ListFunctions(ctx context.Context) ([]pkgv1.Function, error)
}

type ResourceTreeClient interface {
	core.Initializable

	// GetResourceTree gets the resource tree for a root resource
	GetResourceTree(ctx context.Context, root *un.Unstructured) (*resource.Resource, error)
}