session

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

type HelmClient interface {
	// IsReachable checks whether the configured Kubernetes cluster is reachable.
	IsReachable() error

	// InstallApp installs or upgrades an application from [spec.ResolvedSpec].
	// Chart content, release name, and labels all come from resolved.
	// crds are written into the per-invocation chart copy under crds/.
	// skipCRDs maps to Helm Install.SkipCRDs on a fresh install only.
	// postRenderer, when non-nil, is applied to the rendered manifests
	// before they are sent to the cluster.
	InstallApp(ctx context.Context, dryRun bool, resolved *spec.ResolvedSpec, postRenderer postrenderer.PostRenderer, crds []extras.RawFile, skipCRDs bool) error

	// RenderManifests renders the chart from [spec.ResolvedSpec] client-side,
	// without mutating the cluster or Helm's release history. The caller must
	// run the returned cleanup func once done with the result's ChartPath.
	// crds are written into the per-invocation chart copy under crds/.
	// postRenderer, when non-nil, is applied to the rendered manifests.
	RenderManifests(ctx context.Context, resolved *spec.ResolvedSpec, postRenderer postrenderer.PostRenderer, crds []extras.RawFile) (*render.RenderResult, func(), error)

	// RenderManifestsWithPrep is [HelmClient.RenderManifests] and the
	// [helm.ReleasePrep] that picked install or upgrade.
	// Cleanup is nil on error. On success the caller runs it once.
	RenderManifestsWithPrep(ctx context.Context, resolved *spec.ResolvedSpec, postRenderer postrenderer.PostRenderer, crds []extras.RawFile) (*render.RenderResult, helm.ReleasePrep, func(), error)

	// DeleteRelease uninstalls a Helm release. When wait is true the call
	// blocks until all resources are fully removed using the legacy polling
	// strategy with foreground cascade deletion.
	DeleteRelease(ctx context.Context, project, environment string, wait bool) error

	// GetRelease retrieves information about a specific release.
	GetRelease(ctx context.Context, project, environment string) (*v1.Release, error)

	// ListReleases returns a list of releases matching the given selector.
	ListReleases(ctx context.Context, selector labels.Selector) ([]*v1.Release, error)

	// GetReleaseHistory returns the history of a specific release.
	GetReleaseHistory(ctx context.Context, project, environment string) ([]*v1.Release, error)

	// RollbackRelease rolls back a release to a previous revision.
	RollbackRelease(ctx context.Context, releaseName string, revision int, timeout time.Duration) error
}

type HelmConfig struct {
	// KubeconfigPath is the explicit kubeconfig path snapshotted from
	// Session. Destination selection uses [target.Target], not this field.
	KubeconfigPath string
	// ExtraKubeconfigPaths is the extra kubeconfig path list snapshotted
	// from Session. Destination selection uses [target.Target], not this
	// field.
	ExtraKubeconfigPaths []string
	// StorageDriver is the Helm storage driver (secret, configmap, or memory).
	// Empty lets [helm.NewClient] use its default ("secret").
	StorageDriver string
	// Debug reports whether temporary chart directories should be kept.
	Debug bool
	// Timeout is the Helm operation timeout. Zero lets [helm.NewClient] use
	// its default (5 minutes). [Session.New] sets [DefaultTimeout] (10
	// minutes) unless [WithTimeout] overrides it.
	Timeout time.Duration
}

type HelmFactory func(*target.Target, HelmConfig) (HelmClient, error)

type Option func(*Session)

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