resourcepoolv1

package
v0.0.0-...-3511abf Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ResourcePoolType_name = map[int32]string{
		0: "RESOURCE_POOL_TYPE_UNSPECIFIED",
		1: "RESOURCE_POOL_TYPE_AWS",
		2: "RESOURCE_POOL_TYPE_GCP",
		3: "RESOURCE_POOL_TYPE_STATIC",
		4: "RESOURCE_POOL_TYPE_K8S",
	}
	ResourcePoolType_value = map[string]int32{
		"RESOURCE_POOL_TYPE_UNSPECIFIED": 0,
		"RESOURCE_POOL_TYPE_AWS":         1,
		"RESOURCE_POOL_TYPE_GCP":         2,
		"RESOURCE_POOL_TYPE_STATIC":      3,
		"RESOURCE_POOL_TYPE_K8S":         4,
	}
)

Enum value maps for ResourcePoolType.

View Source 
var (
	SchedulerType_name = map[int32]string{
		0: "SCHEDULER_TYPE_UNSPECIFIED",
		1: "SCHEDULER_TYPE_PRIORITY",
		2: "SCHEDULER_TYPE_FAIR_SHARE",
		3: "SCHEDULER_TYPE_ROUND_ROBIN",
		4: "SCHEDULER_TYPE_KUBERNETES",
		5: "SCHEDULER_TYPE_SLURM",
		6: "SCHEDULER_TYPE_PBS",
	}
	SchedulerType_value = map[string]int32{
		"SCHEDULER_TYPE_UNSPECIFIED": 0,
		"SCHEDULER_TYPE_PRIORITY":    1,
		"SCHEDULER_TYPE_FAIR_SHARE":  2,
		"SCHEDULER_TYPE_ROUND_ROBIN": 3,
		"SCHEDULER_TYPE_KUBERNETES":  4,
		"SCHEDULER_TYPE_SLURM":       5,
		"SCHEDULER_TYPE_PBS":         6,
	}
)

Enum value maps for SchedulerType.

View Source 
var (
	FittingPolicy_name = map[int32]string{
		0: "FITTING_POLICY_UNSPECIFIED",
		1: "FITTING_POLICY_BEST",
		2: "FITTING_POLICY_WORST",
		3: "FITTING_POLICY_KUBERNETES",
		4: "FITTING_POLICY_SLURM",
		5: "FITTING_POLICY_PBS",
	}
	FittingPolicy_value = map[string]int32{
		"FITTING_POLICY_UNSPECIFIED": 0,
		"FITTING_POLICY_BEST":        1,
		"FITTING_POLICY_WORST":       2,
		"FITTING_POLICY_KUBERNETES":  3,
		"FITTING_POLICY_SLURM":       4,
		"FITTING_POLICY_PBS":         5,
	}
)

Enum value maps for FittingPolicy.

View Source 
var File_determined_resourcepool_v1_resourcepool_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AwsCustomTag 

