com.netflix.fenzo

Interface TaskRequest

All Known Subinterfaces:

QueuableTask

public interface TaskRequest

Describes a task to be assigned to a host and its requirements.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TaskRequest.AssignedResources
static class	TaskRequest.NamedResourceSetRequest

Method Summary

Modifier and Type	Method and Description
TaskRequest.AssignedResources	getAssignedResources()
double	getCPUs() Get the number of CPUs requested by the task.
java.util.Map<java.lang.String,TaskRequest.NamedResourceSetRequest>	getCustomNamedResources() Get the list of custom named resource sets requested by the task.
double	getDisk() Get the disk space in MBs requested by the task.
java.util.List<? extends ConstraintEvaluator>	getHardConstraints() Get a list of the hard constraints the task requires.
java.lang.String	getId() Get an identifier for this task request.
double	getMemory() Get the amount of memory in MBs requested by the task.
double	getNetworkMbps() Get the network bandwidth in Mbps requested by the task.
int	getPorts() Get the number of ports requested by the task.
java.util.Map<java.lang.String,java.lang.Double>	getScalarRequests() Get the scalar resources being requested by the task.
java.util.List<? extends VMTaskFitnessCalculator>	getSoftConstraints() Get a list of the soft constraints the task requests.
void	setAssignedResources(TaskRequest.AssignedResources assignedResources)
java.lang.String	taskGroupName() Get the name of the task group that this task request belongs to.

Method Detail

getId

java.lang.String getId()

Get an identifier for this task request.

Returns:

a task identifier

taskGroupName

java.lang.String taskGroupName()

Get the name of the task group that this task request belongs to.

Returns:

the name of the group

getCPUs

double getCPUs()

Get the number of CPUs requested by the task.

Returns:

how many CPUs the task is requesting

getMemory

double getMemory()

Get the amount of memory in MBs requested by the task.

Returns:

how many MBs of memory the task is requesting

getNetworkMbps

double getNetworkMbps()

Get the network bandwidth in Mbps requested by the task.

Returns:

how many Mbps of network bandwidth the task is requesting

getDisk

double getDisk()

Get the disk space in MBs requested by the task.

Returns:

how much disk space in MBs the task is requesting

getPorts

int getPorts()

Get the number of ports requested by the task.

Returns:

how many ports the task is requesting

getScalarRequests

java.util.Map<java.lang.String,java.lang.Double> getScalarRequests()

Get the scalar resources being requested by the task. Although the cpus, memory, networkMbps, and disk are scalar resources, Fenzo currently treats the separately. Use this scalar requests collection to specify scalar resources other than those four.

Returns:

A Map of scalar resources requested, with resource name as the key and amount requested as the value.

getCustomNamedResources

java.util.Map<java.lang.String,TaskRequest.NamedResourceSetRequest> getCustomNamedResources()

Get the list of custom named resource sets requested by the task.

Returns:

List of named resource set requests, or null.

getHardConstraints

java.util.List<? extends ConstraintEvaluator> getHardConstraints()

Get a list of the hard constraints the task requires. All of these hard constraints must be satisfied by a host for the task scheduler to assign this task to that host.

Returns:

a List of hard constraints

getSoftConstraints

java.util.List<? extends VMTaskFitnessCalculator> getSoftConstraints()

Get a list of the soft constraints the task requests. Soft constraints need not be satisfied by a host for the task scheduler to assign this task to that host, but hosts that satisfy the soft constraints are preferred by the task scheduler over those that do not.

Returns:

a List of soft constraints

setAssignedResources

void setAssignedResources(TaskRequest.AssignedResources assignedResources)

getAssignedResources

TaskRequest.AssignedResources getAssignedResources()