Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AgentReconciliation ¶
type AgentReconciliation struct {
Agent *kagentv1alpha3.Agent
Target *compiledTarget
Warnings []string
CompilationFailure *ReconciliationFailure
ObservedActorTemplate *ateapipb.ActorTemplate
PreparationFailure *ReconciliationFailure
}
AgentReconciliation is the complete desired and observed state for one Agent. Compilation failures are data so invalid Agents still produce status instead of disappearing from the graph.
func (AgentReconciliation) Equals ¶
func (r AgentReconciliation) Equals(other AgentReconciliation) bool
Equals keeps KRT from reflecting over protobuf caches that mutate during reads.
func (AgentReconciliation) ResourceName ¶
func (r AgentReconciliation) ResourceName() string
type AgentRuntimeObservation ¶
type AgentRuntimeObservation struct {
Namespace string
AgentName string
RevisionID translator.RevisionID
Template *ateapipb.ActorTemplate
Failure *ReconciliationFailure
}
AgentRuntimeObservation records a Agent's preparation. The revision prevents a cached observation from making changed inputs ready before reconciliation.
func (AgentRuntimeObservation) Equals ¶
func (p AgentRuntimeObservation) Equals(other AgentRuntimeObservation) bool
Equals compares runtime contents rather than protobuf's mutable caches.
func (AgentRuntimeObservation) ResourceName ¶
func (p AgentRuntimeObservation) ResourceName() string
type Collections ¶
type Collections struct {
SandboxTemplates krt.Collection[*kagentv1alpha3.SandboxTemplate]
Agents krt.Collection[*kagentv1alpha3.Agent]
AgentTemplates krt.Collection[*kagentv1alpha3.AgentTemplate]
Harnesses krt.Collection[*kagentv1alpha3.Harness]
ModelConfigs krt.Collection[*kagentv1alpha3.ModelConfig]
RemoteMCPServers krt.Collection[*kagentv1alpha3.RemoteMCPServer]
ConfigMaps krt.Collection[*corev1.ConfigMap]
Secrets krt.Collection[*corev1.Secret]
WorkerPools krt.Collection[*atev1alpha1.WorkerPool]
AgentRuntimeObservations krt.StaticCollection[AgentRuntimeObservation]
Reconciliations krt.Collection[AgentReconciliation]
ModelConfigStatuses krt.StatusCollection[*kagentv1alpha3.ModelConfig, kagentv1alpha3.ModelConfigStatus]
ResolvedModelConfigs krt.Collection[translator.ResolvedModelConfig]
AgentStatuses krt.StatusCollection[*kagentv1alpha3.Agent, kagentv1alpha3.AgentStatus]
}
Collections contains shared Kubernetes inputs and compiled Agent state.
func NewCollections ¶
func NewCollections(client kube.Client, watchNamespaces []string, opts krt.OptionsBuilder, settings *configv1.RuntimeDefaultsConfig, images *configv1.HarnessImagesConfig) Collections
NewCollections creates the complete read-only input graph. An empty watchNamespaces list watches all namespaces.
type Reconciler ¶
type Reconciler struct {
// contains filtered or unexported fields
}
Reconciler is the side-effect boundary for the pure KRT graph. Collection handlers enqueue stable keys; retries always read the latest derived state.
func NewReconciler ¶
func NewReconciler(config *rest.Config, collections Collections, store runtimeRevisionStore, templates actorTemplateClient) (*Reconciler, error)
NewReconciler creates the Kubernetes and database write boundary. Run starts its queues after the registered KRT handlers have received initial state.
func (*Reconciler) NeedLeaderElection ¶
func (r *Reconciler) NeedLeaderElection() bool
func (*Reconciler) Run ¶
func (r *Reconciler) Run(stop <-chan struct{})
Run waits for the graph boundary to observe initial state, then processes Agent and status writes until stop closes.
type ReconciliationFailure ¶
ReconciliationFailure identifies the condition stage blocked by an Agent.
type Runtime ¶
type Runtime struct {
Client kube.Client
Options krt.OptionsBuilder
Collections Collections
}
Runtime owns the Kubernetes client and common options shared by the KRT collections. Collections must be created before Start so their informers are registered before the client starts.
func NewRuntime ¶
func NewRuntime(config *rest.Config, watchNamespaces []string, stop <-chan struct{}, settings *configv1.RuntimeDefaultsConfig, images *configv1.HarnessImagesConfig) (*Runtime, error)
NewRuntime creates the shared KRT client and collection graph. Handlers are deliberately registered separately at the eventual application boundary.
type RuntimeRevisionGC ¶
type RuntimeRevisionGC struct {
// contains filtered or unexported fields
}
RuntimeRevisionGC retries durable runtime deletions independently of preparation.
func NewRuntimeRevisionGC ¶
func NewRuntimeRevisionGC(store runtimeRevisionGCStore, templates runtimeRevisionGCClient, pollInterval time.Duration, provider metric.MeterProvider) (*RuntimeRevisionGC, error)
func (*RuntimeRevisionGC) NeedLeaderElection ¶
func (r *RuntimeRevisionGC) NeedLeaderElection() bool
type SandboxReconciler ¶
type SandboxReconciler struct {
// contains filtered or unexported fields
}
SandboxReconciler owns the queued side effects of SandboxTemplate preparation. Sandbox instance lifecycle remains owned by the PostgreSQL-backed worker.
func NewSandboxReconciler ¶
func NewSandboxReconciler(config *rest.Config, runtime *Runtime, store sandboxRevisionStore, actors actorTemplateClient, policy substrate.SandboxPolicy) (*SandboxReconciler, error)
func (*SandboxReconciler) NeedLeaderElection ¶
func (s *SandboxReconciler) NeedLeaderElection() bool
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package remotemcpserver reconciles the discovered tool catalog published in RemoteMCPServer status.
|
Package remotemcpserver reconciles the discovered tool catalog published in RemoteMCPServer status. |
|
Package toolcatalog normalizes and publishes MCP catalog observations.
|
Package toolcatalog normalizes and publishes MCP catalog observations. |