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) Enum

func (x FittingPolicy) Enum() *FittingPolicy

func (FittingPolicy) EnumDescriptor deprecated

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

Deprecated: Use FittingPolicy.Descriptor instead.

func (FittingPolicy) Number

func (FittingPolicy) String

func (x FittingPolicy) String() string

func (FittingPolicy) Type

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 (*ResourcePoolDetail) GetGcp

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 (*ResourcePoolPrioritySchedulerDetail) Reset

func (*ResourcePoolPrioritySchedulerDetail) 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) Enum

func (ResourcePoolType) EnumDescriptor deprecated

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

Deprecated: Use ResourcePoolType.Descriptor instead.

func (ResourcePoolType) Number

func (ResourcePoolType) String

func (x ResourcePoolType) String() string

func (ResourcePoolType) Type

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) Enum

func (x SchedulerType) Enum() *SchedulerType

func (SchedulerType) EnumDescriptor deprecated

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

Deprecated: Use SchedulerType.Descriptor instead.

func (SchedulerType) Number

func (SchedulerType) String

func (x SchedulerType) String() string

func (SchedulerType) Type

Jump to

Keyboard shortcuts

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