v2

package
v2.0.1 Latest Latest
Warning

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

Go to latest
Published: Mar 22, 2026 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	WorkloadState_name = map[int32]string{
		0: "WORKLOAD_STATE_UNSPECIFIED",
		1: "WORKLOAD_STATE_STARTING",
		2: "WORKLOAD_STATE_RUNNING",
		3: "WORKLOAD_STATE_COMPLETED",
		4: "WORKLOAD_STATE_STOPPING",
		5: "WORKLOAD_STATE_ERROR",
		6: "WORKLOAD_STATE_NOT_FOUND",
	}
	WorkloadState_value = map[string]int32{
		"WORKLOAD_STATE_UNSPECIFIED": 0,
		"WORKLOAD_STATE_STARTING":    1,
		"WORKLOAD_STATE_RUNNING":     2,
		"WORKLOAD_STATE_COMPLETED":   3,
		"WORKLOAD_STATE_STOPPING":    4,
		"WORKLOAD_STATE_ERROR":       5,
		"WORKLOAD_STATE_NOT_FOUND":   6,
	}
)

Enum value maps for WorkloadState.

View Source
var (
	ImagePullPolicy_name = map[int32]string{
		0: "IMAGE_PULL_POLICY_UNSPECIFIED",
		1: "IMAGE_PULL_POLICY_ALWAYS",
		2: "IMAGE_PULL_POLICY_IF_NOT_PRESENT",
		3: "IMAGE_PULL_POLICY_NEVER",
	}
	ImagePullPolicy_value = map[string]int32{
		"IMAGE_PULL_POLICY_UNSPECIFIED":    0,
		"IMAGE_PULL_POLICY_ALWAYS":         1,
		"IMAGE_PULL_POLICY_IF_NOT_PRESENT": 2,
		"IMAGE_PULL_POLICY_NEVER":          3,
	}
)

Enum value maps for ImagePullPolicy.

View Source
var File_wasmcloud_runtime_v2_host_heartbeat_proto protoreflect.FileDescriptor
View Source
var File_wasmcloud_runtime_v2_host_service_proto protoreflect.FileDescriptor
View Source
var File_wasmcloud_runtime_v2_wit_interface_proto protoreflect.FileDescriptor
View Source
var File_wasmcloud_runtime_v2_workload_proto protoreflect.FileDescriptor
View Source
var File_wasmcloud_runtime_v2_workload_service_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Component

