types

type Applier interface {
	Apply(deployInfo InstallInfo, objects *ManifestResources, namespace string) (bool, error)
}

type ApplierOptions struct {
	Manifest string

	RESTConfig *rest.Config
	RESTMapper meta.RESTMapper
	Namespace  string
	Validate   bool
	ExtraArgs  []string
}

type BaseCustomObject interface {
	runtime.Object
	metav1.Object
}

type CacheManager interface {
	// InvalidateForOwner invalidates all cache entries which are cached by an owner key.
	// Here all caches should be deleted where entries are unique by a parent resource.
	InvalidateForOwner(key client.ObjectKey)

	// InvalidateSelf invalidates all cache entries which are cached on resource level.
	// Here all cache entries should be deleted where entries are unique by a resource itself.
	InvalidateSelf(key client.ObjectKey)

	// GetRendererCache returns the cache stored under RendererCache.
	GetRendererCache() RendererCache
}

type ChartFlags struct {
	// ConfigFlags support string, bool and int types as helm chart flags
	// check: https://github.com/helm/helm/blob/d7b4c38c42cb0b77f1bcebf9bb4ae7695a10da0b/pkg/action/install.go#L67
	ConfigFlags Flags

	// SetFlags are chart value overrides
	SetFlags Flags
}

type ChartInfo struct {
	ChartPath   string
	RepoName    string
	URL         string
	ChartName   string
	ReleaseName string
	Flags       ChartFlags
}

type Check interface {
	CheckFn(context.Context, *unstructured.Unstructured, logr.Logger, ClusterInfo) (bool, error)
	DefaultFn(context.Context, *unstructured.Unstructured, logr.Logger, ClusterInfo) (bool, error)
}

type CheckFnType func(context.Context, *unstructured.Unstructured, logr.Logger, ClusterInfo) (bool, error)

type ClusterInfo struct {
	Config *rest.Config
	Client client.Client
}

type ClusterInfoCache interface {
	// Get returns the cluster information cached entry by the key passed.
	Get(key client.ObjectKey) ClusterInfo

	// Set sets the cluster information cached entry by the key passed.
	Set(key client.ObjectKey, info ClusterInfo)

	// Delete deletes the cluster information cached entry by the key passed.
	Delete(key client.ObjectKey)
}

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

type CustomObject interface {
	runtime.Object
	metav1.Object
	ComponentName() string
	GetStatus() Status
	SetStatus(Status)
}

type Flags map[string]interface{}

type HelmChartSpec struct {
	// URL defines the helm repo URL
	// +kubebuilder:validation:Optional
	URL string `json:"url"`

	// ChartName defines the helm chart name
	// +kubebuilder:validation:Optional
	ChartName string `json:"chartName"`

	// Type defines the chart as "helm-chart"
	// +kubebuilder:validation:Optional
	Type RefTypeMetadata `json:"type"`
}

type HelmOperation OperationType

type ImageSpec struct {
	// Repo defines the Image repo
	// +kubebuilder:validation:Optional
	Repo string `json:"repo"`

	// Name defines the Image name
	// +kubebuilder:validation:Optional
	Name string `json:"name"`

	// Ref is either a sha value, tag or version
	// +kubebuilder:validation:Optional
	Ref string `json:"ref"`

	// Type defines the chart as "oci-ref"
	// +kubebuilder:validation:Optional
	Type RefTypeMetadata `json:"type"`
}

type InstallInfo struct {
	// ChartInfo represents chart information to be processed
	*ChartInfo
	// ResourceInfo represents additional resources to be processed
	ResourceInfo
	// ClusterInfo represents target cluster information
	ClusterInfo
	// Ctx hold the current context
	Ctx context.Context //nolint:containedctx
	// CheckFn returns a boolean indicating ready state based on custom checks
	CheckFn CheckFnType
	// CheckReadyStates indicates if native resources should be checked for ready states
	CheckReadyStates bool
	// UpdateRepositories indicates if repositories should be updated
	UpdateRepositories bool
}

type InstallationSpec struct {
	ChartPath   string
	ReleaseName string
	ChartFlags
}

