controller

package

Go to main page

Versions in this module

v0

v0.6.49

Jul 10, 2026

v0.6.48

Jul 3, 2026

v0.6.47

Jun 27, 2026

Changes in this version

+ const EnvMemoryEnabled

v0.6.46

Jun 18, 2026

Changes in this version

+ const EnvStreamingProxy

v0.6.45

Jun 11, 2026

v0.6.44

Jun 6, 2026

Changes in this version

+ const EnvCodexMethod

v0.6.43

May 30, 2026

v0.6.42

May 23, 2026

v0.6.41

May 23, 2026

Changes in this version

+ const EnvExaConnection

+ const EnvMcpExcludeTools

+ const EnvOpenCodeOpenAICompatible

v0.6.40

May 16, 2026

v0.6.39

May 14, 2026

Changes in this version

+ const AgentRunFinalizer

+ const AgentRuntimeFinalizer

+ const EnvAgentRunID

+ const EnvBrowserEnabled

+ const EnvClaudeArgs

+ const EnvClaudeBashDefaultTimeout

+ const EnvClaudeBashMaxTimeout

+ const EnvClaudeEndpoint

+ const EnvClaudeModel

+ const EnvClaudeToken

+ const EnvCodexAPIKey

+ const EnvCodexEndpoint

+ const EnvCodexModel

+ const EnvConsoleURL

+ const EnvDeployToken

+ const EnvDindEnabled

+ const EnvExaMcpServers

+ const EnvExecTimeout

+ const EnvGeminiAPIKey

+ const EnvGeminiEndpoint

+ const EnvGeminiInactivityTimeout

+ const EnvGeminiModel

+ const EnvGitProxy

+ const EnvOpenCodeEndpoint

+ const EnvOpenCodeModel

+ const EnvOpenCodeProvider

+ const EnvOpenCodeToken

+ const PluralCAPIClusterFinalizer

+ const SentinelRunJobFinalizer

+ const StackRunJobFinalizer

+ const VirtualClusterFinalizer

+ func CreateConfigMap(ctx context.Context, client k8sClient.Client, restore *velerov1.Restore) error

+ func ExtractResourceRequests(obj *unstructured.Unstructured) map[string]*ResourceRequests

+ func GenerateAPIConstraint(instance *unstructured.Unstructured) (*console.PolicyConstraintAttributes, error)

+ func GetObjectFromOwnerReference(ctx context.Context, client k8sClient.Client, ref v1.OwnerReference, ...) (*unstructured.Unstructured, error)

+ func IsJobStatusConditionPresentAndEqual(conditions []batchv1.JobCondition, conditionType batchv1.JobConditionType, ...) bool

+ func IsJobStatusConditionTrue(conditions []batchv1.JobCondition, conditionType batchv1.JobConditionType) bool

+ func Job(ctx context.Context, r runtimeclient.Client, job *batchv1.Job, log logr.Logger) (*batchv1.Job, error)

+ func LogOverriddenCRDValues(ctx context.Context, spec v1alpha1.AgentConfigurationSpec)

+ type AgentConfigurationReconciler struct

+ Scheme *runtime.Scheme

+ func (r *AgentConfigurationReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, reterr error)