type Component struct {
	Image          string          `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	LocalResources *LocalResources `protobuf:"bytes,2,opt,name=local_resources,json=localResources,proto3" json:"local_resources,omitempty"`
	PoolSize       int32           `protobuf:"zigzag32,3,opt,name=pool_size,json=poolSize,proto3" json:"pool_size,omitempty"`
	MaxInvocations int32           `protobuf:"zigzag32,4,opt,name=max_invocations,json=maxInvocations,proto3" json:"max_invocations,omitempty"`
	// Optional credentials for pulling the image from a private registry
	ImagePullSecret *ImagePullSecret `protobuf:"bytes,5,opt,name=image_pull_secret,json=imagePullSecret,proto3" json:"image_pull_secret,omitempty"`
	Name            string           `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	ImagePullPolicy ImagePullPolicy  `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

Components are the building blocks of a Workload. All their invocations happen over WIT Interfaces, and state is ephemeral. While they can TCP connect outbound, they cannot accept inbound connections (fail bind call).

func (*Component) Descriptor deprecated

func (*Component) Descriptor() ([]byte, []int)

Deprecated: Use Component.ProtoReflect.Descriptor instead.

func (*Component) GetImage

func (x *Component) GetImage() string

func (*Component) GetImagePullPolicy

func (x *Component) GetImagePullPolicy() ImagePullPolicy

func (*Component) GetImagePullSecret

func (x *Component) GetImagePullSecret() *ImagePullSecret

func (*Component) GetLocalResources

func (x *Component) GetLocalResources() *LocalResources

func (*Component) GetMaxInvocations

func (x *Component) GetMaxInvocations() int32

func (*Component) GetName

func (x *Component) GetName() string

func (*Component) GetPoolSize

func (x *Component) GetPoolSize() int32

func (*Component) ProtoMessage

func (*Component) ProtoMessage()

func (*Component) ProtoReflect

func (x *Component) ProtoReflect() protoreflect.Message

func (*Component) Reset

func (x *Component) Reset()

func (*Component) String

func (x *Component) String() string

type EmptyDirVolume

type EmptyDirVolume struct {
	// contains filtered or unexported fields
}

func (*EmptyDirVolume) Descriptor deprecated

func (*EmptyDirVolume) Descriptor() ([]byte, []int)

Deprecated: Use EmptyDirVolume.ProtoReflect.Descriptor instead.

func (*EmptyDirVolume) ProtoMessage

func (*EmptyDirVolume) ProtoMessage()

func (*EmptyDirVolume) ProtoReflect

func (x *EmptyDirVolume) ProtoReflect() protoreflect.Message

func (*EmptyDirVolume) Reset

func (x *EmptyDirVolume) Reset()

func (*EmptyDirVolume) String

func (x *EmptyDirVolume) String() string

type HostHeartbeat

type HostHeartbeat struct {

	// unique host identifier
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// public hostname, may be an IP address or DNS name
	Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// friendly name for the host
	FriendlyName string `protobuf:"bytes,3,opt,name=friendly_name,json=friendlyName,proto3" json:"friendly_name,omitempty"`
	// version of the host runtime
	Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// arbitrary key/value labels associated with the host
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// timestamp when the host started
	StartedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	// operating system architecture
	OsArch string `protobuf:"bytes,7,opt,name=os_arch,json=osArch,proto3" json:"os_arch,omitempty"`
	// operating system name
	OsName string `protobuf:"bytes,8,opt,name=os_name,json=osName,proto3" json:"os_name,omitempty"`
	// operating system kernel version
	OsKernel string `protobuf:"bytes,9,opt,name=os_kernel,json=osKernel,proto3" json:"os_kernel,omitempty"`
	// system cpu usage in percent
	SystemCpuUsage float32 `protobuf:"fixed32,10,opt,name=system_cpu_usage,json=systemCpuUsage,proto3" json:"system_cpu_usage,omitempty"`
	// system total memory in bytes
	SystemMemoryTotal uint64 `protobuf:"varint,11,opt,name=system_memory_total,json=systemMemoryTotal,proto3" json:"system_memory_total,omitempty"`
	// system free memory in bytes
	SystemMemoryFree uint64 `protobuf:"varint,12,opt,name=system_memory_free,json=systemMemoryFree,proto3" json:"system_memory_free,omitempty"`
	// number of components running on the host
	ComponentCount uint64 `protobuf:"varint,13,opt,name=component_count,json=componentCount,proto3" json:"component_count,omitempty"`
	// number of workloads running on the host
	WorkloadCount uint64 `protobuf:"varint,14,opt,name=workload_count,json=workloadCount,proto3" json:"workload_count,omitempty"`
	// WIT interfaces supported by the host
	Imports []*WitInterface `protobuf:"bytes,15,rep,name=imports,proto3" json:"imports,omitempty"`
	// WIT interfaces supported by the host
	Exports []*WitInterface `protobuf:"bytes,16,rep,name=exports,proto3" json:"exports,omitempty"`
	// HTTP port the host is listening on
	HttpPort uint32 `protobuf:"varint,17,opt,name=http_port,json=httpPort,proto3" json:"http_port,omitempty"`
	// contains filtered or unexported fields
}

func (*HostHeartbeat) Descriptor deprecated

func (*HostHeartbeat) Descriptor() ([]byte, []int)

Deprecated: Use HostHeartbeat.ProtoReflect.Descriptor instead.

func (*HostHeartbeat) GetComponentCount

func (x *HostHeartbeat) GetComponentCount() uint64

func (*HostHeartbeat) GetExports

func (x *HostHeartbeat) GetExports() []*WitInterface

func (*HostHeartbeat) GetFriendlyName

func (x *HostHeartbeat) GetFriendlyName() string

func (*HostHeartbeat) GetHostname

func (x *HostHeartbeat) GetHostname() string

func (*HostHeartbeat) GetHttpPort

func (x *HostHeartbeat) GetHttpPort() uint32

func (*HostHeartbeat) GetId

func (x *HostHeartbeat) GetId() string

func (*HostHeartbeat) GetImports

func (x *HostHeartbeat) GetImports() []*WitInterface

func (*HostHeartbeat) GetLabels

func (x *HostHeartbeat) GetLabels() map[string]string

func (*HostHeartbeat) GetOsArch

func (x *HostHeartbeat) GetOsArch() string

func (*HostHeartbeat) GetOsKernel

func (x *HostHeartbeat) GetOsKernel() string

func (*HostHeartbeat) GetOsName

func (x *HostHeartbeat) GetOsName() string

func (*HostHeartbeat) GetStartedAt

func (x *HostHeartbeat) GetStartedAt() *timestamppb.Timestamp

func (*HostHeartbeat) GetSystemCpuUsage

func (x *HostHeartbeat) GetSystemCpuUsage() float32

func (*HostHeartbeat) GetSystemMemoryFree

func (x *HostHeartbeat) GetSystemMemoryFree() uint64

func (*HostHeartbeat) GetSystemMemoryTotal

func (x *HostHeartbeat) GetSystemMemoryTotal() uint64

func (*HostHeartbeat) GetVersion

func (x *HostHeartbeat) GetVersion() string

func (*HostHeartbeat) GetWorkloadCount

func (x *HostHeartbeat) GetWorkloadCount() uint64

func (*HostHeartbeat) ProtoMessage

func (*HostHeartbeat) ProtoMessage()

func (*HostHeartbeat) ProtoReflect

func (x *HostHeartbeat) ProtoReflect() protoreflect.Message

func (*HostHeartbeat) Reset

func (x *HostHeartbeat) Reset()

func (*HostHeartbeat) String

func (x *HostHeartbeat) String() string

type HostHeartbeatRequest

type HostHeartbeatRequest struct {
	Heartbeat *HostHeartbeat `protobuf:"bytes,1,opt,name=heartbeat,proto3" json:"heartbeat,omitempty"`
	// contains filtered or unexported fields
}

func (*HostHeartbeatRequest) Descriptor deprecated

func (*HostHeartbeatRequest) Descriptor() ([]byte, []int)

Deprecated: Use HostHeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HostHeartbeatRequest) GetHeartbeat

func (x *HostHeartbeatRequest) GetHeartbeat() *HostHeartbeat

func (*HostHeartbeatRequest) ProtoMessage

func (*HostHeartbeatRequest) ProtoMessage()

func (*HostHeartbeatRequest) ProtoReflect

func (x *HostHeartbeatRequest) ProtoReflect() protoreflect.Message

func (*HostHeartbeatRequest) Reset

func (x *HostHeartbeatRequest) Reset()

func (*HostHeartbeatRequest) String

func (x *HostHeartbeatRequest) String() string

type HostPathVolume

type HostPathVolume struct {
	LocalPath string `protobuf:"bytes,1,opt,name=local_path,json=localPath,proto3" json:"local_path,omitempty"`
	// contains filtered or unexported fields
}

func (*HostPathVolume) Descriptor deprecated

func (*HostPathVolume) Descriptor() ([]byte, []int)

Deprecated: Use HostPathVolume.ProtoReflect.Descriptor instead.

func (*HostPathVolume) GetLocalPath

func (x *HostPathVolume) GetLocalPath() string

func (*HostPathVolume) ProtoMessage

func (*HostPathVolume) ProtoMessage()

func (*HostPathVolume) ProtoReflect

func (x *HostPathVolume) ProtoReflect() protoreflect.Message

func (*HostPathVolume) Reset

func (x *HostPathVolume) Reset()

func (*HostPathVolume) String

func (x *HostPathVolume) String() string

type ImagePullPolicy

type ImagePullPolicy int32
const (
	// Default policy, fallthrough to the host's default pull policy
	ImagePullPolicy_IMAGE_PULL_POLICY_UNSPECIFIED ImagePullPolicy = 0
	// Always pull the image
	ImagePullPolicy_IMAGE_PULL_POLICY_ALWAYS ImagePullPolicy = 1
	// Pull the image if not present locally
	ImagePullPolicy_IMAGE_PULL_POLICY_IF_NOT_PRESENT ImagePullPolicy = 2
	// Never pull the image, use local copy only
	ImagePullPolicy_IMAGE_PULL_POLICY_NEVER ImagePullPolicy = 3
)

func (ImagePullPolicy) Descriptor

func (ImagePullPolicy) Enum

func (x ImagePullPolicy) Enum() *ImagePullPolicy

func (ImagePullPolicy) EnumDescriptor deprecated

func (ImagePullPolicy) EnumDescriptor() ([]byte, []int)

Deprecated: Use ImagePullPolicy.Descriptor instead.

func (ImagePullPolicy) Number

func (ImagePullPolicy) String

func (x ImagePullPolicy) String() string

func (ImagePullPolicy) Type

type ImagePullSecret

type ImagePullSecret struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

Credentials for pulling images from private OCI registries

⚠️ SECURITY NOTE: Credentials are transmitted as plain text in protobuf messages. Always use TLS/encryption for all network communication to protect these credentials.

func (*ImagePullSecret) Descriptor deprecated

func (*ImagePullSecret) Descriptor() ([]byte, []int)

Deprecated: Use ImagePullSecret.ProtoReflect.Descriptor instead.

func (*ImagePullSecret) GetPassword

func (x *ImagePullSecret) GetPassword() string

func (*ImagePullSecret) GetUsername

func (x *ImagePullSecret) GetUsername() string

func (*ImagePullSecret) ProtoMessage

func (*ImagePullSecret) ProtoMessage()

func (*ImagePullSecret) ProtoReflect

func (x *ImagePullSecret) ProtoReflect() protoreflect.Message

func (*ImagePullSecret) Reset

func (x *ImagePullSecret) Reset()

func (*ImagePullSecret) String

func (x *ImagePullSecret) String() string

type LocalResources

type LocalResources struct {

	// Memory in MiB
	MemoryLimitMb int32 `protobuf:"varint,1,opt,name=memory_limit_mb,json=memoryLimitMb,proto3" json:"memory_limit_mb,omitempty"`
	// CPU in (no idea)
	CpuLimit int32 `protobuf:"varint,2,opt,name=cpu_limit,json=cpuLimit,proto3" json:"cpu_limit,omitempty"`
	// A Generic key/value map for low level component configuration.
	Config map[string]string `` /* 139-byte string literal not displayed */
	// Environment variables for the component, mapped to wasi:cli/env.
	Environment map[string]string `` /* 149-byte string literal not displayed */
	// Volume mounts from the parent Workload
	VolumeMounts []*VolumeMount `protobuf:"bytes,5,rep,name=volume_mounts,json=volumeMounts,proto3" json:"volume_mounts,omitempty"`
	// Allowed Hosts for TCP Outbound connections. "localhost" is always allowed.
	// Can contain wildcards "*" as any part of the hostname.Ex: "*.wasmcloud.io" but not "som*thing.wasmcloud.io"
	// Note this controls socket connections but not DNS lookups.
	// Upon a successful lookup, the host will allow outbound connections to the specified hosts.
	AllowedHosts []string `protobuf:"bytes,6,rep,name=allowed_hosts,json=allowedHosts,proto3" json:"allowed_hosts,omitempty"`
	// contains filtered or unexported fields
}

func (*LocalResources) Descriptor deprecated

func (*LocalResources) Descriptor() ([]byte, []int)

Deprecated: Use LocalResources.ProtoReflect.Descriptor instead.

func (*LocalResources) GetAllowedHosts

func (x *LocalResources) GetAllowedHosts() []string

func (*LocalResources) GetConfig

func (x *LocalResources) GetConfig() map[string]string

func (*LocalResources) GetCpuLimit

func (x *LocalResources) GetCpuLimit() int32

func (*LocalResources) GetEnvironment

func (x *LocalResources) GetEnvironment() map[string]string

func (*LocalResources) GetMemoryLimitMb

func (x *LocalResources) GetMemoryLimitMb() int32

func (*LocalResources) GetVolumeMounts

func (x *LocalResources) GetVolumeMounts() []*VolumeMount

func (*LocalResources) ProtoMessage

func (*LocalResources) ProtoMessage()

func (*LocalResources) ProtoReflect

func (x *LocalResources) ProtoReflect() protoreflect.Message

func (*LocalResources) Reset

func (x *LocalResources) Reset()

func (*LocalResources) String

func (x *LocalResources) String() string

type Service

type Service struct {
	Image          string          `protobuf:"bytes,1,opt,name=image,proto3" json:"image,omitempty"`
	LocalResources *LocalResources `protobuf:"bytes,2,opt,name=local_resources,json=localResources,proto3" json:"local_resources,omitempty"`
	MaxRestarts    uint64          `protobuf:"varint,3,opt,name=max_restarts,json=maxRestarts,proto3" json:"max_restarts,omitempty"`
	// Optional credentials for pulling the image from a private registry
	ImagePullSecret *ImagePullSecret `protobuf:"bytes,4,opt,name=image_pull_secret,json=imagePullSecret,proto3" json:"image_pull_secret,omitempty"`
	ImagePullPolicy ImagePullPolicy  `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Service) Descriptor deprecated

