Versions in this module Expand all Collapse all v0 v0.2.1 Feb 24, 2026 v0.2.0 Feb 24, 2026 Changes in this version + const ComponentConditionSuffix + const ConditionTypeAuthValid + const ConditionTypeConfigValid + const ConditionTypeDependenciesReachable + const ConditionTypeReady + const DefaultRuntimeConfigName + const MessageAllComponentsReady + const MessageAuthError + const MessageAuthValid + const MessageComponentsNotReady + const MessageConfigValid + const MessageDependenciesNotReachable + const MessageDependenciesReachable + const MessageInfraError + const MessageInvalidSpec + const MessageMissingRef + const MessageProgressing + const ReasonAllComponentsReady + const ReasonAuthError + const ReasonAuthValid + const ReasonComponentsNotReady + const ReasonConfigValid + const ReasonDependenciesNotReachable + const ReasonDependenciesReachable + const ReasonInvalidSpec + const ReasonMissingRef + const ReasonProgressing + func ApplyControllerLabelsToResult(planResult *PlanResult, labels map[string]string) + func ApplyDesiredState(ctx context.Context, k8sClient client.Client, fieldOwner string, ...) error + func DeriveStateFromErrors(errs []error) constants.AIMStatus + func EmitConditionLogs(ctx context.Context, transitions []ConditionTransition, ...) + func EmitConditionTransitions(recorder record.EventRecorder, obj runtime.Object, ...) + func EmitRecurringEvents(recorder record.EventRecorder, obj runtime.Object, manager *ConditionManager) + func EmitRecurringLogs(ctx context.Context, manager *ConditionManager) + func IsReconciliationPaused(obj client.Object) bool + func IsStateEngineError(err error) bool + func MergeRuntimeConfigs(priority, base *aimv1alpha1.AIMRuntimeConfigCommon) *aimv1alpha1.AIMRuntimeConfigCommon + func PropagateLabels(parent, child client.Object, config *aimv1alpha1.AIMRuntimeConfigCommon) + func PropagateLabelsForResult(parent client.Object, planResult *PlanResult, ...) + type ChildRef struct + Kind string + Name string + Namespace string + type ComponentHealth struct + ChildRef *ChildRef + Component string + DependencyType DependencyType + Errors []error + Message string + Reason string + State constants.AIMStatus + func GetHTTPRouteHealth(route *gatewayapiv1.HTTPRoute) ComponentHealth + func GetJobHealth(job *batchv1.Job) ComponentHealth + func GetPodsHealth(ctx context.Context, clientset kubernetes.Interface, podList *corev1.PodList) ComponentHealth + func GetPvcHealth(pvc *corev1.PersistentVolumeClaim) ComponentHealth + func (ch ComponentHealth) GetMessage() string + func (ch ComponentHealth) GetReason() string + func (ch ComponentHealth) GetState() constants.AIMStatus + type ComponentHealthProvider interface + GetComponentHealth func() []ComponentHealth + type ConditionManager struct + func NewConditionManager(existing []metav1.Condition) *ConditionManager + func (m *ConditionManager) AllConditionsTrue(conditionTypes ...string) bool + func (m *ConditionManager) AnyConditionFalse(conditionTypes ...string) bool + func (m *ConditionManager) AnyConditionTrue(conditionTypes ...string) bool + func (m *ConditionManager) Conditions() []metav1.Condition + func (m *ConditionManager) ConfigFor(condType string) ObservabilityConfig + func (m *ConditionManager) Delete(condType string) + func (m *ConditionManager) Get(condType string) *metav1.Condition + func (m *ConditionManager) MarkFalse(condType, reason, message string, opts ...ObservabilityOption) + func (m *ConditionManager) MarkTrue(condType, reason, message string, opts ...ObservabilityOption) + func (m *ConditionManager) MarkUnknown(condType, reason, message string, opts ...ObservabilityOption) + func (m *ConditionManager) Set(conditionType string, status metav1.ConditionStatus, reason, message string, ...) + func (m *ConditionManager) SetCondition(cond metav1.Condition, opts ...ObservabilityOption) + type ConditionTransition struct + New *metav1.Condition + Old *metav1.Condition + func DiffConditionTransitions(oldConditions, newConditions []metav1.Condition) []ConditionTransition + type ConfiguredCondition struct + Config ObservabilityConfig + type DependencyType string + const DependencyTypeDownstream + const DependencyTypeUnspecified + const DependencyTypeUpstream + type DomainReconciler interface + ComposeState func(ctx context.Context, reconcileCtx ReconcileContext[T], fetched F) Obs + FetchRemoteState func(ctx context.Context, c client.Client, reconcileCtx ReconcileContext[T]) F + PlanResources func(ctx context.Context, reconcileCtx ReconcileContext[T], obs Obs) PlanResult + type ErrorCategory int + const ErrorCategoryAuth + const ErrorCategoryInfrastructure + const ErrorCategoryInvalidSpec + const ErrorCategoryMissingDownstreamDependency + const ErrorCategoryMissingUpstreamDependency + const ErrorCategoryResourceExhaustion + const ErrorCategoryUnknown + func (c ErrorCategory) String() string + type EventLevel string + const LevelNone + const LevelNormal + const LevelWarning + type EventMode string + const EventAlways + const EventNone + const EventOnTransition + type FetchResult struct + Error error + Value T + func FetchList[T client.ObjectList](ctx context.Context, c client.Client, list T, opts ...client.ListOption) FetchResult[T] + func FetchMergedRuntimeConfig(ctx context.Context, c client.Client, name, namespace string) FetchResult[*aimv1alpha1.AIMRuntimeConfigCommon] + func Fetch[T client.Object](ctx context.Context, c client.Client, key client.ObjectKey, obj T) FetchResult[T] + func (fr FetchResult[T]) HasError() bool + func (fr FetchResult[T]) IsNotFound() bool + func (fr FetchResult[T]) OK() bool + func (fr FetchResult[T]) ToComponentHealth(component string, inspector func(T) ComponentHealth) ComponentHealth + func (fr FetchResult[T]) ToComponentHealthWithContext(ctx context.Context, clientset kubernetes.Interface, component string, ...) ComponentHealth + func (fr FetchResult[T]) ToDownstreamComponentHealth(component string, inspector func(T) ComponentHealth) ComponentHealth + func (fr FetchResult[T]) ToUpstreamComponentHealth(component string, inspector func(T) ComponentHealth) ComponentHealth + type InfrastructureError struct + Count int + Errors []error + func (e InfrastructureError) Error() string + func (e InfrastructureError) Unwrap() []error + type LogMode string + const LogAlways + const LogNone + const LogOnTransition + type ManualStatusController interface + SetStatus func(status S, cm *ConditionManager, obs Obs) + type ObjectWithStatus interface + GetStatus func() S + type ObservabilityConfig struct + type ObservabilityOption func(*ObservabilityConfig) + func AsError() ObservabilityOption + func AsInfo() ObservabilityOption + func AsWarning() ObservabilityOption + func EventLevelToOption(level EventLevel) ObservabilityOption + func Silent() ObservabilityOption + func WithCriticalError() ObservabilityOption + func WithDebugLog() ObservabilityOption + func WithErrorLog() ObservabilityOption + func WithEventMessage(msg string) ObservabilityOption + func WithEventReason(reason string) ObservabilityOption + func WithInfoLog() ObservabilityOption + func WithLog(level int) ObservabilityOption + func WithLogMessage(msg string) ObservabilityOption + func WithNormalEvent() ObservabilityOption + func WithRecurring() ObservabilityOption + func WithRecurringErrorLog() ObservabilityOption + func WithRecurringWarningEvent() ObservabilityOption + func WithWarningEvent() ObservabilityOption + type Pipeline struct + Client client.Client + Clientset kubernetes.Interface + ControllerName string + Reconciler DomainReconciler[T, S, F, Obs] + Recorder record.EventRecorder + Scheme *runtime.Scheme + StatusClient client.StatusWriter + func (p *Pipeline[T, S, F, Obs]) GetFullName() string + func (p *Pipeline[T, S, F, Obs]) GetKubernetesName() string + func (p *Pipeline[T, S, F, Obs]) Run(ctx context.Context, obj T) (ctrl.Result, error) + type PlanResult struct + RequeueAfter time.Duration + func (pr *PlanResult) Apply(obj client.Object) + func (pr *PlanResult) ApplyWithoutOwnerRef(obj client.Object) + func (pr *PlanResult) Delete(obj client.Object) + func (pr *PlanResult) GetToApply() []client.Object + func (pr *PlanResult) GetToApplyWithoutOwnerRef() []client.Object + func (pr *PlanResult) GetToDelete() []client.Object + type ReconcileContext struct + MergedRuntimeConfig FetchResult[*aimv1alpha1.AIMRuntimeConfigCommon] + Object T + type RuntimeConfigRefProvider interface + GetRuntimeConfigRef func() aimv1alpha1.RuntimeConfigRef + type StateEngineDecision struct + RequeueError error + ShouldApply bool + ShouldRequeue bool + type StateEngineError interface + Category func() ErrorCategory + Reason func() string + UserMessage func() string + func CategorizeError(err error) StateEngineError + func NewAuthError(reason, message string, cause error) StateEngineError + func NewInfrastructureError(reason, message string, cause error) StateEngineError + func NewInvalidSpecError(reason, message string, cause error) StateEngineError + func NewMissingDownstreamDependencyError(reason, message string, cause error) StateEngineError + func NewMissingUpstreamDependencyError(reason, message string, cause error) StateEngineError + func NewResourceExhaustionError(reason, message string, cause error) StateEngineError + type StatusDecorator interface + DecorateStatus func(status S, cm *ConditionManager, obs Obs) + type StatusHelper struct + func NewStatusHelper(status StatusWithConditions, cm *ConditionManager) *StatusHelper + func (h *StatusHelper) Degraded(reason, msg string) + func (h *StatusHelper) Failed(reason, msg string) + func (h *StatusHelper) NotAvailable(reason, msg string) + func (h *StatusHelper) Progressing(reason, msg string) + func (h *StatusHelper) Ready(reason, msg string) + type StatusWithConditions interface + GetConditions func() []metav1.Condition + SetConditions func([]metav1.Condition) + SetStatus func(string) v0.2.0-rc1 Feb 23, 2026 v0.0.1-rc1 Feb 3, 2026
Go to main page