type KustomizeSpec struct {
	// Path defines the Kustomize local path
	Path string `json:"path"`

	// URL defines the Kustomize remote URL
	URL string `json:"url"`

	// Type defines the chart as "kustomize"
	// +kubebuilder:validation:Optional
	Type RefTypeMetadata `json:"type"`
}

type LabelNotFoundError struct {
	Resource  client.Object
	LabelName string
}

type ManifestClient interface {
	// GetRawManifest returns processed resource manifest using the client.
	GetRawManifest(deployInfo InstallInfo) *ParsedFile

	// Install transforms and applies resources based on InstallInfo.
	Install(manifest string, deployInfo InstallInfo, transforms []ObjectTransform) (bool, error)

	// Uninstall transforms and applies resources based on InstallInfo.
	Uninstall(manifest string, deployInfo InstallInfo, transforms []ObjectTransform) (bool, error)

	// IsConsistent transforms and checks if resources are consistently installed based on InstallInfo.
	IsConsistent(manifest string, deployInfo InstallInfo, transforms []ObjectTransform) (bool, error)

	// GetCachedResources returns a resource manifest which was already cached during previous operations.
	// By default, it looks inside <chart-path>/manifest/manifest.yaml
	GetCachedResources(chartName, chartPath string) *ParsedFile

	// DeleteCachedResources deletes cached resource manifest.
	// By default, it deletes <chart-path>/manifest/manifest.yaml.
	DeleteCachedResources(chartPath string) *ParsedFile

	// GetManifestResources returns a pre-rendered resource manifest file located at the passed chartPath.
	// If multiple YAML files are present at the dirPath, it cannot resolve the file to be used, hence will not process.
	GetManifestResources(dirPath string) *ParsedFile

	// InvalidateConfigAndRenderedManifest compares the cached hash with the processed hash for helm flags.
	// On mismatch, it invalidates the cached manifest and resets flags on client.
	InvalidateConfigAndRenderedManifest(deployInfo InstallInfo, cachedHash uint32) (uint32, error)

	// GetClusterInfo returns Client and REST config for the target cluster
	GetClusterInfo() (ClusterInfo, error)
}

type ManifestResolver interface {
	// Get returns chart information to be processed, based on the passed CR.
	Get(object BaseCustomObject, logger logr.Logger) (InstallationSpec, error)
}

type ManifestResources struct {
	Items []*unstructured.Unstructured
	Blobs [][]byte
}

type MultiError struct {
	Errs []error
}

type ObjectTransform = func(context.Context, BaseCustomObject, *ManifestResources) error

type OperationType string

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

type RefTypeMetadata string

type RendererCache interface {
	// GetProcessor returns the manifest processor cached entry by key passed.
	GetProcessor(key client.ObjectKey) ManifestClient

	// SetProcessor sets the manifest processor cached entry by key passed.
	SetProcessor(key client.ObjectKey, renderSrc ManifestClient)

	// DeleteProcessor deletes the manifest processor cached entry by key passed.
	DeleteProcessor(key client.ObjectKey)

	// GetConfig returns the hashed configuration cached entry by key passed.
	GetConfig(key client.ObjectKey) uint32

	// SetConfig returns the hashed configuration cached entry by key passed.
	SetConfig(key client.ObjectKey, cfg uint32)

	// DeleteConfig deletes the hashed configuration cached entry by key passed.
	DeleteConfig(key client.ObjectKey)
}

type ResourceInfo struct {
	// BaseResource represents base custom resource that is being reconciled
	BaseResource *unstructured.Unstructured
	// CustomResources represents a set of additional custom resources to be installed
	CustomResources []*unstructured.Unstructured
	// Crds represents a set of additional custom resource definitions to be installed
	Crds []*v1.CustomResourceDefinition
}

type ResourceLists struct {
	Target    kube.ResourceList
	Installed kube.ResourceList
	Namespace kube.ResourceList
}

type State string

type Status struct {
	// State signifies current state of CustomObject.
	// Value can be one of ("Ready", "Processing", "Error", "Deleting").
	// +kubebuilder:validation:Required
	// +kubebuilder:validation:Enum=Processing;Deleting;Ready;Error
	State State `json:"state"`

	// Conditions associated with CustomStatus.
	Conditions []*metav1.Condition `json:"conditions,omitempty"`
}