func (*Service) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetImage

func (x *Service) GetImage() string

func (*Service) GetImagePullPolicy

func (x *Service) GetImagePullPolicy() ImagePullPolicy

func (*Service) GetImagePullSecret

func (x *Service) GetImagePullSecret() *ImagePullSecret

func (*Service) GetLocalResources

func (x *Service) GetLocalResources() *LocalResources

func (*Service) GetMaxRestarts

func (x *Service) GetMaxRestarts() uint64

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) ProtoReflect

func (x *Service) ProtoReflect() protoreflect.Message

func (*Service) Reset

func (x *Service) Reset()

func (*Service) String

func (x *Service) String() string

type Volume

type Volume struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to VolumeType:
	//
	//	*Volume_HostPath
	//	*Volume_EmptyDir
	VolumeType isVolume_VolumeType `protobuf_oneof:"volume_type"`
	// contains filtered or unexported fields
}

func (*Volume) Descriptor deprecated

func (*Volume) Descriptor() ([]byte, []int)

Deprecated: Use Volume.ProtoReflect.Descriptor instead.

func (*Volume) GetEmptyDir

func (x *Volume) GetEmptyDir() *EmptyDirVolume

func (*Volume) GetHostPath

func (x *Volume) GetHostPath() *HostPathVolume

func (*Volume) GetName

func (x *Volume) GetName() string

func (*Volume) GetVolumeType

func (x *Volume) GetVolumeType() isVolume_VolumeType

func (*Volume) ProtoMessage

func (*Volume) ProtoMessage()

func (*Volume) ProtoReflect

func (x *Volume) ProtoReflect() protoreflect.Message

func (*Volume) Reset

func (x *Volume) Reset()

func (*Volume) String

func (x *Volume) String() string

type VolumeMount

type VolumeMount struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	MountPath string `protobuf:"bytes,2,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
	ReadOnly  bool   `protobuf:"varint,3,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	// contains filtered or unexported fields
}

func (*VolumeMount) Descriptor deprecated

func (*VolumeMount) Descriptor() ([]byte, []int)

Deprecated: Use VolumeMount.ProtoReflect.Descriptor instead.

func (*VolumeMount) GetMountPath

func (x *VolumeMount) GetMountPath() string

func (*VolumeMount) GetName

func (x *VolumeMount) GetName() string

func (*VolumeMount) GetReadOnly

func (x *VolumeMount) GetReadOnly() bool

func (*VolumeMount) ProtoMessage

func (*VolumeMount) ProtoMessage()

func (*VolumeMount) ProtoReflect

func (x *VolumeMount) ProtoReflect() protoreflect.Message

