ateletpb

type ActorMetadataDataSource struct {
	Items []*ActorMetadataItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type ActorMetadataField int32

type ActorMetadataItem struct {
	Field ActorMetadataField `protobuf:"varint,1,opt,name=field,proto3,enum=atelet.ActorMetadataField" json:"field,omitempty"`
	Path  string             `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

type ArchAssets struct {
	Files map[string]*AssetFile `` // asset name -> file
	/* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

type AssetFile struct {

	// gs:// URL to download the asset from.
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// Lower-case hex SHA256; names the cached file and verifies its integrity.
	Sha256 string `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// contains filtered or unexported fields
}

type AteomHerderClient interface {
	// Run tells atelet to create a new containerized workload from scratch on an
	// ateom.
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
	// Checkpoint tells atelet to save the current state of the workload on an
	// ateom to object storage, and then completely the ateom to a blank state
	// (back to "available" state.)
	Checkpoint(ctx context.Context, in *CheckpointRequest, opts ...grpc.CallOption) (*CheckpointResponse, error)
	// Restore restores a workload from checkpoint onto an ateom.
	Restore(ctx context.Context, in *RestoreRequest, opts ...grpc.CallOption) (*RestoreResponse, error)
	// UploadPausedCheckpoint copies a local (pause) checkpoint from this node's
	// disk to object storage. Unlike Checkpoint it drives no ateom: the actor is
	// paused, its sandbox is gone; the checkpoint files plus their manifest
	// already sit under the actor's local-checkpoints directory.
	UploadPausedCheckpoint(ctx context.Context, in *UploadPausedCheckpointRequest, opts ...grpc.CallOption) (*UploadPausedCheckpointResponse, error)
	// Terminate tells atelet to terminate/kill any running workload for an actor,
	// unmount its volumes, and clean up actor state on the node.
	Terminate(ctx context.Context, in *TerminateRequest, opts ...grpc.CallOption) (*TerminateResponse, error)
}

type AteomHerderServer interface {
	// Run tells atelet to create a new containerized workload from scratch on an
	// ateom.
	Run(context.Context, *RunRequest) (*RunResponse, error)
	// Checkpoint tells atelet to save the current state of the workload on an
	// ateom to object storage, and then completely the ateom to a blank state
	// (back to "available" state.)
	Checkpoint(context.Context, *CheckpointRequest) (*CheckpointResponse, error)
	// Restore restores a workload from checkpoint onto an ateom.
	Restore(context.Context, *RestoreRequest) (*RestoreResponse, error)
	// UploadPausedCheckpoint copies a local (pause) checkpoint from this node's
	// disk to object storage. Unlike Checkpoint it drives no ateom: the actor is
	// paused, its sandbox is gone; the checkpoint files plus their manifest
	// already sit under the actor's local-checkpoints directory.
	UploadPausedCheckpoint(context.Context, *UploadPausedCheckpointRequest) (*UploadPausedCheckpointResponse, error)
	// Terminate tells atelet to terminate/kill any running workload for an actor,
	// unmount its volumes, and clean up actor state on the node.
	Terminate(context.Context, *TerminateRequest) (*TerminateResponse, error)
	// contains filtered or unexported methods
}

type Capabilities struct {
	Add  []string `protobuf:"bytes,1,rep,name=add,proto3" json:"add,omitempty"`
	Drop []string `protobuf:"bytes,2,rep,name=drop,proto3" json:"drop,omitempty"`
	// contains filtered or unexported fields
}

type CheckpointRequest struct {
	TargetAteomUid        string `protobuf:"bytes,1,opt,name=target_ateom_uid,json=targetAteomUid,proto3" json:"target_ateom_uid,omitempty"`
	Atespace              string `protobuf:"bytes,2,opt,name=atespace,proto3" json:"atespace,omitempty"`
	ActorName             string `protobuf:"bytes,3,opt,name=actor_name,json=actorName,proto3" json:"actor_name,omitempty"`
	ActorUid              string `protobuf:"bytes,4,opt,name=actor_uid,json=actorUid,proto3" json:"actor_uid,omitempty"`
	ActorTemplateAtespace string `` /* 126-byte string literal not displayed */
	ActorTemplateName     string `protobuf:"bytes,6,opt,name=actor_template_name,json=actorTemplateName,proto3" json:"actor_template_name,omitempty"`
	// Sandbox binary config is not sent on checkpoint: atelet uses the version the
	// actor is currently running (recorded with the actor's on-node state at
	// Run/Restore) and records it into the snapshot manifest.
	Spec *WorkloadSpec  `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	Type CheckpointType `protobuf:"varint,8,opt,name=type,proto3,enum=atelet.CheckpointType" json:"type,omitempty"`
	// The checkpoint configuration, depending on the type.
	//
	// Types that are valid to be assigned to Config:
	//
	//	*CheckpointRequest_LocalConfig
	//	*CheckpointRequest_ExternalConfig
	Config isCheckpointRequest_Config `protobuf_oneof:"config"`
	// What should be included in the checkpoint.
	Scope SnapshotScope `protobuf:"varint,11,opt,name=scope,proto3,enum=atelet.SnapshotScope" json:"scope,omitempty"`
	// contains filtered or unexported fields
}

type CheckpointRequest_ExternalConfig struct {
	ExternalConfig *ExternalCheckpointConfiguration `protobuf:"bytes,10,opt,name=external_config,json=externalConfig,proto3,oneof"`
}

type CheckpointRequest_LocalConfig struct {
	LocalConfig *LocalCheckpointConfiguration `protobuf:"bytes,9,opt,name=local_config,json=localConfig,proto3,oneof"`
}

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

type CheckpointType int32

type Container struct {
	Name            string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image           string           `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Command         []string         `protobuf:"bytes,3,rep,name=command,proto3" json:"command,omitempty"`
	Args            []string         `protobuf:"bytes,7,rep,name=args,proto3" json:"args,omitempty"`
	Env             []*EnvEntry      `protobuf:"bytes,4,rep,name=env,proto3" json:"env,omitempty"`
	Readyz          *Readyz          `protobuf:"bytes,5,opt,name=readyz,proto3" json:"readyz,omitempty"`
	VolumeMounts    []*VolumeMount   `protobuf:"bytes,6,rep,name=volume_mounts,json=volumeMounts,proto3" json:"volume_mounts,omitempty"`
	SecurityContext *SecurityContext `protobuf:"bytes,8,opt,name=security_context,json=securityContext,proto3" json:"security_context,omitempty"`
	// resources are the cgroup limits for this container, resolved by
	// ate-api-server from the ActorTemplate. Unset means no limits.
	Resources *ResourceLimits `protobuf:"bytes,9,opt,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

type CredentialBrokerClient interface {
	MintActorCertificate(ctx context.Context, in *MintActorCertificateRequest, opts ...grpc.CallOption) (*MintActorCertificateResponse, error)
}

type CredentialBrokerServer interface {
	MintActorCertificate(context.Context, *MintActorCertificateRequest) (*MintActorCertificateResponse, error)
	// contains filtered or unexported methods
}

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

type EgressGateway struct {

	// address is required and identifies the remote gateway as an IP address or
	// DNS name followed by its port.
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

type EnvEntry struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ExternalCheckpointConfiguration struct {

	// The object storage URI of the snapshot to write. Object names are appended
	// to it, so it addresses the snapshot as a whole rather than any one object.
	SnapshotUri string `protobuf:"bytes,1,opt,name=snapshot_uri,json=snapshotUri,proto3" json:"snapshot_uri,omitempty"`
	// contains filtered or unexported fields
}

type ExternalVolumeSource struct {
	StorageVolumeId string            `protobuf:"bytes,1,opt,name=storage_volume_id,json=storageVolumeId,proto3" json:"storage_volume_id,omitempty"`
	VolumeType      string            `protobuf:"bytes,2,opt,name=volume_type,json=volumeType,proto3" json:"volume_type,omitempty"`
	VolumeContext   map[string]string `` /* 174-byte string literal not displayed */
	// contains filtered or unexported fields
}

type HTTPGetAction struct {

	// Path to access on the HTTP server. Empty means "/readyz".
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// TCP port to connect to (1..65535).
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

type ImageVolumeSource struct {
	Reference string `protobuf:"bytes,1,opt,name=reference,proto3" json:"reference,omitempty"`
	// contains filtered or unexported fields
}

type LocalCheckpointConfiguration struct {

	// Names a sub-directory on the local filesystem below which the checkpoint
	// data will be stored. atelet decides where that directory lives, from the
	// actor's UID, so this is a bare name and must not contain a path separator.
	// The structure of the checkpoint should generally be treated as opaque.
	SnapshotName string `protobuf:"bytes,1,opt,name=snapshot_name,json=snapshotName,proto3" json:"snapshot_name,omitempty"`
	// contains filtered or unexported fields
}

type MintActorCertificateRequest struct {

	// DER-encoded PKCS #10 certificate signing request. Atunnel retains the
	// corresponding private key.
	CertificateSigningRequest []byte `` /* 138-byte string literal not displayed */
	// Actor incarnation this activation expects. Ateapi resolves the actor from
	// the authenticated worker and rejects the request if its UID differs.
	ExpectedActorUid string `protobuf:"bytes,2,opt,name=expected_actor_uid,json=expectedActorUid,proto3" json:"expected_actor_uid,omitempty"`
	// contains filtered or unexported fields
}

type MintActorCertificateResponse struct {

	// DER-encoded leaf followed by any intermediate certificates.
	ActorCertificates [][]byte `protobuf:"bytes,1,rep,name=actor_certificates,json=actorCertificates,proto3" json:"actor_certificates,omitempty"`
	// contains filtered or unexported fields
}

type Readyz struct {
	HttpGet *HTTPGetAction `protobuf:"bytes,1,opt,name=http_get,json=httpGet,proto3" json:"http_get,omitempty"`
	// How long to keep polling before giving up and failing the actor start.
	// Zero means the ateom's default.
	TimeoutSeconds int32 `protobuf:"varint,2,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
	// contains filtered or unexported fields
}

type ResourceLimits struct {

	// memory_bytes is the memory limit in bytes. 0 means unset.
	MemoryBytes int64 `protobuf:"varint,1,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"`
	// cpu_millis is the CPU limit in milli-cores (1000 = one core). 0 means unset.
	CpuMillis int64 `protobuf:"varint,2,opt,name=cpu_millis,json=cpuMillis,proto3" json:"cpu_millis,omitempty"`
	// contains filtered or unexported fields
}

type RestoreRequest struct {
	TargetAteomUid        string `protobuf:"bytes,1,opt,name=target_ateom_uid,json=targetAteomUid,proto3" json:"target_ateom_uid,omitempty"`
	Atespace              string `protobuf:"bytes,2,opt,name=atespace,proto3" json:"atespace,omitempty"`
	ActorName             string `protobuf:"bytes,3,opt,name=actor_name,json=actorName,proto3" json:"actor_name,omitempty"`
	ActorUid              string `protobuf:"bytes,4,opt,name=actor_uid,json=actorUid,proto3" json:"actor_uid,omitempty"`
	ActorTemplateAtespace string `` /* 126-byte string literal not displayed */
	ActorTemplateName     string `protobuf:"bytes,6,opt,name=actor_template_name,json=actorTemplateName,proto3" json:"actor_template_name,omitempty"`
	// Sandbox binary config is not sent on restore: the snapshot is
	// self-describing. atelet reads the snapshot manifest to recover the pinned
	// sandbox version that created it.
	Spec *WorkloadSpec  `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	Type CheckpointType `protobuf:"varint,8,opt,name=type,proto3,enum=atelet.CheckpointType" json:"type,omitempty"`
	// The checkpoint configuration, depending on the type.
	//
	// Types that are valid to be assigned to Config:
	//
	//	*RestoreRequest_LocalConfig
	//	*RestoreRequest_ExternalConfig
	Config isRestoreRequest_Config `protobuf_oneof:"config"`
	// What content to restore from the checkpoint.
	Scope SnapshotScope `protobuf:"varint,11,opt,name=scope,proto3,enum=atelet.SnapshotScope" json:"scope,omitempty"`
	// The object storage URI of the ActorTemplate's golden snapshot.
	// Set only when scope is SNAPSHOT_SCOPE_DATA_ON_GOLDEN: restore combines
	// the golden snapshot (memory + full fs delta) with the durable data in
	// the snapshot referenced by `config`. A top-level field rather than part
	// of the `config` oneof: the actor's snapshot may be local (a pause
	// checkpoint) while the golden snapshot is always external.
	GoldenSnapshotUri string `protobuf:"bytes,12,opt,name=golden_snapshot_uri,json=goldenSnapshotUri,proto3" json:"golden_snapshot_uri,omitempty"`
	// When absent, actor traffic uses direct egress instead of atunnel.
	EgressGateway *EgressGateway `protobuf:"bytes,13,opt,name=egress_gateway,json=egressGateway,proto3,oneof" json:"egress_gateway,omitempty"`
	// The actor's declared size, from the ActorTemplate's resource limits. For
	// gVisor and micro-VM DATA-scope restores the sandbox is (re)sized to these;
	// for a FULL micro-VM restore the size baked into the snapshot wins. Zero
	// means "unset": keep the runtime default.
	CpuMilli    int64 `protobuf:"varint,14,opt,name=cpu_milli,json=cpuMilli,proto3" json:"cpu_milli,omitempty"`          // CPU limit in millicores (1000 = one core).
	MemoryBytes int64 `protobuf:"varint,15,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"` // Memory limit in bytes.
	// contains filtered or unexported fields
}

type RestoreRequest_ExternalConfig struct {
	ExternalConfig *ExternalCheckpointConfiguration `protobuf:"bytes,10,opt,name=external_config,json=externalConfig,proto3,oneof"`
}

type RestoreRequest_LocalConfig struct {
	LocalConfig *LocalCheckpointConfiguration `protobuf:"bytes,9,opt,name=local_config,json=localConfig,proto3,oneof"`
}

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

type RunRequest struct {
	TargetAteomUid        string        `protobuf:"bytes,1,opt,name=target_ateom_uid,json=targetAteomUid,proto3" json:"target_ateom_uid,omitempty"`
	Atespace              string        `protobuf:"bytes,2,opt,name=atespace,proto3" json:"atespace,omitempty"`
	ActorName             string        `protobuf:"bytes,3,opt,name=actor_name,json=actorName,proto3" json:"actor_name,omitempty"`
	ActorUid              string        `protobuf:"bytes,4,opt,name=actor_uid,json=actorUid,proto3" json:"actor_uid,omitempty"`
	ActorTemplateAtespace string        `` /* 126-byte string literal not displayed */
	ActorTemplateName     string        `protobuf:"bytes,6,opt,name=actor_template_name,json=actorTemplateName,proto3" json:"actor_template_name,omitempty"`
	Spec                  *WorkloadSpec `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	// The sandbox binaries to use for booting this actor from scratch. atelet
	// fetches the relevant assets and records them with the actor's on-node state
	// so a later Checkpoint can pin the same version into the snapshot manifest.
	SandboxAssets *SandboxAssets `protobuf:"bytes,8,opt,name=sandbox_assets,json=sandboxAssets,proto3" json:"sandbox_assets,omitempty"`
	// When absent, actor traffic uses direct egress instead of atunnel.
	EgressGateway *EgressGateway `protobuf:"bytes,9,opt,name=egress_gateway,json=egressGateway,proto3,oneof" json:"egress_gateway,omitempty"`
	// The actor's declared size, from the ActorTemplate's resource limits. atelet
	// passes these through to the sandbox so it is sized to the actor (not the
	// whole host or worker pod). Zero means "unset": keep the runtime default.
	CpuMilli    int64 `protobuf:"varint,10,opt,name=cpu_milli,json=cpuMilli,proto3" json:"cpu_milli,omitempty"`          // CPU limit in millicores (1000 = one core).
	MemoryBytes int64 `protobuf:"varint,11,opt,name=memory_bytes,json=memoryBytes,proto3" json:"memory_bytes,omitempty"` // Memory limit in bytes.
	// contains filtered or unexported fields
}

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

type SandboxAssets struct {
	SandboxClass string                 `protobuf:"bytes,1,opt,name=sandbox_class,json=sandboxClass,proto3" json:"sandbox_class,omitempty"` // e.g. "gvisor"
	Assets       map[string]*ArchAssets ``                                                                                                  // arch -> {name -> file}
	/* 139-byte string literal not displayed */
	// pause_image is the image for the sandbox's root container. Like the
	// binaries above it is sandbox configuration, not workload configuration,
	// and atelet pins it into the snapshot manifest so a restore rebuilds the
	// sandbox from the same image.
	PauseImage string `protobuf:"bytes,3,opt,name=pause_image,json=pauseImage,proto3" json:"pause_image,omitempty"`
	// contains filtered or unexported fields
}

type SecurityContext struct {
	Capabilities *Capabilities `protobuf:"bytes,1,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

type SetWorkerCapacityRequest struct {

	// What the worker can supply, in the same vocabulary the control plane
	// records and an ActorTemplate asks in.
	Capacity *ateapipb.WorkerResources `protobuf:"bytes,1,opt,name=capacity,proto3" json:"capacity,omitempty"`
	// contains filtered or unexported fields
}

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

type SnapshotScope int32

type SystemInfoDataSource struct {

	// Types that are valid to be assigned to DataSource:
	//
	//	*SystemInfoDataSource_ActorMetadata
	//	*SystemInfoDataSource_TrustBundle
	DataSource isSystemInfoDataSource_DataSource `protobuf_oneof:"data_source"`
	// contains filtered or unexported fields
}

type SystemInfoDataSource_ActorMetadata struct {
	ActorMetadata *ActorMetadataDataSource `protobuf:"bytes,1,opt,name=actor_metadata,json=actorMetadata,proto3,oneof"`
}

type SystemInfoDataSource_TrustBundle struct {
	TrustBundle *TrustBundleDataSource `protobuf:"bytes,2,opt,name=trust_bundle,json=trustBundle,proto3,oneof"`
}

type SystemInfoVolume struct {
	DataSources []*SystemInfoDataSource `protobuf:"bytes,1,rep,name=data_sources,json=dataSources,proto3" json:"data_sources,omitempty"`
	// contains filtered or unexported fields
}

type TerminateRequest struct {
	TargetAteomUid        string        `protobuf:"bytes,1,opt,name=target_ateom_uid,json=targetAteomUid,proto3" json:"target_ateom_uid,omitempty"`
	Atespace              string        `protobuf:"bytes,2,opt,name=atespace,proto3" json:"atespace,omitempty"`
	ActorName             string        `protobuf:"bytes,3,opt,name=actor_name,json=actorName,proto3" json:"actor_name,omitempty"`
	ActorUid              string        `protobuf:"bytes,4,opt,name=actor_uid,json=actorUid,proto3" json:"actor_uid,omitempty"`
	ActorTemplateAtespace string        `` /* 126-byte string literal not displayed */
	ActorTemplateName     string        `protobuf:"bytes,6,opt,name=actor_template_name,json=actorTemplateName,proto3" json:"actor_template_name,omitempty"`
	Spec                  *WorkloadSpec `protobuf:"bytes,7,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

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

type TrustBundleDataSource struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedAteomHerderServer struct{}

type UnimplementedCredentialBrokerServer struct{}

type UnimplementedWorkerCapacityServer struct{}

type UnsafeAteomHerderServer interface {
	// contains filtered or unexported methods
}

type UnsafeCredentialBrokerServer interface {
	// contains filtered or unexported methods
}

type UnsafeWorkerCapacityServer interface {
	// contains filtered or unexported methods
}

type UploadPausedCheckpointRequest struct {
	Atespace  string `protobuf:"bytes,1,opt,name=atespace,proto3" json:"atespace,omitempty"`
	ActorName string `protobuf:"bytes,2,opt,name=actor_name,json=actorName,proto3" json:"actor_name,omitempty"`
	ActorUid  string `protobuf:"bytes,3,opt,name=actor_uid,json=actorUid,proto3" json:"actor_uid,omitempty"`
	// For metrics attribution, like on CheckpointRequest.
	ActorTemplateAtespace string `` /* 126-byte string literal not displayed */
	ActorTemplateName     string `protobuf:"bytes,5,opt,name=actor_template_name,json=actorTemplateName,proto3" json:"actor_template_name,omitempty"`
	// The local checkpoint to upload: LocalSnapshotInfo.snapshot_name recorded
	// at pause time.
	LocalSnapshotName string `protobuf:"bytes,6,opt,name=local_snapshot_name,json=localSnapshotName,proto3" json:"local_snapshot_name,omitempty"`
	// Destination object-storage URI (the actor's in-progress snapshot URI).
	DestinationSnapshotUri string `` /* 129-byte string literal not displayed */
	// Scope the uploaded snapshot must have (the commit scope; FULL or DATA).
	// The scope the pause checkpoint captured is not sent: atelet reads it from
	// the local snapshot's own manifest, which is authoritative. When they
	// differ, atelet converts where possible (micro-VM FULL capture to a DATA
	// upload by selecting the durable-dir tar) and rejects otherwise.
	DesiredScope SnapshotScope `protobuf:"varint,8,opt,name=desired_scope,json=desiredScope,proto3,enum=atelet.SnapshotScope" json:"desired_scope,omitempty"`
	// contains filtered or unexported fields
}

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

type Volume struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to Source:
	//
	//	*Volume_DurableDir
	//	*Volume_External
	//	*Volume_SystemInfo
	//	*Volume_Image
	Source isVolume_Source `protobuf_oneof:"source"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

type Volume_DurableDir struct {
	DurableDir *DurableDirVolume `protobuf:"bytes,2,opt,name=durable_dir,json=durableDir,proto3,oneof"`
}

type Volume_External struct {
	External *ExternalVolumeSource `protobuf:"bytes,3,opt,name=external,proto3,oneof"`
}

type Volume_Image struct {
	Image *ImageVolumeSource `protobuf:"bytes,5,opt,name=image,proto3,oneof"`
}

type Volume_SystemInfo struct {
	SystemInfo *SystemInfoVolume `protobuf:"bytes,4,opt,name=system_info,json=systemInfo,proto3,oneof"`
}

type WorkerCapacityClient interface {
	SetWorkerCapacity(ctx context.Context, in *SetWorkerCapacityRequest, opts ...grpc.CallOption) (*SetWorkerCapacityResponse, error)
}

type WorkerCapacityServer interface {
	SetWorkerCapacity(context.Context, *SetWorkerCapacityRequest) (*SetWorkerCapacityResponse, error)
	// contains filtered or unexported methods
}

type WorkloadSpec struct {
	Containers []*Container `protobuf:"bytes,1,rep,name=containers,proto3" json:"containers,omitempty"`
	Volumes    []*Volume    `protobuf:"bytes,3,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}