controller

type AgentTaskReconciler struct {
	client.Client
	Clientset       kubernetes.Interface
	Scheme          *runtime.Scheme
	SandboxRegistry *registry.Registry[pkgsandbox.SandboxProvider]
	TokenMinter     auth.Minter
	TokenStore      auth.TokenStore
	TokenAuditor    auth.TokenAuditor
	Notifier        TaskNotifier
	LifecycleHook   SandboxLifecycleHook
	FeatureGate     FeatureGate
	DefaultProvider string
}

type DirectSetupRunner struct {
	// Executor is an optional SQLExecutor (e.g. *sql.DB). If nil, RunSetupSQL connects using adminDSN.
	Executor SQLExecutor
}

type EnvironmentReconciler struct {
	client.Client
	APIReader        client.Reader
	Scheme           *runtime.Scheme
	Recorder         *events.Recorder
	Router           routing.Router
	DatabaseProvider database.DatabaseProvider
	ChangeDetector   changeset.ChangeDetector
	Notifier         notifier.Notifier
	StatusReporter   notifier.StatusReporter
	Deployer         deployer.Deployer
	TestRunner       divtesting.TestRunner
	AsyncProvisioner async.Provisioner
	FeatureProvider  features.FeatureProvider
	SetupJobImage    string
	SetupRunner      SetupRunner
}

type FeatureGate interface {
	IsEnabled(ctx context.Context, feature string) bool
}

type HookJobConfig struct {
	JobName      string
	Namespace    string
	Image        string
	Args         []string
	EnvVars      []corev1.EnvVar
	EnvFrom      []corev1.EnvFromSource
	Volumes      []corev1.Volume
	VolumeMounts []corev1.VolumeMount
	Timeout      int32
	Owner        metav1.Object
	Labels       map[string]string
}

type JobSetupRunner struct {
	Reconciler *EnvironmentReconciler
}

type NoopTaskNotifier struct{}

type PreviewGroupReconciler struct {
	client.Client
	Scheme           *runtime.Scheme
	Recorder         *events.Recorder
	Notifier         notifier.PreviewGroupNotifier
	StatusReporter   notifier.StatusReporter
	DatabaseProvider database.DatabaseProvider
	EnableGAMMA      bool // Enable GAMMA mesh routing (requires Istio Ambient)
}

type SQLExecutor interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
}

type SandboxLifecycleHook interface {
	PreProvision(ctx context.Context, task *v1alpha1.AgentTask) error
	PostProvision(ctx context.Context, task *v1alpha1.AgentTask, res *pkgsandbox.SandboxResult) error
	PreTeardown(ctx context.Context, task *v1alpha1.AgentTask) error
}

type SetupRunner interface {
	RunSetupSQL(ctx context.Context, env *divergeiov1alpha1.Environment, setupSQL, adminDSN string) error
}

type StaticFeatureGate struct {
	Enabled bool
}

type TaskNotifier interface {
	NotifyPhaseChange(ctx context.Context, task *v1alpha1.AgentTask, oldPhase, newPhase v1alpha1.AgentTaskPhase) error
}