func (*VolumeMount) Reset

func (x *VolumeMount) Reset()

func (*VolumeMount) String

func (x *VolumeMount) String() string

type Volume_EmptyDir

type Volume_EmptyDir struct {
	EmptyDir *EmptyDirVolume `protobuf:"bytes,3,opt,name=empty_dir,json=emptyDir,proto3,oneof"`
}

type Volume_HostPath

type Volume_HostPath struct {
	HostPath *HostPathVolume `protobuf:"bytes,2,opt,name=host_path,json=hostPath,proto3,oneof"`
}

type WitInterface

type WitInterface struct {
	Namespace  string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Package    string            `protobuf:"bytes,2,opt,name=package,proto3" json:"package,omitempty"`
	Version    string            `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Interfaces []string          `protobuf:"bytes,4,rep,name=interfaces,proto3" json:"interfaces,omitempty"`
	Config     map[string]string `` /* 139-byte string literal not displayed */
	// Optional instance name for multi-backend routing. When multiple entries
	// share the same namespace:package, each must have a unique name. Components
	// use this name as the identifier in resource-opening functions (e.g.,
	// store::open(name) for keyvalue, create-container(name) for blobstore).
	Name string `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*WitInterface) Descriptor deprecated

func (*WitInterface) Descriptor() ([]byte, []int)