+ func (r *AgentConfigurationReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type AgentRunReconciler struct

+ CacheSyncTimeout time.Duration

+ ConsoleClient pluralclient.Client

+ ConsoleURL string

+ DeployToken string

+ Scheme *runtime.Scheme

+ func (r *AgentRunReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, retErr error)

+ func (r *AgentRunReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type AgentRuntimeReconciler struct

+ CacheSyncTimeout time.Duration

+ ClusterID string

+ ConsoleClient consoleclient.Client

+ Ctx context.Context

+ Scheme *runtime.Scheme

+ func (r *AgentRuntimeReconciler) ListAgentRuntimePendingRuns(ctx context.Context, id string) ...

+ func (r *AgentRuntimeReconciler) Publish(runID string, kick bool)

+ func (r *AgentRuntimeReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, retErr error)

+ func (r *AgentRuntimeReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type ArgoRolloutReconciler struct

+ ArgoClientSet roclientset.Interface

+ ConsoleClient client.Client

+ ConsoleURL string

+ DynamicClient dynamic.Interface

+ HttpClient *http.Client

+ KubeClient kubernetes.Interface

+ Scheme *runtime.Scheme

+ SvcReconciler v1.Reconciler

+ func (r *ArgoRolloutReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *ArgoRolloutReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type BackupReconciler struct

+ ConsoleClient client.Client

+ Scheme *runtime.Scheme

+ func (r *BackupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *BackupReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type BundleData struct

+ BundleDisplayName string

+ BundleName string

+ Description string

+ Remediation string

+ Severity string

+ type CloudProvider interface

+ UpgradeInsights func(context.Context, v1alpha1.UpgradeInsights) ([]console.UpgradeInsightAttributes, []console.CloudAddonAttributes, error)

+ func NewCloudProvider(distro *console.ClusterDistro, kubeClient runtimeclient.Client, ...) (CloudProvider, error)

+ type ClusterDrainReconciler struct

+ Scheme *runtime.Scheme

+ func (r *ClusterDrainReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, reterr error)

+ func (r *ClusterDrainReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type ConstraintReconciler struct

+ ConsoleClient consoleclient.Client

+ Constraints map[string]console.PolicyConstraintAttributes

+ Reader k8sClient.Reader

+ Scheme *runtime.Scheme

+ func (r *ConstraintReconciler) ConstraintPodStatusToUnstructured(ctx context.Context, cps *constraintstatusv1beta1.ConstraintPodStatus) (*unstructured.Unstructured, error)

+ func (r *ConstraintReconciler) Reconcile(ctx context.Context, req ctrl.Request) (reconcile.Result, error)

+ func (r *ConstraintReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type CrdRegisterControllerReconciler struct

+ DiscoveryCache discoverycache.Cache

+ Mgr ctrl.Manager

+ ReconcilerGroups map[schema.GroupVersionKind]SetupWithManager

+ Scheme *runtime.Scheme

+ func (r *CrdRegisterControllerReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *CrdRegisterControllerReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type CustomHealthReconciler struct

+ Scheme *runtime.Scheme

+ func (r *CustomHealthReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, reterr error)

+ func (r *CustomHealthReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type DebounceReconciler struct

+ func NewDebounceReconciler(client client.Client, duration time.Duration, actual reconcile.Reconciler) *DebounceReconciler

+ func (r *DebounceReconciler) Reconcile(_ context.Context, req reconcile.Request) (reconcile.Result, error)

+ func (r *DebounceReconciler) Start(ctx context.Context)

+ type DefaultScope struct

+ func (in *DefaultScope[T]) PatchObject() error

+ type EKSCloudProvider struct

+ func (in *EKSCloudProvider) UpgradeInsights(ctx context.Context, ui v1alpha1.UpgradeInsights) ([]console.UpgradeInsightAttributes, []console.CloudAddonAttributes, error)

+ type HelmReleaseReconciler struct

+ ClientSet kubernetes.Interface

+ Scheme *runtime.Scheme

+ func (r *HelmReleaseReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *HelmReleaseReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type IngressReplicaReconciler struct

+ Scheme *runtime.Scheme

+ func (r *IngressReplicaReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, reterr error)

+ func (r *IngressReplicaReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type K8sObjectIdentifier struct

+ GVK schema.GroupVersionKind

+ Name string

+ Namespace string

+ func (gvk K8sObjectIdentifier) String() string

+ type KubecostExtractorReconciler struct

+ ExtConsoleClient consoleclient.Client

+ KubeClient kubernetes.Interface

+ Proxy bool

+ Scheme *runtime.Scheme

+ ServiceIDCache *ServiceIDCache

+ Tasks cmap.ConcurrentMap[string, context.CancelFunc]

+ func (r *KubecostExtractorReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, reterr error)

+ func (r *KubecostExtractorReconciler) RunOnInterval(ctx context.Context, key string, interval time.Duration, ...)

+ func (r *KubecostExtractorReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type MetricsAggregateReconciler struct

+ DiscoveryCache discoverycache.Cache

+ Scheme *runtime.Scheme

+ func (r *MetricsAggregateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, reterr error)

+ func (r *MetricsAggregateReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager) error

+ type PipelineGateReconciler struct

+ ConsoleClient consoleclient.Client

+ GateCache *cache.Cache[console.PipelineGateFragment]

+ Scheme *runtime.Scheme

+ func (r *PipelineGateReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, reterr error)

+ func (r *PipelineGateReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type PluralCAPIClusterController struct

+ ConsoleUrl string

+ Scheme *runtime.Scheme

+ func (in *PluralCAPIClusterController) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, reterr error)

+ func (in *PluralCAPIClusterController) SetupWithManager(mgr ctrl.Manager) error

+ type ResourceRequests struct

+ CPU float64

+ Memory float64

+ type RestoreReconciler struct

+ ConsoleClient client.Client

+ Scheme *runtime.Scheme

+ func (r *RestoreReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *RestoreReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type Scope interface

+ PatchObject func() error

+ func NewDefaultScope[T client.Object](ctx context.Context, client client.Client, object T) (Scope[T], error)

+ type SentinelRunJobReconciler struct

+ ConsoleClient consoleclient.Client

+ ConsoleURL string

+ DeployToken string

+ Scheme *runtime.Scheme

+ func (r *SentinelRunJobReconciler) GenerateRunJob(run *console.SentinelRunJobFragment, jobSpec *batchv1.JobSpec, ...) (*batchv1.Job, error)

+ func (r *SentinelRunJobReconciler) GetRunResourceName(run *console.SentinelRunJobFragment) string

+ func (r *SentinelRunJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, retErr error)

+ func (r *SentinelRunJobReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type ServiceIDCache struct

+ func NewServiceIDCache(clearAfter time.Duration) *ServiceIDCache

+ func (c *ServiceIDCache) Get(key K8sObjectIdentifier) (string, bool)

+ func (c *ServiceIDCache) Set(key K8sObjectIdentifier, value string)

+ type SetupWithManager func(mgr ctrl.Manager) error

+ type StackRunJobReconciler struct

+ ConsoleClient client.Client

+ ConsoleURL string

+ DeployToken string

+ Scheme *runtime.Scheme

+ func (r *StackRunJobReconciler) GenerateRunJob(run *console.StackRunMinimalFragment, jobSpec *batchv1.JobSpec, ...) (*batchv1.Job, error)

+ func (r *StackRunJobReconciler) GetRunResourceName(run *console.StackRunMinimalFragment) string

+ func (r *StackRunJobReconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ reconcile.Result, retErr error)

+ func (r *StackRunJobReconciler) SetupWithManager(mgr ctrl.Manager) error

+ type StatusViolation struct

+ Group string

+ Kind string

+ Message string

+ Name string

+ Namespace string

+ Version string

+ type UpgradeInsightsController struct

+ ConsoleClient client.Client

+ Scheme *runtime.Scheme

+ func (in *UpgradeInsightsController) Reconcile(ctx context.Context, req reconcile.Request) (_ reconcile.Result, reterr error)

+ func (in *UpgradeInsightsController) SetupWithManager(mgr ctrl.Manager) error

+ type VirtualClusterController struct

+ ConsoleUrl string

+ ExtConsoleClient client.Client

+ Scheme *runtime.Scheme

+ func (in *VirtualClusterController) Reconcile(ctx context.Context, req reconcile.Request) (_ reconcile.Result, reterr error)

+ func (in *VirtualClusterController) SetupWithManager(mgr ctrl.Manager) error

+ type VulnerabilityReportReconciler struct

+ ConsoleClient client.Client

+ Ctx context.Context

+ Scheme *runtime.Scheme

+ func (r *VulnerabilityReportReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

+ func (r *VulnerabilityReportReconciler) SetupWithManager(mgr ctrl.Manager) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL