Versions in this module Expand all Collapse all v2 v2.0.1 Mar 22, 2026 v2.0.0 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 Other modules containing this package go.wasmcloud.dev/runtime-operator