Deprecated: Use WitInterface.ProtoReflect.Descriptor instead.

func (*WitInterface) GetConfig

func (x *WitInterface) GetConfig() map[string]string

func (*WitInterface) GetInterfaces

func (x *WitInterface) GetInterfaces() []string

func (*WitInterface) GetName

func (x *WitInterface) GetName() string

func (*WitInterface) GetNamespace

func (x *WitInterface) GetNamespace() string

func (*WitInterface) GetPackage

func (x *WitInterface) GetPackage() string

func (*WitInterface) GetVersion

func (x *WitInterface) GetVersion() string

func (*WitInterface) ProtoMessage

func (*WitInterface) ProtoMessage()

func (*WitInterface) ProtoReflect

func (x *WitInterface) ProtoReflect() protoreflect.Message

func (*WitInterface) Reset

func (x *WitInterface) Reset()

func (*WitInterface) String

func (x *WitInterface) String() string

type WitWorld

type WitWorld struct {
	Components []*Component `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"`
	// Host interfaces that are available to the components.
	// The 'config' on each host_interface may carry Workload Specific configuration.
	HostInterfaces []*WitInterface `protobuf:"bytes,2,rep,name=host_interfaces,json=hostInterfaces,proto3" json:"host_interfaces,omitempty"`
	// contains filtered or unexported fields
}

Represents the WIT World (WebAssembly Interface Types) World Resolution is the intersection of all Component 'root' interfaces with Host interfaces. It must overlap 100%.

func (*WitWorld) Descriptor deprecated

func (*WitWorld) Descriptor() ([]byte, []int)

Deprecated: Use WitWorld.ProtoReflect.Descriptor instead.

func (*WitWorld) GetComponents

func (x *WitWorld) GetComponents() []*Component

func (*WitWorld) GetHostInterfaces

func (x *WitWorld) GetHostInterfaces() []*WitInterface

func (*WitWorld) ProtoMessage

func (*WitWorld) ProtoMessage()

func (*WitWorld) ProtoReflect

func (x *WitWorld) ProtoReflect() protoreflect.Message

func (*WitWorld) Reset

func (x *WitWorld) Reset()

func (*WitWorld) String

func (x *WitWorld) String() string

type Workload