type AwsCustomTag struct {

	// The key of the custom tag
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The value of the custom tag
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

List of arbitrary user-defined tags that are added to the Determined agent instances

func (*AwsCustomTag) Descriptor deprecated 

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

Deprecated: Use AwsCustomTag.ProtoReflect.Descriptor instead.

func (*AwsCustomTag) GetKey 

func (x *AwsCustomTag) GetKey() string

func (*AwsCustomTag) GetValue 

func (x *AwsCustomTag) GetValue() string

func (*AwsCustomTag) ProtoMessage 

func (*AwsCustomTag) ProtoMessage()

func (*AwsCustomTag) ProtoReflect 

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

func (*AwsCustomTag) Reset 

func (x *AwsCustomTag) Reset()

func (*AwsCustomTag) String 

func (x *AwsCustomTag) String() string

type FittingPolicy 

type FittingPolicy int32

The fitting policy of the scheduler. 

const (
	// Unspecified. This value will never actually be returned by the API, it is
	// just an artifact of using protobuf.
	FittingPolicy_FITTING_POLICY_UNSPECIFIED FittingPolicy = 0
	// Best fit. Tasks are preferentially “packed” together on the smallest number
	// of agents
	FittingPolicy_FITTING_POLICY_BEST FittingPolicy = 1
	// Worst fit. Tasks are placed on under-utilized agents, spreading out the
	// tasks.
	FittingPolicy_FITTING_POLICY_WORST FittingPolicy = 2
	// A kubernetes placeholder. In k8s, the task placement is delegated to the
	// k8s scheduler so the fitting policy is not relevant.
	FittingPolicy_FITTING_POLICY_KUBERNETES FittingPolicy = 3
	// A slurm placeholder. When running on slurm, task placement is delegated.
	FittingPolicy_FITTING_POLICY_SLURM FittingPolicy = 4
	// A PBS placeholder. When running on PBS, task placement is delegated.
	FittingPolicy_FITTING_POLICY_PBS FittingPolicy = 5
)

func (FittingPolicy) Descriptor 

func (FittingPolicy) Descriptor() protoreflect.EnumDescriptor

func (FittingPolicy) Enum 

func (x FittingPolicy) Enum() *FittingPolicy

func (FittingPolicy) EnumDescriptor deprecated 

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

Deprecated: Use FittingPolicy.Descriptor instead.

func (FittingPolicy) Number 

func (x FittingPolicy) Number() protoreflect.EnumNumber

func (FittingPolicy) String 

func (x FittingPolicy) String() string

func (FittingPolicy) Type 

func (FittingPolicy) Type() protoreflect.EnumType

type K8PriorityClass 

type K8PriorityClass struct {

	// Priority class name.
	PriorityClass string `protobuf:"bytes,1,opt,name=priority_class,json=priorityClass,proto3" json:"priority_class,omitempty"`
	// Priority class value.
	PriorityValue int32 `protobuf:"varint,2,opt,name=priority_value,json=priorityValue,proto3" json:"priority_value,omitempty"`
	// contains filtered or unexported fields
}

A kubernetes priority class

func (*K8PriorityClass) Descriptor deprecated 

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

Deprecated: Use K8PriorityClass.ProtoReflect.Descriptor instead.

func (*K8PriorityClass) GetPriorityClass 

func (x *K8PriorityClass) GetPriorityClass() string

func (*K8PriorityClass) GetPriorityValue 

func (x *K8PriorityClass) GetPriorityValue() int32

func (*K8PriorityClass) ProtoMessage 

func (*K8PriorityClass) ProtoMessage()

func (*K8PriorityClass) ProtoReflect 

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

func (*K8PriorityClass) Reset 

func (x *K8PriorityClass) Reset()

func (*K8PriorityClass) String 

func (x *K8PriorityClass) String() string

type ResourcePool 

type ResourcePool struct {

	// The unique name of the resource pool.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The description of the resource pool
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// The type of the resource pool (AWS/GCP/STATIC)
	Type ResourcePoolType `protobuf:"varint,3,opt,name=type,proto3,enum=determined.resourcepool.v1.ResourcePoolType" json:"type,omitempty"`
	// The number of agents running in the resource pool
	NumAgents int32 `protobuf:"varint,4,opt,name=num_agents,json=numAgents,proto3" json:"num_agents,omitempty"`
	// The total number of slots that exist in the resource pool
	SlotsAvailable int32 `protobuf:"varint,5,opt,name=slots_available,json=slotsAvailable,proto3" json:"slots_available,omitempty"`
	// The number of slots that are actively running workloads
	SlotsUsed int32 `protobuf:"varint,6,opt,name=slots_used,json=slotsUsed,proto3" json:"slots_used,omitempty"`
	// Slot device type: cpu, gpu, ...
	SlotType devicev1.Type `protobuf:"varint,32,opt,name=slot_type,json=slotType,proto3,enum=determined.device.v1.Type" json:"slot_type,omitempty"`
	// The max number of aux containers that can run in this resource pool
	AuxContainerCapacity int32 `protobuf:"varint,7,opt,name=aux_container_capacity,json=auxContainerCapacity,proto3" json:"aux_container_capacity,omitempty"`
	// The current number of aux containers running in this resource pool
	AuxContainersRunning int32 `protobuf:"varint,8,opt,name=aux_containers_running,json=auxContainersRunning,proto3" json:"aux_containers_running,omitempty"`
	// Is this resource pool the default compute pool?
	DefaultComputePool bool `protobuf:"varint,9,opt,name=default_compute_pool,json=defaultComputePool,proto3" json:"default_compute_pool,omitempty"`
	// Is this resource pool the default auxiliary pool?
	DefaultAuxPool bool `protobuf:"varint,10,opt,name=default_aux_pool,json=defaultAuxPool,proto3" json:"default_aux_pool,omitempty"`
	// Is this resource pool using preemptible/spot instances? Only meaningful in
	// an AWS or GCP resource pool.
	Preemptible bool `protobuf:"varint,11,opt,name=preemptible,proto3" json:"preemptible,omitempty"`
	// When using dynamic agents, the minimum number of agents that can exist in
	// the resource pool.
	MinAgents int32 `protobuf:"varint,12,opt,name=min_agents,json=minAgents,proto3" json:"min_agents,omitempty"`
	// When using dynamic agents, the maximum number of agents that can exist in
	// the resource pool.
	MaxAgents int32 `protobuf:"varint,13,opt,name=max_agents,json=maxAgents,proto3" json:"max_agents,omitempty"`
	// The number of slots that exists on an dynamic agent.
	SlotsPerAgent int32 `protobuf:"varint,14,opt,name=slots_per_agent,json=slotsPerAgent,proto3" json:"slots_per_agent,omitempty"`
	// The maximum number of auxiliary containers that can run on an individual
	// agent
	AuxContainerCapacityPerAgent int32 `` /* 153-byte string literal not displayed */
	// The type of the scheduler. Either 'FAIR_SHARE', 'PRIORITY', or
	// 'ROUND_ROBIN'
	SchedulerType SchedulerType `` /* 148-byte string literal not displayed */
	// The fitting policy of the scheduler.
	SchedulerFittingPolicy FittingPolicy `` /* 177-byte string literal not displayed */
	// The location of the resource pool. For AWS this returns the region and for
	// GCP this return the zone.
	Location string `protobuf:"bytes,18,opt,name=location,proto3" json:"location,omitempty"`
	// The VM image used for the agents when using dynamic agents.
	ImageId string `protobuf:"bytes,19,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	// The instance type of the agents when using dynamic agents. For AWS this is
	// the Instance Type. For GCP this is the machine type combined with the
	// number and types of GPUs. To work with this data programattically, we
	// recommend working with the ResourcePool.details.aws.instanceType and
	// ResourcePool.details.gcp.machineType/gpuType/gpuNum.
	InstanceType string `protobuf:"bytes,20,opt,name=instance_type,json=instanceType,proto3" json:"instance_type,omitempty"`
	// The url of the Determined master
	MasterUrl string `protobuf:"bytes,21,opt,name=master_url,json=masterUrl,proto3" json:"master_url,omitempty"`
	// A hostname for which the master’s TLS certificate is valid, if the host
	// specified by the master_url option is an IP address or is not contained in
	// the certificate
	MasterCertName string `protobuf:"bytes,22,opt,name=master_cert_name,json=masterCertName,proto3" json:"master_cert_name,omitempty"`
	// The startup script for the agent. This runs on the node the agent runs on.
	StartupScript string `protobuf:"bytes,23,opt,name=startup_script,json=startupScript,proto3" json:"startup_script,omitempty"`
	// The startup script for the agent's container. This runs in the container
	// determined-agent runs in.
	ContainerStartupScript string `` /* 130-byte string literal not displayed */
	// The Docker network to use for the agent when using dynamic agents.
	AgentDockerNetwork string `protobuf:"bytes,25,opt,name=agent_docker_network,json=agentDockerNetwork,proto3" json:"agent_docker_network,omitempty"`
	// The docker runtime to use for the agent when using dynamic agents
	AgentDockerRuntime string `protobuf:"bytes,26,opt,name=agent_docker_runtime,json=agentDockerRuntime,proto3" json:"agent_docker_runtime,omitempty"`
	// The docker image to use for the agent when using dynamic agents
	AgentDockerImage string `protobuf:"bytes,27,opt,name=agent_docker_image,json=agentDockerImage,proto3" json:"agent_docker_image,omitempty"`
	// the Fluent docker image to use
	//
	// Deprecated: Do not use.
	AgentFluentImage string `protobuf:"bytes,28,opt,name=agent_fluent_image,json=agentFluentImage,proto3" json:"agent_fluent_image,omitempty"`
	// The maximum idle period of agents in seconds. The master waits for this
	// period of time before shutting down idle agents.
	MaxIdleAgentPeriod float32 `protobuf:"fixed32,29,opt,name=max_idle_agent_period,json=maxIdleAgentPeriod,proto3" json:"max_idle_agent_period,omitempty"`
	// The maximum starting period of agents in seconds. The master waits for this
	// period of time for starting agents before retrying.
	MaxAgentStartingPeriod float32 `` /* 134-byte string literal not displayed */
	// GCP, AWS and Priority Scheduler details
	Details *ResourcePoolDetail `protobuf:"bytes,31,opt,name=details,proto3" json:"details,omitempty"`
	// GCP, AWS accelerator information
	Accelerator string `protobuf:"bytes,33,opt,name=accelerator,proto3" json:"accelerator,omitempty"`
	// Job queue stats
	Stats *jobv1.QueueStats `protobuf:"bytes,34,opt,name=stats,proto3" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

A Resource Pool is a pool of resources where containers are run.

func (*ResourcePool) Descriptor deprecated 

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

Deprecated: Use ResourcePool.ProtoReflect.Descriptor instead.

func (*ResourcePool) GetAccelerator 

func (x *ResourcePool) GetAccelerator() string

func (*ResourcePool) GetAgentDockerImage 

func (x *ResourcePool) GetAgentDockerImage() string

func (*ResourcePool) GetAgentDockerNetwork 

func (x *ResourcePool) GetAgentDockerNetwork() string

func (*ResourcePool) GetAgentDockerRuntime 

func (x *ResourcePool) GetAgentDockerRuntime() string

func (*ResourcePool) GetAgentFluentImage deprecated 

func (x *ResourcePool) GetAgentFluentImage() string

Deprecated: Do not use.

func (*ResourcePool) GetAuxContainerCapacity 

func (x *ResourcePool) GetAuxContainerCapacity() int32

func (*ResourcePool) GetAuxContainerCapacityPerAgent 

func (x *ResourcePool) GetAuxContainerCapacityPerAgent() int32

func (*ResourcePool) GetAuxContainersRunning 

func (x *ResourcePool) GetAuxContainersRunning() int32

func (*ResourcePool) GetContainerStartupScript 

func (x *ResourcePool) GetContainerStartupScript() string

func (*ResourcePool) GetDefaultAuxPool 

func (x *ResourcePool) GetDefaultAuxPool() bool

func (*ResourcePool) GetDefaultComputePool 

func (x *ResourcePool) GetDefaultComputePool() bool

func (*ResourcePool) GetDescription 

func (x *ResourcePool) GetDescription() string

func (*ResourcePool) GetDetails 

func (x *ResourcePool) GetDetails() *ResourcePoolDetail

func (*ResourcePool) GetImageId 

func (x *ResourcePool) GetImageId() string

func (*ResourcePool) GetInstanceType 

func (x *ResourcePool) GetInstanceType() string

func (*ResourcePool) GetLocation 

func (x *ResourcePool) GetLocation() string

func (*ResourcePool) GetMasterCertName 

func (x *ResourcePool) GetMasterCertName() string

func (*ResourcePool) GetMasterUrl 

func (x *ResourcePool) GetMasterUrl() string

func (*ResourcePool) GetMaxAgentStartingPeriod 

func (x *ResourcePool) GetMaxAgentStartingPeriod() float32

func (*ResourcePool) GetMaxAgents 

func (x *ResourcePool) GetMaxAgents() int32

func (*ResourcePool) GetMaxIdleAgentPeriod 

func (x *ResourcePool) GetMaxIdleAgentPeriod() float32

func (*ResourcePool) GetMinAgents 

func (x *ResourcePool) GetMinAgents() int32

func (*ResourcePool) GetName 

func (x *ResourcePool) GetName() string

func (*ResourcePool) GetNumAgents 

func (x *ResourcePool) GetNumAgents() int32

func (*ResourcePool) GetPreemptible 

func (x *ResourcePool) GetPreemptible() bool

func (*ResourcePool) GetSchedulerFittingPolicy 

func (x *ResourcePool) GetSchedulerFittingPolicy() FittingPolicy

func (*ResourcePool) GetSchedulerType 

func (x *ResourcePool) GetSchedulerType() SchedulerType

func (*ResourcePool) GetSlotType 

func (x *ResourcePool) GetSlotType() devicev1.Type

func (*ResourcePool) GetSlotsAvailable 

func (x *ResourcePool) GetSlotsAvailable() int32

func (*ResourcePool) GetSlotsPerAgent 

func (x *ResourcePool) GetSlotsPerAgent() int32

func (*ResourcePool) GetSlotsUsed 

func (x *ResourcePool) GetSlotsUsed() int32

func (*ResourcePool) GetStartupScript 

func (x *ResourcePool) GetStartupScript() string

func (*ResourcePool) GetStats 

func (x *ResourcePool) GetStats() *jobv1.QueueStats

func (*ResourcePool) GetType 

func (x *ResourcePool) GetType() ResourcePoolType

func (*ResourcePool) ProtoMessage 

func (*ResourcePool) ProtoMessage()

func (*ResourcePool) ProtoReflect 

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

func (*ResourcePool) Reset 

func (x *ResourcePool) Reset()

func (*ResourcePool) String 

func (x *ResourcePool) String() string

type ResourcePoolAwsDetail 

type ResourcePoolAwsDetail struct {

	// The region the resource pool exists in
	Region string `protobuf:"bytes,1,opt,name=region,proto3" json:"region,omitempty"`
	// Size of the root volume of the Determined agent in GB
	RootVolumeSize int32 `protobuf:"varint,2,opt,name=root_volume_size,json=rootVolumeSize,proto3" json:"root_volume_size,omitempty"`
	// The AMI ID of the Determined agent
	ImageId string `protobuf:"bytes,3,opt,name=image_id,json=imageId,proto3" json:"image_id,omitempty"`
	// Key for tagging the Determined agent instances
	TagKey string `protobuf:"bytes,4,opt,name=tag_key,json=tagKey,proto3" json:"tag_key,omitempty"`
	// Value for tagging the Determined agent instances
	TagValue string `protobuf:"bytes,5,opt,name=tag_value,json=tagValue,proto3" json:"tag_value,omitempty"`
	// Name to set for the Determined agent instances
	InstanceName string `protobuf:"bytes,6,opt,name=instance_name,json=instanceName,proto3" json:"instance_name,omitempty"`
	// The name of the SSH key registered with AWS for SSH key access to the agent
	// instances
	SshKeyName string `protobuf:"bytes,7,opt,name=ssh_key_name,json=sshKeyName,proto3" json:"ssh_key_name,omitempty"`
	// Whether to use public IP addresses for the Determined agent
	PublicIp bool `protobuf:"varint,8,opt,name=public_ip,json=publicIp,proto3" json:"public_ip,omitempty"`
	// The ID of the subnet to run the Determined agents in
	SubnetId string `protobuf:"bytes,9,opt,name=subnet_id,json=subnetId,proto3" json:"subnet_id,omitempty"`
	// The ID of the security group to run the Determined agents as
	SecurityGroupId string `protobuf:"bytes,10,opt,name=security_group_id,json=securityGroupId,proto3" json:"security_group_id,omitempty"`
	// The Amazon Resource Name (ARN) of the IAM instance profile to attach to the
	// agent instances.
	IamInstanceProfileArn string `` /* 129-byte string literal not displayed */
	// AWS instance type to use for dynamic agents
	InstanceType string `protobuf:"bytes,12,opt,name=instance_type,json=instanceType,proto3" json:"instance_type,omitempty"`
	// The log group
	LogGroup string `protobuf:"bytes,13,opt,name=log_group,json=logGroup,proto3" json:"log_group,omitempty"`
	// The log stream
	LogStream string `protobuf:"bytes,14,opt,name=log_stream,json=logStream,proto3" json:"log_stream,omitempty"`
	// Whether to use spot instances
	SpotEnabled bool `protobuf:"varint,15,opt,name=spot_enabled,json=spotEnabled,proto3" json:"spot_enabled,omitempty"`
	// The maximum price per hour to pay for a spot instance
	SpotMaxPrice string `protobuf:"bytes,16,opt,name=spot_max_price,json=spotMaxPrice,proto3" json:"spot_max_price,omitempty"`
	// List of arbitrary user-defined tags that are added to the Determined agent
	// instances
	CustomTags []*AwsCustomTag `protobuf:"bytes,17,rep,name=custom_tags,json=customTags,proto3" json:"custom_tags,omitempty"`
	// contains filtered or unexported fields
}

AWS-specific details about the resource pool

func (*ResourcePoolAwsDetail) Descriptor deprecated 

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

Deprecated: Use ResourcePoolAwsDetail.ProtoReflect.Descriptor instead.

func (*ResourcePoolAwsDetail) GetCustomTags 

func (x *ResourcePoolAwsDetail) GetCustomTags() []*AwsCustomTag

func (*ResourcePoolAwsDetail) GetIamInstanceProfileArn 

func (x *ResourcePoolAwsDetail) GetIamInstanceProfileArn() string

func (*ResourcePoolAwsDetail) GetImageId 

func (x *ResourcePoolAwsDetail) GetImageId() string

func (*ResourcePoolAwsDetail) GetInstanceName 

func (x *ResourcePoolAwsDetail) GetInstanceName() string

func (*ResourcePoolAwsDetail) GetInstanceType 

func (x *ResourcePoolAwsDetail) GetInstanceType() string

func (*ResourcePoolAwsDetail) GetLogGroup 

func (x *ResourcePoolAwsDetail) GetLogGroup() string

func (*ResourcePoolAwsDetail) GetLogStream 

func (x *ResourcePoolAwsDetail) GetLogStream() string

func (*ResourcePoolAwsDetail) GetPublicIp 

func (x *ResourcePoolAwsDetail) GetPublicIp() bool

func (*ResourcePoolAwsDetail) GetRegion 

func (x *ResourcePoolAwsDetail) GetRegion() string

func (*ResourcePoolAwsDetail) GetRootVolumeSize 

func (x *ResourcePoolAwsDetail) GetRootVolumeSize() int32

func (*ResourcePoolAwsDetail) GetSecurityGroupId 

func (x *ResourcePoolAwsDetail) GetSecurityGroupId() string

func (*ResourcePoolAwsDetail) GetSpotEnabled 

func (x *ResourcePoolAwsDetail) GetSpotEnabled() bool

func (*ResourcePoolAwsDetail) GetSpotMaxPrice 

func (x *ResourcePoolAwsDetail) GetSpotMaxPrice() string

func (*ResourcePoolAwsDetail) GetSshKeyName 

func (x *ResourcePoolAwsDetail) GetSshKeyName() string

func (*ResourcePoolAwsDetail) GetSubnetId 

func (x *ResourcePoolAwsDetail) GetSubnetId() string

func (*ResourcePoolAwsDetail) GetTagKey 

func (x *ResourcePoolAwsDetail) GetTagKey() string

func (*ResourcePoolAwsDetail) GetTagValue 

func (x *ResourcePoolAwsDetail) GetTagValue() string

func (*ResourcePoolAwsDetail) ProtoMessage 

func (*ResourcePoolAwsDetail) ProtoMessage()

func (*ResourcePoolAwsDetail) ProtoReflect 

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

func (*ResourcePoolAwsDetail) Reset 

func (x *ResourcePoolAwsDetail) Reset()

func (*ResourcePoolAwsDetail) String 

func (x *ResourcePoolAwsDetail) String() string

type ResourcePoolDetail 

type ResourcePoolDetail struct {

	// AWS-specific details
	Aws *ResourcePoolAwsDetail `protobuf:"bytes,1,opt,name=aws,proto3" json:"aws,omitempty"`
	// GCP-specific details
	Gcp *ResourcePoolGcpDetail `protobuf:"bytes,2,opt,name=gcp,proto3" json:"gcp,omitempty"`
	// Priority scheduler-specific details
	PriorityScheduler *ResourcePoolPrioritySchedulerDetail `protobuf:"bytes,3,opt,name=priority_scheduler,json=priorityScheduler,proto3" json:"priority_scheduler,omitempty"`
	// contains filtered or unexported fields
}

Detailed information about the resource pool

func (*ResourcePoolDetail) Descriptor deprecated 

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

Deprecated: Use ResourcePoolDetail.ProtoReflect.Descriptor instead.

func (*ResourcePoolDetail) GetAws 

func (x *ResourcePoolDetail) GetAws() *ResourcePoolAwsDetail

func (*ResourcePoolDetail) GetGcp 

func (x *ResourcePoolDetail) GetGcp() *ResourcePoolGcpDetail

func (*ResourcePoolDetail) GetPriorityScheduler 

func (x *ResourcePoolDetail) GetPriorityScheduler() *ResourcePoolPrioritySchedulerDetail

func (*ResourcePoolDetail) ProtoMessage 

func (*ResourcePoolDetail) ProtoMessage()

func (*ResourcePoolDetail) ProtoReflect 

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

func (*ResourcePoolDetail) Reset 

func (x *ResourcePoolDetail) Reset()

func (*ResourcePoolDetail) String 

func (x *ResourcePoolDetail) String() string

type ResourcePoolGcpDetail 

type ResourcePoolGcpDetail struct {

	// The project ID of the GCP resources used by Determined
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The zone of the GCP resources used by Determined
	Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
	// Size of the root volume of the Determined agent in GB
	BootDiskSize int32 `protobuf:"varint,3,opt,name=boot_disk_size,json=bootDiskSize,proto3" json:"boot_disk_size,omitempty"`
	// The boot disk source image of the Determined agent
	BootDiskSourceImage string `protobuf:"bytes,4,opt,name=boot_disk_source_image,json=bootDiskSourceImage,proto3" json:"boot_disk_source_image,omitempty"`
	// Key for labeling the Determined agent instances.
	LabelKey string `protobuf:"bytes,5,opt,name=label_key,json=labelKey,proto3" json:"label_key,omitempty"`
	// Value for labeling the Determined agent instances
	LabelValue string `protobuf:"bytes,6,opt,name=label_value,json=labelValue,proto3" json:"label_value,omitempty"`
	// Name prefix to set for the Determined agent instances
	NamePrefix string `protobuf:"bytes,7,opt,name=name_prefix,json=namePrefix,proto3" json:"name_prefix,omitempty"`
	// Network resource for the Determined agent instances
	Network string `protobuf:"bytes,8,opt,name=network,proto3" json:"network,omitempty"`
	// Subnetwork resource for the Determined agent instances
	Subnetwork string `protobuf:"bytes,9,opt,name=subnetwork,proto3" json:"subnetwork,omitempty"`
	// Whether to use external IP addresses for the Determined agent instances
	ExternalIp bool `protobuf:"varint,10,opt,name=external_ip,json=externalIp,proto3" json:"external_ip,omitempty"`
	// The network tags to set firewalls for the Determined agent instances
	NetworkTags []string `protobuf:"bytes,11,rep,name=network_tags,json=networkTags,proto3" json:"network_tags,omitempty"`
	// Email of the service account for the Determined agent instances.
	ServiceAccountEmail string `protobuf:"bytes,12,opt,name=service_account_email,json=serviceAccountEmail,proto3" json:"service_account_email,omitempty"`
	// List of scopes authorized for the Determined agent instances
	ServiceAccountScopes []string `protobuf:"bytes,13,rep,name=service_account_scopes,json=serviceAccountScopes,proto3" json:"service_account_scopes,omitempty"`
	// Type of machine for the Determined agents
	MachineType string `protobuf:"bytes,14,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// Type of GPU for the Determined agents
	GpuType string `protobuf:"bytes,15,opt,name=gpu_type,json=gpuType,proto3" json:"gpu_type,omitempty"`
	// Number of GPUs for the Determined agents
	GpuNum int32 `protobuf:"varint,16,opt,name=gpu_num,json=gpuNum,proto3" json:"gpu_num,omitempty"`
	// Whether to use preemptible instances
	Preemptible bool `protobuf:"varint,17,opt,name=preemptible,proto3" json:"preemptible,omitempty"`
	// The timeout period for tracking a GCP operation in seconds
	OperationTimeoutPeriod float32 `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

GCP-specific details about the resource pool

func (*ResourcePoolGcpDetail) Descriptor deprecated 

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

Deprecated: Use ResourcePoolGcpDetail.ProtoReflect.Descriptor instead.

func (*ResourcePoolGcpDetail) GetBootDiskSize 

func (x *ResourcePoolGcpDetail) GetBootDiskSize() int32

func (*ResourcePoolGcpDetail) GetBootDiskSourceImage 

func (x *ResourcePoolGcpDetail) GetBootDiskSourceImage() string

func (*ResourcePoolGcpDetail) GetExternalIp 

func (x *ResourcePoolGcpDetail) GetExternalIp() bool

func (*ResourcePoolGcpDetail) GetGpuNum 

func (x *ResourcePoolGcpDetail) GetGpuNum() int32

func (*ResourcePoolGcpDetail) GetGpuType 

func (x *ResourcePoolGcpDetail) GetGpuType() string

func (*ResourcePoolGcpDetail) GetLabelKey 

func (x *ResourcePoolGcpDetail) GetLabelKey() string

func (*ResourcePoolGcpDetail) GetLabelValue 

func (x *ResourcePoolGcpDetail) GetLabelValue() string

func (*ResourcePoolGcpDetail) GetMachineType 

func (x *ResourcePoolGcpDetail) GetMachineType() string

func (*ResourcePoolGcpDetail) GetNamePrefix 

func (x *ResourcePoolGcpDetail) GetNamePrefix() string

func (*ResourcePoolGcpDetail) GetNetwork 

func (x *ResourcePoolGcpDetail) GetNetwork() string

func (*ResourcePoolGcpDetail) GetNetworkTags 

func (x *ResourcePoolGcpDetail) GetNetworkTags() []string

func (*ResourcePoolGcpDetail) GetOperationTimeoutPeriod 

func (x *ResourcePoolGcpDetail) GetOperationTimeoutPeriod() float32

func (*ResourcePoolGcpDetail) GetPreemptible 

func (x *ResourcePoolGcpDetail) GetPreemptible() bool

func (*ResourcePoolGcpDetail) GetProject 

func (x *ResourcePoolGcpDetail) GetProject() string

func (*ResourcePoolGcpDetail) GetServiceAccountEmail 

func (x *ResourcePoolGcpDetail) GetServiceAccountEmail() string

func (*ResourcePoolGcpDetail) GetServiceAccountScopes 

func (x *ResourcePoolGcpDetail) GetServiceAccountScopes() []string

func (*ResourcePoolGcpDetail) GetSubnetwork 

func (x *ResourcePoolGcpDetail) GetSubnetwork() string

func (*ResourcePoolGcpDetail) GetZone 

func (x *ResourcePoolGcpDetail) GetZone() string

func (*ResourcePoolGcpDetail) ProtoMessage 

func (*ResourcePoolGcpDetail) ProtoMessage()

func (*ResourcePoolGcpDetail) ProtoReflect 

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

func (*ResourcePoolGcpDetail) Reset 

func (x *ResourcePoolGcpDetail) Reset()

func (*ResourcePoolGcpDetail) String 

func (x *ResourcePoolGcpDetail) String() string

type ResourcePoolPrioritySchedulerDetail 

type ResourcePoolPrioritySchedulerDetail struct {

	// Whether lower priority tasks should be preempted to schedule higher
	// priority tasks
	Preemption bool `protobuf:"varint,1,opt,name=preemption,proto3" json:"preemption,omitempty"`
	// The priority that is assigned to tasks that do not explicitly specify a
	// priority.
	DefaultPriority int32 `protobuf:"varint,2,opt,name=default_priority,json=defaultPriority,proto3" json:"default_priority,omitempty"`
	// List of available priorities for K8 (if applicable).
	K8Priorities []*K8PriorityClass `protobuf:"bytes,3,rep,name=k8_priorities,json=k8Priorities,proto3" json:"k8_priorities,omitempty"`
	// contains filtered or unexported fields
}

Details related to the priority scheduler. This will only be present if the schedulerType=priority

func (*ResourcePoolPrioritySchedulerDetail) Descriptor deprecated 

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

Deprecated: Use ResourcePoolPrioritySchedulerDetail.ProtoReflect.Descriptor instead.

func (*ResourcePoolPrioritySchedulerDetail) GetDefaultPriority 

func (x *ResourcePoolPrioritySchedulerDetail) GetDefaultPriority() int32

func (*ResourcePoolPrioritySchedulerDetail) GetK8Priorities 

func (x *ResourcePoolPrioritySchedulerDetail) GetK8Priorities() []*K8PriorityClass

func (*ResourcePoolPrioritySchedulerDetail) GetPreemption 

func (x *ResourcePoolPrioritySchedulerDetail) GetPreemption() bool

func (*ResourcePoolPrioritySchedulerDetail) ProtoMessage 

func (*ResourcePoolPrioritySchedulerDetail) ProtoMessage()

func (*ResourcePoolPrioritySchedulerDetail) ProtoReflect 

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

func (*ResourcePoolPrioritySchedulerDetail) Reset 

func (x *ResourcePoolPrioritySchedulerDetail) Reset()

func (*ResourcePoolPrioritySchedulerDetail) String 

func (x *ResourcePoolPrioritySchedulerDetail) String() string

type ResourcePoolType 

type ResourcePoolType int32

The type of the ResourcePool. 

const (
	// Unspecified. This value will never actually be returned by the API, it is
	// just an artifact of using protobuf.
	ResourcePoolType_RESOURCE_POOL_TYPE_UNSPECIFIED ResourcePoolType = 0
	// An AWS resource pool.
	ResourcePoolType_RESOURCE_POOL_TYPE_AWS ResourcePoolType = 1
	// A GCP resource pool.
	ResourcePoolType_RESOURCE_POOL_TYPE_GCP ResourcePoolType = 2
	// A static resource pool.
	ResourcePoolType_RESOURCE_POOL_TYPE_STATIC ResourcePoolType = 3
	// The kubernetes resource pool.
	ResourcePoolType_RESOURCE_POOL_TYPE_K8S ResourcePoolType = 4
)

func (ResourcePoolType) Descriptor 

func (ResourcePoolType) Descriptor() protoreflect.EnumDescriptor

func (ResourcePoolType) Enum 

func (x ResourcePoolType) Enum() *ResourcePoolType

func (ResourcePoolType) EnumDescriptor deprecated 

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

Deprecated: Use ResourcePoolType.Descriptor instead.

func (ResourcePoolType) Number 

func (x ResourcePoolType) Number() protoreflect.EnumNumber

func (ResourcePoolType) String 

func (x ResourcePoolType) String() string

func (ResourcePoolType) Type 

func (ResourcePoolType) Type() protoreflect.EnumType

type SchedulerType 

type SchedulerType int32

The type of the Scheduler. 

const (
	// Unspecified. This value will never actually be returned by the API, it is
	// just an artifact of using protobuf.
	SchedulerType_SCHEDULER_TYPE_UNSPECIFIED SchedulerType = 0
	// The priority scheduler.
	SchedulerType_SCHEDULER_TYPE_PRIORITY SchedulerType = 1
	// The fair share scheduler.
	SchedulerType_SCHEDULER_TYPE_FAIR_SHARE SchedulerType = 2
	// The round robin scheduler
	SchedulerType_SCHEDULER_TYPE_ROUND_ROBIN SchedulerType = 3
	// The kubernetes scheduler.
	SchedulerType_SCHEDULER_TYPE_KUBERNETES SchedulerType = 4
	// A slurm placeholder. When running on slurm, all scheduling behavior is
	// delegated.
	SchedulerType_SCHEDULER_TYPE_SLURM SchedulerType = 5
	// A PBS placeholder. When running on PBS, all scheduling behavior is
	// delegated.
	SchedulerType_SCHEDULER_TYPE_PBS SchedulerType = 6
)

func (SchedulerType) Descriptor 

func (SchedulerType) Descriptor() protoreflect.EnumDescriptor

func (SchedulerType) Enum 

func (x SchedulerType) Enum() *SchedulerType

func (SchedulerType) EnumDescriptor deprecated 

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

Deprecated: Use SchedulerType.Descriptor instead.

func (SchedulerType) Number 

func (x SchedulerType) Number() protoreflect.EnumNumber

func (SchedulerType) String 

func (x SchedulerType) String() string

func (SchedulerType) Type 

func (SchedulerType) Type() protoreflect.EnumType

Source Files

View all Source files

Jump to

Keyboard shortcuts

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