runtime

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 18, 2025 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const HostRoundtripTimeout = 1 * time.Minute

HostRoundtripTimeout is the max timeout for host RPC calls. Callers can set lower context timeouts as needed.

Variables

This section is empty.

Functions

func MaterializeConfigLayer 

func MaterializeConfigLayer(ctx context.Context,
	kubeClient client.Client, namespace string, configLayer *runtimev1alpha1.ConfigLayer,
) (map[string]string, error)

func MaterializeImagePullSecret 

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

func MergeMaps 

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

MergeMaps merges multiple maps of strings into a single map.

func ResolveConfigFrom 

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

func ResolveSecretFrom 

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

func RoundTrip 

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

RoundTrip sends a request and waits for a response.

Types

type ArtifactReconciler 

type ArtifactReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

ArtifactReconciler reconciles a Workload object

func (*ArtifactReconciler) Reconcile 

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

func (*ArtifactReconciler) SetupWithManager 

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

type HostReconciler 

type HostReconciler struct {
	client.Client
	Scheme             *runtime.Scheme
	Bus                wasmbus.Bus
	UnreachableTimeout time.Duration
	CPUThreshold       float64
	MemoryThreshold    float64
	// contains filtered or unexported fields
}

HostReconciler reconciles a Host object

func (*HostReconciler) Reconcile 

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

func (*HostReconciler) SetupWithManager 

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

type WashHostClient 

type WashHostClient struct {
	Bus    wasmbus.Bus
	HostID string
}

func NewWashHostClient 

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

func (*WashHostClient) Heartbeat 

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

func (*WashHostClient) Start 

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

func (*WashHostClient) Status 

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

func (*WashHostClient) Stop 

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

type WorkloadDeploymentReconciler 

type WorkloadDeploymentReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

WorkloadDeploymentReconciler reconciles a WorkloadReplicaSet object

func (*WorkloadDeploymentReconciler) Reconcile 

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

func (*WorkloadDeploymentReconciler) SetupWithManager 

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

type WorkloadReconciler 

type WorkloadReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	Bus    wasmbus.Bus
	// contains filtered or unexported fields
}

WorkloadReconciler reconciles a Workload object

func (*WorkloadReconciler) Reconcile 

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

func (*WorkloadReconciler) SetupWithManager 

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

type WorkloadReplicaSetReconciler 

type WorkloadReplicaSetReconciler struct {
	client.Client
	Scheme *runtime.Scheme
	// contains filtered or unexported fields
}

WorkloadReplicaSetReconciler reconciles a WorkloadReplicaSet object

func (*WorkloadReplicaSetReconciler) Reconcile 

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

func (*WorkloadReplicaSetReconciler) SetupWithManager 

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

Source Files

  • artifact_controller.go
  • host_client.go
  • host_controller.go
  • utils.go
  • workload_controller.go
  • workload_deployment_controller.go
  • workload_replicaset_controller.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.