runtime

May 7, 2026

Changes in this version

type HostPodReconciler

+ OperatorNamespace string

type HostReconciler

+ OperatorNamespace string

type WorkloadReconciler

+ AllowSharedHosts bool

+ OperatorNamespace string

+ Recorder events.EventRecorder

type WorkloadRouteReconciler

+ OperatorNamespace string

Apr 14, 2026

Changes in this version

+ type WorkloadRouteReconciler struct

+ Scheme *runtime.Scheme

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

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

Apr 2, 2026

Changes in this version

+ const HostPodLabel

+ type HostPodReconciler struct

+ Namespace string

+ Scheme *runtime.Scheme

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

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

Mar 22, 2026

Changes in this version

+ const HostRoundtripTimeout

+ func MaterializeConfigLayer(ctx context.Context, kubeClient client.Client, namespace string, ...) (map[string]string, error)

+ func MaterializeImagePullSecret(ctx context.Context, kubeClient client.Client, namespace string, name string, ...) (*runtimev2.ImagePullSecret, error)

+ func MergeMaps(maps ...map[string]string) map[string]string

+ func ResolveConfigFrom(ctx context.Context, kubeClient client.Client, namespace string, ...) (map[string]string, error)

+ func ResolveSecretFrom(ctx context.Context, kubeClient client.Client, namespace string, ...) (map[string]string, error)

+ func RoundTrip[Req proto.Message, Resp proto.Message](ctx context.Context, bus wasmbus.Bus, subject string, req Req, resp Resp) error

+ type ArtifactReconciler struct

+ Scheme *runtime.Scheme

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

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

+ type HostReconciler struct

+ Bus wasmbus.Bus

+ CPUThreshold float64

+ MemoryThreshold float64

+ Scheme *runtime.Scheme

+ UnreachableTimeout time.Duration

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

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

+ type WashHostClient struct

+ Bus wasmbus.Bus

+ HostID string

+ func NewWashHostClient(bus wasmbus.Bus, hostID string) *WashHostClient

+ func (w *WashHostClient) Heartbeat(ctx context.Context) (*runtimev2.HostHeartbeat, error)

+ func (w *WashHostClient) Start(ctx context.Context, req *runtimev2.WorkloadStartRequest) (*runtimev2.WorkloadStartResponse, error)

+ func (w *WashHostClient) Status(ctx context.Context, req *runtimev2.WorkloadStatusRequest) (*runtimev2.WorkloadStatusResponse, error)

+ func (w *WashHostClient) Stop(ctx context.Context, req *runtimev2.WorkloadStopRequest) (*runtimev2.WorkloadStopResponse, error)

+ type WorkloadDeploymentReconciler struct

+ Scheme *runtime.Scheme

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

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

+ type WorkloadReconciler struct

+ Bus wasmbus.Bus

+ Scheme *runtime.Scheme

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

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

+ type WorkloadReplicaSetReconciler struct

+ Scheme *runtime.Scheme

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

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