Class RunSpecification.Builder

java.lang.Object

co.yellowdog.platform.model.builders.ValidatedBuilder<RunSpecification>

co.yellowdog.platform.model.RunSpecification.Builder

Enclosing class:

RunSpecification

public static class RunSpecification.Builder
extends ValidatedBuilder<RunSpecification>

A builder that can be used to build a new RunSpecification that is automatically validated on build.

Method Summary

Modifier and Type	Method	Description
RunSpecification	buildUnchecked()	Builds the object without enforcing validation constraints.
RunSpecification.Builder	clearInstanceTypes()
RunSpecification.Builder	clearNamespaces()
RunSpecification.Builder	clearProviders()
RunSpecification.Builder	clearRegions()
RunSpecification.Builder	clearTaskTypes()
RunSpecification.Builder	clearWorkerTags()
RunSpecification.Builder	exclusiveWorkers(Boolean exclusiveWorkers)	If true, then do not allow claimed Workers to be shared with other task groups; otherwise, Workers can be shared.
RunSpecification.Builder	instanceType(@NotBlank String instanceType)
RunSpecification.Builder	instanceTypes(Collection<? extends @NotBlank String> instanceTypes)
RunSpecification.Builder	maximumTaskRetries(int maximumTaskRetries)	The maximum number of times a task can be retried after it has failed.
RunSpecification.Builder	maxWorkers(Integer maxWorkers)	The maximum number of Workers that can be claimed for the associated TaskGroup.
RunSpecification.Builder	minWorkers(Integer minWorkers)	The minimum number of Workers that the associated TaskGroup requires.
RunSpecification.Builder	namespace(@NotBlank @Namespace String namespace)
RunSpecification.Builder	namespaces(Collection<? extends @NotBlank @Namespace String> namespaces)
RunSpecification.Builder	provider(@NotNull CloudProvider provider)
RunSpecification.Builder	providers(Collection<? extends @NotNull CloudProvider> providers)
RunSpecification.Builder	ram(DoubleRange ram)	Range constraint on GB of RAM that are required to execute tasks
RunSpecification.Builder	region(@NotBlank String region)
RunSpecification.Builder	regions(Collection<? extends @NotBlank String> regions)
RunSpecification.Builder	tasksPerWorker(Integer tasksPerWorker)	Determines the number of worker claims based on splitting the number of unfinished tasks across workers.
RunSpecification.Builder	taskTimeout(Duration taskTimeout)	The maximum time that a worker should attempt to execute a task for before failing it.
RunSpecification.Builder	taskType(@NotBlank String taskType)
RunSpecification.Builder	taskTypes(Collection<? extends @NotBlank String> taskTypes)
String	toString()
RunSpecification.Builder	vcpus(DoubleRange vcpus)	Range constraint on number of vCPUs that are required to execute tasks
RunSpecification.Builder	workerTag(@NotBlank @Size(max=200) String workerTag)
RunSpecification.Builder	workerTags(Collection<? extends @NotBlank @Size(max=200) String> workerTags)

Methods inherited from class co.yellowdog.platform.model.builders.ValidatedBuilder

build, validate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details

instanceType

public RunSpecification.Builder instanceType(@NotBlank
 @NotBlank String instanceType)

instanceTypes

public RunSpecification.Builder instanceTypes(Collection<? extends @NotBlank String> instanceTypes)

clearInstanceTypes

public RunSpecification.Builder clearInstanceTypes()

vcpus

public RunSpecification.Builder vcpus(DoubleRange vcpus)

Range constraint on number of vCPUs that are required to execute tasks

Parameters:

vcpus - range constraint on required number of vCPUs

Returns:

this.

ram

public RunSpecification.Builder ram(DoubleRange ram)

Range constraint on GB of RAM that are required to execute tasks

Parameters:

ram - range constraint on GB of RAM

Returns:

this.

taskType

public RunSpecification.Builder taskType(@NotBlank
 @NotBlank String taskType)

taskTypes

public RunSpecification.Builder taskTypes(Collection<? extends @NotBlank String> taskTypes)

clearTaskTypes

public RunSpecification.Builder clearTaskTypes()

minWorkers

public RunSpecification.Builder minWorkers(Integer minWorkers)

The minimum number of Workers that the associated TaskGroup requires. This many workers must be claimed before the associated TaskGroup will start running.

Parameters:

minWorkers - defines the minimum number of Workers required

Returns:

this.

maxWorkers

public RunSpecification.Builder maxWorkers(Integer maxWorkers)

The maximum number of Workers that can be claimed for the associated TaskGroup.

Parameters:

maxWorkers - defines the maximum number of Workers that can be claimed

Returns:

this.

tasksPerWorker

public RunSpecification.Builder tasksPerWorker(Integer tasksPerWorker)

Determines the number of worker claims based on splitting the number of unfinished tasks across workers.

Parameters:

tasksPerWorker - how many unfinished tasks per worker to determine the number of worker claims

Returns:

this.

exclusiveWorkers

public RunSpecification.Builder exclusiveWorkers(Boolean exclusiveWorkers)

If true, then do not allow claimed Workers to be shared with other task groups; otherwise, Workers can be shared.

Parameters:

exclusiveWorkers - if true, then do not allow claimed Workers to be shared with other task groups; otherwise, Workers can be shared

Returns:

this.

maximumTaskRetries

public RunSpecification.Builder maximumTaskRetries(int maximumTaskRetries)

The maximum number of times a task can be retried after it has failed.

Parameters:

maximumTaskRetries - the maximum number of times a task can be retried after it has failed

Returns:

this.

taskTimeout

public RunSpecification.Builder taskTimeout(Duration taskTimeout)

The maximum time that a worker should attempt to execute a task for before failing it. NB: This value can be overridden on individual tasks when they are added.

Parameters:

taskTimeout - the maximum time that a worker should attempt to execute a task for before failing it

Returns:

this.

provider

public RunSpecification.Builder provider(@NotNull
 @NotNull CloudProvider provider)

providers

public RunSpecification.Builder providers(Collection<? extends @NotNull CloudProvider> providers)

clearProviders

public RunSpecification.Builder clearProviders()

region

public RunSpecification.Builder region(@NotBlank
 @NotBlank String region)

regions

public RunSpecification.Builder regions(Collection<? extends @NotBlank String> regions)

clearRegions

public RunSpecification.Builder clearRegions()

workerTag

public RunSpecification.Builder workerTag(@NotBlank @Size(max=200)
 @NotBlank @Size(max=200) String workerTag)

workerTags

public RunSpecification.Builder workerTags(Collection<? extends @NotBlank @Size(max=200) String> workerTags)

clearWorkerTags

public RunSpecification.Builder clearWorkerTags()

namespace

public RunSpecification.Builder namespace(@NotBlank @Namespace
 @NotBlank @Namespace String namespace)

namespaces

public RunSpecification.Builder namespaces(Collection<? extends @NotBlank @Namespace String> namespaces)

clearNamespaces

public RunSpecification.Builder clearNamespaces()

buildUnchecked

public RunSpecification buildUnchecked()

Description copied from class: ValidatedBuilder

Builds the object without enforcing validation constraints. This should only be used for testing purposes

Overrides:

buildUnchecked in class ValidatedBuilder<RunSpecification>

Returns:

the object being built

toString

public String toString()

Overrides:

toString in class Object