type Workload struct {
	Namespace   string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name        string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Annotations map[string]string `` /* 149-byte string literal not displayed */
	Service     *Service          `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	WitWorld    *WitWorld         `protobuf:"bytes,5,opt,name=wit_world,json=witWorld,proto3" json:"wit_world,omitempty"`
	Volumes     []*Volume         `protobuf:"bytes,6,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}

Workloads are Components that when combined form a complete unit of execution (a.k.a: WIT World fully resolved). Workloads also carry an extra Component ( Service ) that can interact with the fully resolved WIT World.

func (*Workload) Descriptor deprecated

func (*Workload) Descriptor() ([]byte, []int)

Deprecated: Use Workload.ProtoReflect.Descriptor instead.

func (*Workload) GetAnnotations

func (x *Workload) GetAnnotations() map[string]string

func (*Workload) GetName

func (x *Workload) GetName() string

func (*Workload) GetNamespace

func (x *Workload) GetNamespace() string

func (*Workload) GetService

func (x *Workload) GetService() *Service

func (*Workload) GetVolumes

func (x *Workload) GetVolumes() []*Volume

func (*Workload) GetWitWorld

func (x *Workload) GetWitWorld() *WitWorld

func (*Workload) ProtoMessage

func (*Workload) ProtoMessage()

func (*Workload) ProtoReflect

func (x *Workload) ProtoReflect() protoreflect.Message

func (*Workload) Reset

func (x *Workload) Reset()

func (*Workload) String

func (x *Workload) String() string

type WorkloadStartRequest

type WorkloadStartRequest struct {
	Workload   *Workload `protobuf:"bytes,1,opt,name=workload,proto3" json:"workload,omitempty"`
	WorkloadId string    `protobuf:"bytes,2,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStartRequest) Descriptor deprecated

func (*WorkloadStartRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadStartRequest.ProtoReflect.Descriptor instead.

func (*WorkloadStartRequest) GetWorkload

func (x *WorkloadStartRequest) GetWorkload() *Workload

func (*WorkloadStartRequest) GetWorkloadId

func (x *WorkloadStartRequest) GetWorkloadId() string

func (*WorkloadStartRequest) ProtoMessage

func (*WorkloadStartRequest) ProtoMessage()

func (*WorkloadStartRequest) ProtoReflect

func (x *WorkloadStartRequest) ProtoReflect() protoreflect.Message

func (*WorkloadStartRequest) Reset

func (x *WorkloadStartRequest) Reset()

func (*WorkloadStartRequest) String

func (x *WorkloadStartRequest) String() string

type WorkloadStartResponse

type WorkloadStartResponse struct {
	WorkloadStatus *WorkloadStatus `protobuf:"bytes,1,opt,name=workload_status,json=workloadStatus,proto3" json:"workload_status,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStartResponse) Descriptor deprecated

func (*WorkloadStartResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadStartResponse.ProtoReflect.Descriptor instead.

func (*WorkloadStartResponse) GetWorkloadStatus

func (x *WorkloadStartResponse) GetWorkloadStatus() *WorkloadStatus

func (*WorkloadStartResponse) ProtoMessage

func (*WorkloadStartResponse) ProtoMessage()

func (*WorkloadStartResponse) ProtoReflect

func (x *WorkloadStartResponse) ProtoReflect() protoreflect.Message

func (*WorkloadStartResponse) Reset

func (x *WorkloadStartResponse) Reset()

func (*WorkloadStartResponse) String

func (x *WorkloadStartResponse) String() string

type WorkloadState

type WorkloadState int32
const (
	// Sentinel value, should not be used
	WorkloadState_WORKLOAD_STATE_UNSPECIFIED WorkloadState = 0
	// Workload "start" received by the host and workload is starting.
	// The workload_id is now in the host's internal state.
	// The host might have not performed internal checks yet, resulting in
	// the workload not being started and going into the "error" state.
	WorkloadState_WORKLOAD_STATE_STARTING WorkloadState = 1
	// Workload passed checks and is considered running
	WorkloadState_WORKLOAD_STATE_RUNNING WorkloadState = 2
	// Workload completed execution
	// This indicates the workload executed to completion
	// Useful for wasi:cli/run workloads
	WorkloadState_WORKLOAD_STATE_COMPLETED WorkloadState = 3
	// Workload "stop" received and stopping
	// The host continues to report the workload status
	// until the workload is fully stopped.
	// Then the host removes the workload from its internal state.
	WorkloadState_WORKLOAD_STATE_STOPPING WorkloadState = 4
	// Workload failed to start or stopped due to an error
	WorkloadState_WORKLOAD_STATE_ERROR WorkloadState = 5
	// Workload not found
	WorkloadState_WORKLOAD_STATE_NOT_FOUND WorkloadState = 6
)

func (WorkloadState) Descriptor

func (WorkloadState) Enum

func (x WorkloadState) Enum() *WorkloadState

func (WorkloadState) EnumDescriptor deprecated

func (WorkloadState) EnumDescriptor() ([]byte, []int)

Deprecated: Use WorkloadState.Descriptor instead.

func (WorkloadState) Number

func (WorkloadState) String

func (x WorkloadState) String() string

func (WorkloadState) Type

type WorkloadStatus

type WorkloadStatus struct {
	WorkloadId    string        `protobuf:"bytes,1,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"`
	WorkloadState WorkloadState `` /* 141-byte string literal not displayed */
	Message       string        `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStatus) Descriptor deprecated

func (*WorkloadStatus) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadStatus.ProtoReflect.Descriptor instead.

func (*WorkloadStatus) GetMessage

func (x *WorkloadStatus) GetMessage() string

func (*WorkloadStatus) GetWorkloadId

func (x *WorkloadStatus) GetWorkloadId() string

func (*WorkloadStatus) GetWorkloadState

func (x *WorkloadStatus) GetWorkloadState() WorkloadState

func (*WorkloadStatus) ProtoMessage

func (*WorkloadStatus) ProtoMessage()

func (*WorkloadStatus) ProtoReflect

func (x *WorkloadStatus) ProtoReflect() protoreflect.Message

func (*WorkloadStatus) Reset

func (x *WorkloadStatus) Reset()

func (*WorkloadStatus) String

func (x *WorkloadStatus) String() string

type WorkloadStatusRequest

type WorkloadStatusRequest struct {
	WorkloadId string `protobuf:"bytes,1,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStatusRequest) Descriptor deprecated

func (*WorkloadStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadStatusRequest.ProtoReflect.Descriptor instead.

func (*WorkloadStatusRequest) GetWorkloadId

func (x *WorkloadStatusRequest) GetWorkloadId() string

func (*WorkloadStatusRequest) ProtoMessage

func (*WorkloadStatusRequest) ProtoMessage()

func (*WorkloadStatusRequest) ProtoReflect

func (x *WorkloadStatusRequest) ProtoReflect() protoreflect.Message

func (*WorkloadStatusRequest) Reset

func (x *WorkloadStatusRequest) Reset()

func (*WorkloadStatusRequest) String

func (x *WorkloadStatusRequest) String() string

type WorkloadStatusResponse

type WorkloadStatusResponse struct {
	WorkloadStatus *WorkloadStatus `protobuf:"bytes,1,opt,name=workload_status,json=workloadStatus,proto3" json:"workload_status,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStatusResponse) Descriptor deprecated

func (*WorkloadStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadStatusResponse.ProtoReflect.Descriptor instead.

func (*WorkloadStatusResponse) GetWorkloadStatus

func (x *WorkloadStatusResponse) GetWorkloadStatus() *WorkloadStatus

func (*WorkloadStatusResponse) ProtoMessage

func (*WorkloadStatusResponse) ProtoMessage()

func (*WorkloadStatusResponse) ProtoReflect

func (x *WorkloadStatusResponse) ProtoReflect() protoreflect.Message

func (*WorkloadStatusResponse) Reset

func (x *WorkloadStatusResponse) Reset()

func (*WorkloadStatusResponse) String

func (x *WorkloadStatusResponse) String() string

type WorkloadStopRequest

type WorkloadStopRequest struct {
	WorkloadId string `protobuf:"bytes,1,opt,name=workload_id,json=workloadId,proto3" json:"workload_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStopRequest) Descriptor deprecated

func (*WorkloadStopRequest) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadStopRequest.ProtoReflect.Descriptor instead.

func (*WorkloadStopRequest) GetWorkloadId

func (x *WorkloadStopRequest) GetWorkloadId() string

func (*WorkloadStopRequest) ProtoMessage

func (*WorkloadStopRequest) ProtoMessage()

func (*WorkloadStopRequest) ProtoReflect

func (x *WorkloadStopRequest) ProtoReflect() protoreflect.Message

func (*WorkloadStopRequest) Reset

func (x *WorkloadStopRequest) Reset()

func (*WorkloadStopRequest) String

func (x *WorkloadStopRequest) String() string

type WorkloadStopResponse

type WorkloadStopResponse struct {
	WorkloadStatus *WorkloadStatus `protobuf:"bytes,1,opt,name=workload_status,json=workloadStatus,proto3" json:"workload_status,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkloadStopResponse) Descriptor deprecated

func (*WorkloadStopResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkloadStopResponse.ProtoReflect.Descriptor instead.

func (*WorkloadStopResponse) GetWorkloadStatus

func (x *WorkloadStopResponse) GetWorkloadStatus() *WorkloadStatus

func (*WorkloadStopResponse) ProtoMessage

func (*WorkloadStopResponse) ProtoMessage()

func (*WorkloadStopResponse) ProtoReflect

func (x *WorkloadStopResponse) ProtoReflect() protoreflect.Message

func (*WorkloadStopResponse) Reset

func (x *WorkloadStopResponse) Reset()

func (*WorkloadStopResponse) String

func (x *WorkloadStopResponse) String() string

Source Files

  • host_heartbeat.pb.go
  • host_service.pb.go
  • wit_interface.pb.go
  • workload.pb.go
  • workload_service.pb.go

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL