Documentation
¶
Index ¶
- Variables
- type Component
- func (*Component) Descriptor() ([]byte, []int)deprecated
- func (x *Component) GetImage() string
- func (x *Component) GetImagePullPolicy() ImagePullPolicy
- func (x *Component) GetImagePullSecret() *ImagePullSecret
- func (x *Component) GetLocalResources() *LocalResources
- func (x *Component) GetMaxInvocations() int32
- func (x *Component) GetName() string
- func (x *Component) GetPoolSize() int32
- func (*Component) ProtoMessage()
- func (x *Component) ProtoReflect() protoreflect.Message
- func (x *Component) Reset()
- func (x *Component) String() string
- type EmptyDirVolume
- type HostHeartbeat
- func (*HostHeartbeat) Descriptor() ([]byte, []int)deprecated
- func (x *HostHeartbeat) GetComponentCount() uint64
- func (x *HostHeartbeat) GetExports() []*WitInterface
- func (x *HostHeartbeat) GetFriendlyName() string
- func (x *HostHeartbeat) GetHostname() string
- func (x *HostHeartbeat) GetHttpPort() uint32
- func (x *HostHeartbeat) GetId() string
- func (x *HostHeartbeat) GetImports() []*WitInterface
- func (x *HostHeartbeat) GetLabels() map[string]string
- func (x *HostHeartbeat) GetOsArch() string
- func (x *HostHeartbeat) GetOsKernel() string
- func (x *HostHeartbeat) GetOsName() string
- func (x *HostHeartbeat) GetStartedAt() *timestamppb.Timestamp
- func (x *HostHeartbeat) GetSystemCpuUsage() float32
- func (x *HostHeartbeat) GetSystemMemoryFree() uint64
- func (x *HostHeartbeat) GetSystemMemoryTotal() uint64
- func (x *HostHeartbeat) GetVersion() string
- func (x *HostHeartbeat) GetWorkloadCount() uint64
- func (*HostHeartbeat) ProtoMessage()
- func (x *HostHeartbeat) ProtoReflect() protoreflect.Message
- func (x *HostHeartbeat) Reset()
- func (x *HostHeartbeat) String() string
- type HostHeartbeatRequest
- func (*HostHeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HostHeartbeatRequest) GetHeartbeat() *HostHeartbeat
- func (*HostHeartbeatRequest) ProtoMessage()
- func (x *HostHeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *HostHeartbeatRequest) Reset()
- func (x *HostHeartbeatRequest) String() string
- type HostPathVolume
- type ImagePullPolicy
- func (ImagePullPolicy) Descriptor() protoreflect.EnumDescriptor
- func (x ImagePullPolicy) Enum() *ImagePullPolicy
- func (ImagePullPolicy) EnumDescriptor() ([]byte, []int)deprecated
- func (x ImagePullPolicy) Number() protoreflect.EnumNumber
- func (x ImagePullPolicy) String() string
- func (ImagePullPolicy) Type() protoreflect.EnumType
- type ImagePullSecret
- func (*ImagePullSecret) Descriptor() ([]byte, []int)deprecated
- func (x *ImagePullSecret) GetPassword() string
- func (x *ImagePullSecret) GetUsername() string
- func (*ImagePullSecret) ProtoMessage()
- func (x *ImagePullSecret) ProtoReflect() protoreflect.Message
- func (x *ImagePullSecret) Reset()
- func (x *ImagePullSecret) String() string
- type LocalResources
- func (*LocalResources) Descriptor() ([]byte, []int)deprecated
- func (x *LocalResources) GetAllowedHosts() []string
- func (x *LocalResources) GetConfig() map[string]string
- func (x *LocalResources) GetCpuLimit() int32
- func (x *LocalResources) GetEnvironment() map[string]string
- func (x *LocalResources) GetMemoryLimitMb() int32
- func (x *LocalResources) GetVolumeMounts() []*VolumeMount
- func (*LocalResources) ProtoMessage()
- func (x *LocalResources) ProtoReflect() protoreflect.Message
- func (x *LocalResources) Reset()
- func (x *LocalResources) String() string
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetImage() string
- func (x *Service) GetImagePullPolicy() ImagePullPolicy
- func (x *Service) GetImagePullSecret() *ImagePullSecret
- func (x *Service) GetLocalResources() *LocalResources
- func (x *Service) GetMaxRestarts() uint64
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type Volume
- func (*Volume) Descriptor() ([]byte, []int)deprecated
- func (x *Volume) GetEmptyDir() *EmptyDirVolume
- func (x *Volume) GetHostPath() *HostPathVolume
- func (x *Volume) GetName() string
- func (x *Volume) GetVolumeType() isVolume_VolumeType
- func (*Volume) ProtoMessage()
- func (x *Volume) ProtoReflect() protoreflect.Message
- func (x *Volume) Reset()
- func (x *Volume) String() string
- type VolumeMount
- func (*VolumeMount) Descriptor() ([]byte, []int)deprecated
- func (x *VolumeMount) GetMountPath() string
- func (x *VolumeMount) GetName() string
- func (x *VolumeMount) GetReadOnly() bool
- func (*VolumeMount) ProtoMessage()
- func (x *VolumeMount) ProtoReflect() protoreflect.Message
- func (x *VolumeMount) Reset()
- func (x *VolumeMount) String() string
- type Volume_EmptyDir
- type Volume_HostPath
- type WitInterface
- func (*WitInterface) Descriptor() ([]byte, []int)deprecated
- func (x *WitInterface) GetConfig() map[string]string
- func (x *WitInterface) GetInterfaces() []string
- func (x *WitInterface) GetName() string
- func (x *WitInterface) GetNamespace() string
- func (x *WitInterface) GetPackage() string
- func (x *WitInterface) GetVersion() string
- func (*WitInterface) ProtoMessage()
- func (x *WitInterface) ProtoReflect() protoreflect.Message
- func (x *WitInterface) Reset()
- func (x *WitInterface) String() string
- type WitWorld
- func (*WitWorld) Descriptor() ([]byte, []int)deprecated
- func (x *WitWorld) GetComponents() []*Component
- func (x *WitWorld) GetHostInterfaces() []*WitInterface
- func (*WitWorld) ProtoMessage()
- func (x *WitWorld) ProtoReflect() protoreflect.Message
- func (x *WitWorld) Reset()
- func (x *WitWorld) String() string
- type Workload
- func (*Workload) Descriptor() ([]byte, []int)deprecated
- func (x *Workload) GetAnnotations() map[string]string
- func (x *Workload) GetName() string
- func (x *Workload) GetNamespace() string
- func (x *Workload) GetService() *Service
- func (x *Workload) GetVolumes() []*Volume
- func (x *Workload) GetWitWorld() *WitWorld
- func (*Workload) ProtoMessage()
- func (x *Workload) ProtoReflect() protoreflect.Message
- func (x *Workload) Reset()
- func (x *Workload) String() string
- type WorkloadStartRequest
- func (*WorkloadStartRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadStartRequest) GetWorkload() *Workload
- func (x *WorkloadStartRequest) GetWorkloadId() string
- func (*WorkloadStartRequest) ProtoMessage()
- func (x *WorkloadStartRequest) ProtoReflect() protoreflect.Message
- func (x *WorkloadStartRequest) Reset()
- func (x *WorkloadStartRequest) String() string
- type WorkloadStartResponse
- func (*WorkloadStartResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadStartResponse) GetWorkloadStatus() *WorkloadStatus
- func (*WorkloadStartResponse) ProtoMessage()
- func (x *WorkloadStartResponse) ProtoReflect() protoreflect.Message
- func (x *WorkloadStartResponse) Reset()
- func (x *WorkloadStartResponse) String() string
- type WorkloadState
- func (WorkloadState) Descriptor() protoreflect.EnumDescriptor
- func (x WorkloadState) Enum() *WorkloadState
- func (WorkloadState) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkloadState) Number() protoreflect.EnumNumber
- func (x WorkloadState) String() string
- func (WorkloadState) Type() protoreflect.EnumType
- type WorkloadStatus
- func (*WorkloadStatus) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadStatus) GetMessage() string
- func (x *WorkloadStatus) GetWorkloadId() string
- func (x *WorkloadStatus) GetWorkloadState() WorkloadState
- func (*WorkloadStatus) ProtoMessage()
- func (x *WorkloadStatus) ProtoReflect() protoreflect.Message
- func (x *WorkloadStatus) Reset()
- func (x *WorkloadStatus) String() string
- type WorkloadStatusRequest
- func (*WorkloadStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadStatusRequest) GetWorkloadId() string
- func (*WorkloadStatusRequest) ProtoMessage()
- func (x *WorkloadStatusRequest) ProtoReflect() protoreflect.Message
- func (x *WorkloadStatusRequest) Reset()
- func (x *WorkloadStatusRequest) String() string
- type WorkloadStatusResponse
- func (*WorkloadStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadStatusResponse) GetWorkloadStatus() *WorkloadStatus
- func (*WorkloadStatusResponse) ProtoMessage()
- func (x *WorkloadStatusResponse) ProtoReflect() protoreflect.Message
- func (x *WorkloadStatusResponse) Reset()
- func (x *WorkloadStatusResponse) String() string
- type WorkloadStopRequest
- func (*WorkloadStopRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadStopRequest) GetWorkloadId() string
- func (*WorkloadStopRequest) ProtoMessage()
- func (x *WorkloadStopRequest) ProtoReflect() protoreflect.Message
- func (x *WorkloadStopRequest) Reset()
- func (x *WorkloadStopRequest) String() string
- type WorkloadStopResponse
- func (*WorkloadStopResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkloadStopResponse) GetWorkloadStatus() *WorkloadStatus
- func (*WorkloadStopResponse) ProtoMessage()
- func (x *WorkloadStopResponse) ProtoReflect() protoreflect.Message
- func (x *WorkloadStopResponse) Reset()
- func (x *WorkloadStopResponse) String() string
Constants ¶
This section is empty.
Variables ¶
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.
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.
var File_wasmcloud_runtime_v2_host_heartbeat_proto protoreflect.FileDescriptor
var File_wasmcloud_runtime_v2_host_service_proto protoreflect.FileDescriptor
var File_wasmcloud_runtime_v2_wit_interface_proto protoreflect.FileDescriptor
var File_wasmcloud_runtime_v2_workload_proto protoreflect.FileDescriptor
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) GetImagePullPolicy ¶
func (x *Component) GetImagePullPolicy() ImagePullPolicy
func (*Component) GetImagePullSecret ¶
func (x *Component) GetImagePullSecret() *ImagePullSecret
func (*Component) GetLocalResources ¶
func (x *Component) GetLocalResources() *LocalResources
func (*Component) ProtoReflect ¶
func (x *Component) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
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 (x ImagePullPolicy) Number() protoreflect.EnumNumber
func (ImagePullPolicy) String ¶
func (x ImagePullPolicy) String() string
func (ImagePullPolicy) Type ¶
func (ImagePullPolicy) Type() protoreflect.EnumType
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) GetImagePullPolicy ¶
func (x *Service) GetImagePullPolicy() ImagePullPolicy
func (*Service) GetImagePullSecret ¶
func (x *Service) GetImagePullSecret() *ImagePullSecret
func (*Service) GetLocalResources ¶
func (x *Service) GetLocalResources() *LocalResources
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
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) GetEmptyDir ¶
func (x *Volume) GetEmptyDir() *EmptyDirVolume
func (*Volume) GetHostPath ¶
func (x *Volume) GetHostPath() *HostPathVolume
func (*Volume) ProtoReflect ¶
func (x *Volume) ProtoReflect() protoreflect.Message
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) GetHostInterfaces ¶
func (x *WitWorld) GetHostInterfaces() []*WitInterface
func (*WitWorld) ProtoReflect ¶
func (x *WitWorld) ProtoReflect() protoreflect.Message
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) ProtoReflect ¶
func (x *Workload) ProtoReflect() protoreflect.Message
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) Descriptor() protoreflect.EnumDescriptor
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 (x WorkloadState) Number() protoreflect.EnumNumber
func (WorkloadState) String ¶
func (x WorkloadState) String() string
func (WorkloadState) Type ¶
func (WorkloadState) Type() protoreflect.EnumType
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