Skip navigation links
A B C D E F G H I L M N O P Q R S T U V W 

A

Action0 - Interface in com.netflix.fenzo.functions
A no-argument action.
Action1<T> - Interface in com.netflix.fenzo.functions
A one-argument action.
Action2<T1,T2> - Interface in com.netflix.fenzo.functions
A two argument action.
ActiveTask(TaskRequest, AssignableVirtualMachine) - Constructor for class com.netflix.fenzo.TaskTracker.ActiveTask
 
add(ResAllocs, ResAllocs) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
add(ResAllocs, QueuableTask) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
addException(Exception) - Method in class com.netflix.fenzo.SchedulingResult
 
addLeases(List<? extends VirtualMachineLease>) - Method in class com.netflix.fenzo.TaskSchedulingService
Add new leases to be used for next scheduling iteration.
addOrReplaceAutoScaleRule(AutoScaleRule) - Method in class com.netflix.fenzo.TaskScheduler
Add a new autoscale rule to those used by this scheduler.
addOrReplaceResAllocs(ResAllocs) - Method in class com.netflix.fenzo.TaskScheduler
Add a new resource allocation, or replace an existing one of the same name.
addUsage(QueuableTask) - Method in class com.netflix.fenzo.queues.UsageTrackedQueue.ResUsage
 
Assignable<T> - Class in com.netflix.fenzo.queues
A wrapper object containing a task, and optionally an assignment failure for this task.
AssignedResources() - Constructor for class com.netflix.fenzo.TaskRequest.AssignedResources
 
AssignmentFailure - Class in com.netflix.fenzo
An assignment failure to indicate that a particular task could not be scheduled because a quantifiable resource was insufficient, along with the amount of the resource that was requested (asked) by the task, the amount already used, and the amount available on the target.
AssignmentFailure(VMResource, double, double, double, String) - Constructor for class com.netflix.fenzo.AssignmentFailure
 
assignTask(QueuableTask) - Method in interface com.netflix.fenzo.queues.UsageTrackedQueue
Mark the given task to be assigned resources.
AsSoftConstraint - Class in com.netflix.fenzo
Converts a hard constraint into a soft constraint.
AsSoftConstraint() - Constructor for class com.netflix.fenzo.AsSoftConstraint
 
asSoftConstraint() - Method in class com.netflix.fenzo.plugins.BalancedHostAttrConstraint
Converts this constraint into a "soft" constraint.
AutoScaleAction - Interface in com.netflix.fenzo
Describes an autoscaling action, either the scaling up or down of an autoscaling group.
AutoScaleAction.Type - Enum in com.netflix.fenzo
Indicates whether the autoscale action is to scale up or to scale down.
AutoScaleRule - Interface in com.netflix.fenzo
A rule that defines when to scale the number of hosts of a certain type.

B

BalancedHostAttrConstraint - Class in com.netflix.fenzo.plugins
A balanced host attribute constraint attempts to distribute co-tasks evenly among host types, where their types are determined by the values of particular host attributes.
BalancedHostAttrConstraint(Func1<String, Set<String>>, String, int) - Constructor for class com.netflix.fenzo.plugins.BalancedHostAttrConstraint
Create a constraint evaluator to balance tasks across hosts based on a given host attribute.
BinPackingFitnessCalculators - Class in com.netflix.fenzo.plugins
A collection of bin packing fitness calculators.
BinPackingFitnessCalculators() - Constructor for class com.netflix.fenzo.plugins.BinPackingFitnessCalculators
 
build() - Method in class com.netflix.fenzo.sla.ResAllocsBuilder
Builds a ResAllocs object based on your builder method instructions.
build() - Method in class com.netflix.fenzo.TaskScheduler.Builder
Creates a TaskScheduler based on the various builder methods you have chained.
build() - Method in class com.netflix.fenzo.TaskSchedulingService.Builder
Creates a TaskSchedulingService based on the various builder methods you have chained.
Builder() - Constructor for class com.netflix.fenzo.TaskScheduler.Builder
 
Builder() - Constructor for class com.netflix.fenzo.TaskSchedulingService.Builder
 

C

calculateFitness(TaskRequest, VirtualMachineCurrentState, TaskTrackerState) - Method in class com.netflix.fenzo.DefaultFitnessCalculator
Computes the suitability of targetVM to take on the task described by taskRequest to be 1.0 (fully suitable).
calculateFitness(TaskRequest, VirtualMachineCurrentState, TaskTrackerState) - Method in interface com.netflix.fenzo.VMTaskFitnessCalculator
Calculates how well the task fits on the host.
call() - Method in interface com.netflix.fenzo.functions.Action0
Invoke the action.
call(T) - Method in interface com.netflix.fenzo.functions.Action1
Invoke the action.
call(T1, T2) - Method in interface com.netflix.fenzo.functions.Action2
Invoke the action.
call(T1) - Method in interface com.netflix.fenzo.functions.Func1
Invoke the function.
ceilingOf(ResAllocs, ResAllocs) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
com.netflix.fenzo - package com.netflix.fenzo
 
com.netflix.fenzo.functions - package com.netflix.fenzo.functions
 
com.netflix.fenzo.plugins - package com.netflix.fenzo.plugins
 
com.netflix.fenzo.queues - package com.netflix.fenzo.queues
 
com.netflix.fenzo.queues.tiered - package com.netflix.fenzo.queues.tiered
 
com.netflix.fenzo.samples - package com.netflix.fenzo.samples
 
com.netflix.fenzo.sla - package com.netflix.fenzo.sla
 
ConstraintEvaluator - Interface in com.netflix.fenzo
A constraint evaluator inspects a target to decide whether or not its attributes are satisfactory according to some standard given the current state of task assignments in the system at large.
ConstraintEvaluator.Result - Class in com.netflix.fenzo
The result of the evaluation of a ConstraintEvaluator.
ConstraintFailure - Class in com.netflix.fenzo
An object that encapsulates the case of a target failing to satisfy a constraint mandated by a task and implemented by a ConstraintEvaluator.
ConstraintFailure(String, String) - Constructor for class com.netflix.fenzo.ConstraintFailure
 
ConsumeResult(int, String, String, double) - Constructor for class com.netflix.fenzo.PreferentialNamedConsumableResourceSet.ConsumeResult
 
cpuBinPacker - Static variable in class com.netflix.fenzo.plugins.BinPackingFitnessCalculators
A CPU bin packing fitness calculator.
cpuCores() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
cpuCores() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the number of cores (CPUs) on this host that are available for assigning.
cpuMemBinPacker - Static variable in class com.netflix.fenzo.plugins.BinPackingFitnessCalculators
A bin packing fitness calculator that achieves both CPU and Memory bin packing with equal weights to both goals.
cpuMemNetworkBinPacker - Static variable in class com.netflix.fenzo.plugins.BinPackingFitnessCalculators
A fitness calculator that achieves CPU, Memory, and network bandwidth bin packing with equal weights to each of the three goals.
createTieredQueue(int) - Static method in class com.netflix.fenzo.queues.TaskQueues
Create a tiered TaskQueue with the given number of tiers.
CustomResAbsentKey - Static variable in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet
 

D

DefaultFitnessCalculator - Class in com.netflix.fenzo
A default fitness calculator that always finds any target to be perfectly fit for any task.
DefaultFitnessCalculator() - Constructor for class com.netflix.fenzo.DefaultFitnessCalculator
 
disableShortfallEvaluation() - Method in class com.netflix.fenzo.TaskScheduler.Builder
Disable resource shortfall evaluation.
disableVM(String, long) - Method in class com.netflix.fenzo.TaskScheduler
Disable the virtual machine with the specified hostname.
disableVMByVMId(String, long) - Method in class com.netflix.fenzo.TaskScheduler
Disable the virtual machine with the specified ID.
disconnected(SchedulerDriver) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
 
diskMB() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
diskMB() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the amount of disk space, in MB, on this host that is avaialble for assigning.

E

empty() - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
emptyOf(String) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
enableVM(String) - Method in class com.netflix.fenzo.TaskScheduler
Enable the VM with the specified host name.
error(T, AssignmentFailure) - Static method in class com.netflix.fenzo.queues.Assignable
 
error(SchedulerDriver, String) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
 
evaluate(TaskRequest, VirtualMachineCurrentState, TaskTrackerState) - Method in interface com.netflix.fenzo.ConstraintEvaluator
Inspects a target to decide whether or not it meets the constraints appropriate to a particular task.
evaluate(TaskRequest, VirtualMachineCurrentState, TaskTrackerState) - Method in class com.netflix.fenzo.plugins.BalancedHostAttrConstraint
 
evaluate(TaskRequest, VirtualMachineCurrentState, TaskTrackerState) - Method in class com.netflix.fenzo.plugins.ExclusiveHostConstraint
Determines whether the prospective host already has tasks either running on it or assigned to be run on it, and returns a false Result if either of those things is the case.
evaluate(TaskRequest, VirtualMachineCurrentState, TaskTrackerState) - Method in class com.netflix.fenzo.plugins.HostAttrValueConstraint
Tests a host to determine whether it has an attribute of the required value for this task request.
evaluate(TaskRequest, VirtualMachineCurrentState, TaskTrackerState) - Method in class com.netflix.fenzo.plugins.UniqueHostAttrConstraint
Determines whether a particular target host is appropriate for a particular task request by rejecting any host that has the same value for the unique constraint attribute as another host that is already assigned a co-task of the specified task request.
ExclusiveHostConstraint - Class in com.netflix.fenzo.plugins
This constraint ensures that the host is exclusively assigned to the given job.
ExclusiveHostConstraint() - Constructor for class com.netflix.fenzo.plugins.ExclusiveHostConstraint
 
executorLost(SchedulerDriver, Protos.ExecutorID, Protos.SlaveID, int) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
Do nothing, instead, rely on task lost status updates to inform Fenzo of task completions.
expireAllLeases(String) - Method in class com.netflix.fenzo.TaskScheduler
Call this method to instruct the task scheduler to reject all of the unused offers it is currently holding that concern resources offered by the host with the name hostname.
expireAllLeases() - Method in class com.netflix.fenzo.TaskScheduler
Call this method to instruct the task scheduler to reject all of the unused offers it is currently holding.
expireAllLeasesByVMId(String) - Method in class com.netflix.fenzo.TaskScheduler
Call this method to instruct the task scheduler to reject all of the unused offers it is currently holding that concern resources offered by the host with the ID, vmId.
expireLease(String) - Method in class com.netflix.fenzo.TaskScheduler
Call this method to instruct the task scheduler to reject a particular resource offer.

F

frameworkMessage(SchedulerDriver, Protos.ExecutorID, Protos.SlaveID, byte[]) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
 
Func1<T1,R> - Interface in com.netflix.fenzo.functions
Represents a function with a single argument.

G

get(ConstraintEvaluator) - Static method in class com.netflix.fenzo.AsSoftConstraint
Returns a "soft" constraint, in the form of a VMTaskFitnessCalculator, based on a specified "hard" constraint, in the form of a ConstraintEvaluator.
getAllCurrentlyAssignedTasks() - Method in interface com.netflix.fenzo.TaskTrackerState
Get a map of all tasks currently assigned during a scheduling trial, but not running yet.
getAllCurrentOffers() - Method in interface com.netflix.fenzo.VirtualMachineCurrentState
Get all offers for the VM that represent the available resources.
getAllRunningTasks() - Method in interface com.netflix.fenzo.TaskTrackerState
Get a map of all running tasks.
getAllTasks() - Method in interface com.netflix.fenzo.queues.InternalTaskQueue
Get all of the tasks in the queue.
getAllTasks() - Method in class com.netflix.fenzo.queues.tiered.TieredQueue
 
getAllTasks() - Method in interface com.netflix.fenzo.queues.UsageTrackedQueue
Get list of all tasks grouped by their state.
getAsking() - Method in class com.netflix.fenzo.AssignmentFailure
Returns the quantity of this target resource the task was requesting.
getAssignedPorts() - Method in class com.netflix.fenzo.TaskAssignmentResult
Returns a list of port numbers corresponding to the ports the task was assigned on the host.
getAssignedResources() - Method in interface com.netflix.fenzo.TaskRequest
 
getAssignmentFailure() - Method in class com.netflix.fenzo.queues.Assignable
 
getAttributeMap() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
getAttributeMap() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the map of Mesos attributes associated with this lease (offer).
getAttrName() - Method in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet.ConsumeResult
 
getAutoScaleRules() - Method in class com.netflix.fenzo.TaskScheduler
Get the autoscale rules currently registered with the scheduler.
getAvailable() - Method in class com.netflix.fenzo.AssignmentFailure
Returns the quantity of this resource that the target has free to be assigned to a new task or tasks.
getBeg() - Method in class com.netflix.fenzo.VirtualMachineLease.Range
Get the beginning value of the range.
getBucketName() - Method in interface com.netflix.fenzo.queues.QAttributes
Get the queue's bucket name.
getBucketName() - Method in class com.netflix.fenzo.queues.QAttributes.QAttributesAdaptor
 
getConstraintFailure() - Method in class com.netflix.fenzo.TaskAssignmentResult
Get the ConstraintFailure corresponding to the task constraint that the host failed to meet.
getConsumedNamedResources() - Method in class com.netflix.fenzo.TaskRequest.AssignedResources
 
getCoolDownSecs() - Method in interface com.netflix.fenzo.AutoScaleRule
Returns the amount of time to wait from the beginning of a scale up or scale down operation before initiating another autoscale operation (a.k.a the "cool down" time).
getCores() - Method in interface com.netflix.fenzo.sla.ResAllocs
Limits the number of cores the task group can use to the number returned from this method.
getCpus() - Method in class com.netflix.fenzo.queues.UsageTrackedQueue.ResUsage
 
getCPUs() - Method in interface com.netflix.fenzo.TaskRequest
Get the number of CPUs requested by the task.
getCurrAvailableResources() - Method in interface com.netflix.fenzo.VirtualMachineCurrentState
Returns a VM lease object representing totals of resources from all available leases on this host for the current scheduling run.
getCustomNamedResources() - Method in interface com.netflix.fenzo.TaskRequest
Get the list of custom named resource sets requested by the task.
getDisabledUntil() - Method in interface com.netflix.fenzo.VirtualMachineCurrentState
Returns the time until which the given host remains disabled.
getDisk() - Method in class com.netflix.fenzo.queues.UsageTrackedQueue.ResUsage
 
getDisk() - Method in interface com.netflix.fenzo.sla.ResAllocs
Limits the amount of disk space the task group can use to the number of MB returned from this method.
getDisk() - Method in interface com.netflix.fenzo.TaskRequest
Get the disk space in MBs requested by the task.
getDominantResUsageFrom(ResAllocs) - Method in class com.netflix.fenzo.queues.UsageTrackedQueue.ResUsage
 
getDominantUsageShare() - Method in interface com.netflix.fenzo.queues.UsageTrackedQueue
Get the usage of the dominant resource, expressed as a share of the total known available resources.
getEnd() - Method in class com.netflix.fenzo.VirtualMachineLease.Range
Get the end value of the range.
getExceptions() - Method in exception com.netflix.fenzo.queues.TaskQueueMultiException
 
getExceptions() - Method in class com.netflix.fenzo.SchedulingResult
 
getFailureReason() - Method in class com.netflix.fenzo.ConstraintEvaluator.Result
Returns the reason why the target did not satisfy the constraint.
getFailures() - Method in class com.netflix.fenzo.SchedulingResult
Get the unsuccessful task assignment result map.
getFailures() - Method in class com.netflix.fenzo.TaskAssignmentResult
Get a list of AssignmentFailures corresponding to the reasons why the assignment of this task to the host did not succeed because of insufficient resources.
getFitness() - Method in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet.ConsumeResult
 
getFitness() - Method in class com.netflix.fenzo.TaskAssignmentResult
Get the result of the fitness calculation applied to this host for this task.
getHardConstraints() - Method in interface com.netflix.fenzo.TaskRequest
Get a list of the hard constraints the task requires.
getHostname() - Method in class com.netflix.fenzo.TaskAssignmentResult
Returns the name of the host machine to which this task was attempted to be assigned.
getHostname() - Method in interface com.netflix.fenzo.VirtualMachineCurrentState
Get the name of the host on which the virtual machine is running.
getHostname() - Method in class com.netflix.fenzo.VMAssignmentResult
Get the name of the host whose assignment results are available.
getHosts() - Method in class com.netflix.fenzo.ScaleDownAction
Get the hostnames to unqueueTask from the cluster during the scale down action.
getId() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
getId() - Method in class com.netflix.fenzo.queues.QAttributes.TaskIdAttributesTuple
 
getId() - Method in interface com.netflix.fenzo.TaskRequest
Get an identifier for this task request.
getId() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the ID of the lease (offer ID).
getIdleVMsCount() - Method in class com.netflix.fenzo.SchedulingResult
Get the number of hosts (virtual machines) that are idle at the end of this scheduling trial.
getIndex() - Method in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet.ConsumeResult
 
getIndex() - Method in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet.PreferentialNamedConsumableResource
 
getLeasesAdded() - Method in class com.netflix.fenzo.SchedulingResult
Get the number of leases (resource offers) added during this scheduling trial.
getLeasesRejected() - Method in class com.netflix.fenzo.SchedulingResult
Get the number of leases (resource offers) rejected during this scheduling trial.
getLeasesUsed() - Method in class com.netflix.fenzo.VMAssignmentResult
Get the list of leases (resource offers) used in creating the resource assignments for tasks.
getLimit() - Method in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet.PreferentialNamedConsumableResource
 
getMaxIdleHostsToKeep() - Method in interface com.netflix.fenzo.AutoScaleRule
Returns the maximum number of hosts, in the autoscale group this rule applies to, that Fenzo is to keep in idle readiness.
getMaxSize() - Method in interface com.netflix.fenzo.AutoScaleRule
Returns the maximum number of hosts to expect in the autoscale group for this rule.
getMemory() - Method in class com.netflix.fenzo.queues.UsageTrackedQueue.ResUsage
 
getMemory() - Method in interface com.netflix.fenzo.sla.ResAllocs
Limits the amount of memory the task group can use to the number of MB returned from this method
getMemory() - Method in interface com.netflix.fenzo.TaskRequest
Get the amount of memory in MBs requested by the task.
getMessage() - Method in class com.netflix.fenzo.AssignmentFailure
Returns text message associated with this assignment failure.
getMinIdleHostsToKeep() - Method in interface com.netflix.fenzo.AutoScaleRule
Returns the minimum number of hosts, in the autoscale group this rule applies to, that Fenzo is to keep in idle readiness.
getMinSize() - Method in interface com.netflix.fenzo.AutoScaleRule
Returns the minimum number of hosts to expect in the autoscale group for this rule.
getName() - Method in interface com.netflix.fenzo.ConstraintEvaluator
Returns the name of the constraint evaluator.
getName() - Method in class com.netflix.fenzo.ConstraintFailure
Returns the name of the constraint that was violated by the target.
getName() - Method in class com.netflix.fenzo.DefaultFitnessCalculator
Returns the name of this fitness calculator (the class name).
getName() - Method in class com.netflix.fenzo.plugins.BalancedHostAttrConstraint
Returns the name of the balanced host attribute constraint, which takes the form of the name of the class (or subclass) followed by a dash followed by the value of hostAttributeName as it was set when the constraint object was created.
getName() - Method in class com.netflix.fenzo.plugins.ExclusiveHostConstraint
Returns the name of this class as a String.
getName() - Method in class com.netflix.fenzo.plugins.HostAttrValueConstraint
Returns the name of this constraint as a String, in the form of the class name followed by a dash followed by the value of hostAttributeName as it was set when this object was constructed.
getName() - Method in class com.netflix.fenzo.plugins.UniqueHostAttrConstraint
Returns the name of this constraint evaluator as a String in the form of the name of this class followed by a dash followed by the host attribute name that this evaluator uses to uniquely identify the host.
getName() - Method in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet
 
getName() - Method in interface com.netflix.fenzo.VMTaskFitnessCalculator
Get the name of this fitness calculator.
getNetworkMbps() - Method in class com.netflix.fenzo.queues.UsageTrackedQueue.ResUsage
 
getNetworkMbps() - Method in interface com.netflix.fenzo.sla.ResAllocs
Limits the amount of bandwidth the task group can use to the number of megabits per second returned from this method.
getNetworkMbps() - Method in interface com.netflix.fenzo.TaskRequest
Get the network bandwidth in Mbps requested by the task.
getNumAllocations() - Method in class com.netflix.fenzo.SchedulingResult
Get the number of resource allocations performed during this scheduling trial.
getNumSets() - Method in class com.netflix.fenzo.TaskRequest.NamedResourceSetRequest
 
getNumSubResources() - Method in class com.netflix.fenzo.TaskRequest.NamedResourceSetRequest
 
getOffer() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
getOffer() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the Mesos resource offer associated with this lease.
getOfferedTime() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
getOfferedTime() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the time that this lease (offer) was obtained.
getPorts() - Method in interface com.netflix.fenzo.TaskRequest
Get the number of ports requested by the task.
getqAttributes() - Method in class com.netflix.fenzo.queues.QAttributes.TaskIdAttributesTuple
 
getQAttributes() - Method in interface com.netflix.fenzo.queues.QueuableTask
Get the attributes for the queue that the task belongs to.
getReason() - Method in class com.netflix.fenzo.ConstraintFailure
Returns a description of how the constraint was violated by the target.
getRequest() - Method in class com.netflix.fenzo.TaskAssignmentResult
Returns the TaskRequest corresponding to the task whose assignment result this is.
getResAllocs() - Method in class com.netflix.fenzo.TaskScheduler
Get the current mapping of resource allocations registered with the scheduler.
getResAllocsWrapper() - Method in class com.netflix.fenzo.queues.UsageTrackedQueue.ResUsage
 
getResName() - Method in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet.ConsumeResult
 
getResName() - Method in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet.PreferentialNamedConsumableResource
 
getResName() - Method in class com.netflix.fenzo.TaskRequest.NamedResourceSetRequest
 
getResource() - Method in class com.netflix.fenzo.AssignmentFailure
Returns which target resource this assignment failure is referring to.
getResourceSets() - Method in interface com.netflix.fenzo.VirtualMachineCurrentState
Get a map of resource sets of the virtual machine.
getResourceStatus() - Method in class com.netflix.fenzo.TaskScheduler
Returns the state of resources on all known hosts.
getResultMap() - Method in class com.netflix.fenzo.SchedulingResult
Get the successful task assignment result map.
getResValue() - Method in class com.netflix.fenzo.TaskRequest.NamedResourceSetRequest
 
getrSets() - Method in class com.netflix.fenzo.TaskAssignmentResult
 
getRuleName() - Method in interface com.netflix.fenzo.AutoScaleAction
Get the name of the auto scale rule that is triggering the autoscale action.
getRuleName() - Method in interface com.netflix.fenzo.AutoScaleRule
Returns the value, for the group of hosts that this rule applies to, of the host attribute that you have designated to differentiate autoscale groups.
getRuleName() - Method in class com.netflix.fenzo.ScaleDownAction
Get the name of the autoscale rule that triggered the scale down action.
getRuleName() - Method in class com.netflix.fenzo.ScaleUpAction
Returns the name of the autoscale rule that triggered the scale up action.
getRunningTasks() - Method in interface com.netflix.fenzo.VirtualMachineCurrentState
Get a list of those tasks that had already been assigned to this host before the current scheduling run started.
getRuntime() - Method in class com.netflix.fenzo.SchedulingResult
Get the time elapsed, in milliseconds, during this scheduling trial.
getScalarRequests() - Method in interface com.netflix.fenzo.TaskRequest
Get the scalar resources being requested by the task.
getScalarValue(String) - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
getScalarValue(String) - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the value of the scalar resource for the given name.
getScalarValues() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
getScalarValues() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get a map of all of the scalar resources with resource names as the key and resource value as the value.
getScaleUpCount() - Method in class com.netflix.fenzo.ScaleUpAction
Returns the number of hosts to add to the cluster during this scale up action.
getShortfallAdjustedAgents(int) - Method in interface com.netflix.fenzo.AutoScaleRule
Returns adjusted number of agents.
getSoftConstraints() - Method in interface com.netflix.fenzo.TaskRequest
Get a list of the soft constraints the task requests.
getTask() - Method in class com.netflix.fenzo.queues.Assignable
 
getTaskAssigner() - Method in class com.netflix.fenzo.TaskScheduler
Get the task assigner action.
getTaskGroupName() - Method in interface com.netflix.fenzo.sla.ResAllocs
 
getTaskId() - Method in class com.netflix.fenzo.TaskAssignmentResult
Returns the string identifier of the task request for the task whose assignment result this is.
getTaskRequest() - Method in class com.netflix.fenzo.TaskTracker.ActiveTask
Get the task request object associated with the active task.
getTasksAssigned() - Method in class com.netflix.fenzo.VMAssignmentResult
Get the set of tasks that are assigned resources from this host.
getTasksCurrentlyAssigned() - Method in interface com.netflix.fenzo.VirtualMachineCurrentState
Get list of task assignment results for this host so far in the current scheduling run.
getTaskTracker() - Method in class com.netflix.fenzo.TaskScheduler
 
getTaskUnAssigner() - Method in class com.netflix.fenzo.TaskScheduler
Get the task unassigner action.
getTierNumber() - Method in interface com.netflix.fenzo.queues.QAttributes
Get the tier number for the queue.
getTierNumber() - Method in class com.netflix.fenzo.queues.QAttributes.QAttributesAdaptor
 
getTotalLease() - Method in class com.netflix.fenzo.TaskTracker.ActiveTask
Get the totals resource offers associated with the host on which the task is active.
getTotalVMsCount() - Method in class com.netflix.fenzo.SchedulingResult
Get the total number of hosts (virtual machines) known during this scheduling trial.
getType() - Method in interface com.netflix.fenzo.AutoScaleAction
Returns an indication of whether the autoscale action is to scale up or to scale down.
getType() - Method in class com.netflix.fenzo.ScaleDownAction
Returns an indication of whether the autoscale action is to scale up or to scale down - in this case, down.
getType() - Method in class com.netflix.fenzo.ScaleUpAction
Returns an indication of whether the autoscale action is to scale up or to scale down - in this case, up.
getUsageBy() - Method in class com.netflix.fenzo.PreferentialNamedConsumableResourceSet.PreferentialNamedConsumableResource
 
getUsageTracker() - Method in interface com.netflix.fenzo.queues.InternalTaskQueue
Get the usage tracker, if any.
getUsageTracker() - Method in class com.netflix.fenzo.queues.tiered.TieredQueue
This method provides a bridge to the usage tracked queues contained within the tiered queues implementation.
getUsed() - Method in class com.netflix.fenzo.AssignmentFailure
Returns the quantity of this resource that is already assigned on the target.
getVmCurrentStates() - Method in class com.netflix.fenzo.TaskScheduler
Returns the current state of all known hosts.
getVMID() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
getVMID() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the ID of the host (mesos slave ID).

H

hasEqualResources(ResAllocs, ResAllocs) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
hasFailure() - Method in class com.netflix.fenzo.queues.Assignable
 
HostAttrValueConstraint - Class in com.netflix.fenzo.plugins
A constraint that ensures that a task gets a host with an attribute of a specified value.
HostAttrValueConstraint(String, Func1<String, String>) - Constructor for class com.netflix.fenzo.plugins.HostAttrValueConstraint
 
hostname() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
hostname() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the name of the host offered in this lease.

I

idleMachineTooSmall(VirtualMachineLease) - Method in interface com.netflix.fenzo.AutoScaleRule
Determines whether a host has too few resources to be considered an idle but potentially useful host.
initializeRunningTask(QueuableTask, String) - Method in class com.netflix.fenzo.TaskSchedulingService
Mark the given tasks as running.
InternalTaskQueue - Interface in com.netflix.fenzo.queues
This interface defines the behavior of task queues required for Fenzo internally.
InvalidTierNumberException - Exception in com.netflix.fenzo.queues
 
InvalidTierNumberException(int, int) - Constructor for exception com.netflix.fenzo.queues.InvalidTierNumberException
 
InvalidTierNumberException(int, int, Throwable) - Constructor for exception com.netflix.fenzo.queues.InvalidTierNumberException
 
isBounded(QueuableTask, ResAllocs) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
isBounded(ResAllocs, QueuableTask) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
isBounded(ResAllocs, ResAllocs) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
isShutdown() - Method in class com.netflix.fenzo.TaskSchedulingService
 
isSuccessful() - Method in class com.netflix.fenzo.ConstraintEvaluator.Result
Indicates whether the constraint evaluator found the target to satisfy the constraint.
isSuccessful() - Method in class com.netflix.fenzo.TaskAssignmentResult
Indicates whether the assignment of this task to the host succeeded.

L

launchTask(QueuableTask) - Method in interface com.netflix.fenzo.queues.UsageTrackedQueue
Mark the given task as launched.

M

main(String[]) - Static method in class com.netflix.fenzo.samples.SampleQbasedScheduling
This is the main method of this sample framework.
main(String[]) - Static method in class com.netflix.fenzo.samples.TaskGenerator
Main method to run the task generator.
memoryBinPacker - Static variable in class com.netflix.fenzo.plugins.BinPackingFitnessCalculators
A memory bin packing fitness calcualtor.
memoryMB() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
memoryMB() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the amount of memory, in MBs, on this host that is available for assigning.
MesosScheduler() - Constructor for class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
 

N

NamedResourceSetRequest(String, String, int, int) - Constructor for class com.netflix.fenzo.TaskRequest.NamedResourceSetRequest
 
networkBinPacker - Static variable in class com.netflix.fenzo.plugins.BinPackingFitnessCalculators
A network bandwidth bin packing fitness calculator.
networkMbps() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
networkMbps() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the amount of network bandwidth, in Mbps, on this host that is available for assigning.
next() - Method in class com.netflix.fenzo.queues.tiered.TieredQueue
This implementation dynamically picks the next task to consider for resource assignment based on tiers and then based on current dominant resource usage.
next() - Method in interface com.netflix.fenzo.TaskIterator
Get the next task from queue, or null if no more tasks exist.
nextTaskToLaunch() - Method in interface com.netflix.fenzo.queues.UsageTrackedQueue
Get the next task to assign resources to.

O

offerRescinded(SchedulerDriver, Protos.OfferID) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
Tell Fenzo scheduler that a resource offer should be expired immediately.

P

portRanges() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
portRanges() - Method in interface com.netflix.fenzo.VirtualMachineLease
Get the list of port ranges on this host that are available for assigning.
PreferentialNamedConsumableResourceSet - Class in com.netflix.fenzo
This encapsulates preferential resource sets available on a VM.
PreferentialNamedConsumableResourceSet(String, int, int) - Constructor for class com.netflix.fenzo.PreferentialNamedConsumableResourceSet
 
PreferentialNamedConsumableResourceSet.ConsumeResult - Class in com.netflix.fenzo
 
PreferentialNamedConsumableResourceSet.PreferentialNamedConsumableResource - Class in com.netflix.fenzo
 

Q

QAttributes - Interface in com.netflix.fenzo.queues
Attributes for a queue.
QAttributes.QAttributesAdaptor - Class in com.netflix.fenzo.queues
A convenience class for creating QAttributes instances.
QAttributes.TaskIdAttributesTuple - Class in com.netflix.fenzo.queues
A convenience class to represent the tuple of task id and QAttributes.
QAttributesAdaptor(int, String) - Constructor for class com.netflix.fenzo.queues.QAttributes.QAttributesAdaptor
 
QueuableTask - Interface in com.netflix.fenzo.queues
A queuable task extends TaskRequest with a method to get attributes for the queue.
queueTask(QueuableTask) - Method in interface com.netflix.fenzo.queues.TaskQueue
Add a task to the queue.
queueTask(QueuableTask) - Method in class com.netflix.fenzo.queues.tiered.TieredQueue
 
queueTask(QueuableTask) - Method in interface com.netflix.fenzo.queues.UsageTrackedQueue
Add the given task to the queue.

R

Range(int, int) - Constructor for class com.netflix.fenzo.VirtualMachineLease.Range
 
registered(SchedulerDriver, Protos.FrameworkID, Protos.MasterInfo) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
When we register successfully with mesos, any previous resource offers are invalid.
removeAutoScaleRule(String) - Method in class com.netflix.fenzo.TaskScheduler
Remove the autoscale rule associated with the given name from those used by the scheduler.
removeResAllocs(String) - Method in class com.netflix.fenzo.TaskScheduler
Remove a resource allocation associated with the specified name.
removeTask(String, QAttributes) - Method in interface com.netflix.fenzo.queues.UsageTrackedQueue
Remove the given task from the queue, irrespective of whether it is queued or launched.
removeTask(String, QAttributes, String) - Method in class com.netflix.fenzo.TaskSchedulingService
Mark the task to be removed.
remUsage(QueuableTask) - Method in class com.netflix.fenzo.queues.UsageTrackedQueue.ResUsage
 
rename(String, ResAllocs) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
requestAllTasks(Action1<Map<TaskQueue.TaskState, Collection<QueuableTask>>>) - Method in class com.netflix.fenzo.TaskSchedulingService
Get all of the tasks in the scheduling service's queue and call the given action when it is available.
requestResourceStatus(Action1<Map<String, Map<VMResource, Double[]>>>) - Method in class com.netflix.fenzo.TaskSchedulingService
Get resource status information and call the given action when available.
requestVmCurrentStates(Action1<List<VirtualMachineCurrentState>>) - Method in class com.netflix.fenzo.TaskSchedulingService
Get the current states of all known VMs and call the given action when available.
reregistered(SchedulerDriver, Protos.MasterInfo) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
Similar to registered() method, expire any previously known resource offers by asking Fenzo scheduler to expire all leases right away.
ResAllocs - Interface in com.netflix.fenzo.sla
Interface that represents resource allocation limits for a task group.
ResAllocsBuilder - Class in com.netflix.fenzo.sla
Builder class for ResAllocs.
ResAllocsBuilder(String) - Constructor for class com.netflix.fenzo.sla.ResAllocsBuilder
 
ResAllocsUtil - Class in com.netflix.fenzo.sla
Collection of helper functions for ResAllocs data type.
ResAllocsUtil() - Constructor for class com.netflix.fenzo.sla.ResAllocsUtil
 
reset() - Method in interface com.netflix.fenzo.queues.InternalTaskQueue
Reset the queue and make it ready for next scheduling iteration.
reset() - Method in class com.netflix.fenzo.queues.tiered.TieredQueue
 
reset() - Method in interface com.netflix.fenzo.queues.UsageTrackedQueue
Reset the queue to mark the end of a scheduling iteration.
resourceOffers(SchedulerDriver, List<Protos.Offer>) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
Add the received Mesos resource offers to the lease queue.
Result(boolean, String) - Constructor for class com.netflix.fenzo.ConstraintEvaluator.Result
 
ResUsage() - Constructor for class com.netflix.fenzo.queues.UsageTrackedQueue.ResUsage
 
run() - Method in class com.netflix.fenzo.samples.TaskGenerator
 

S

SampleFramework - Class in com.netflix.fenzo.samples
A sample Mesos framework that shows a sample usage of Fenzo TaskScheduler.
SampleFramework(BlockingQueue<TaskRequest>, String, Action1<String>, Func1<String, String>) - Constructor for class com.netflix.fenzo.samples.SampleFramework
Create a sample mesos framework with the given task queue and mesos master connection string.
SampleFramework.MesosScheduler - Class in com.netflix.fenzo.samples
A sample mesos scheduler that shows how mesos callbacks can be setup for use with Fenzo TaskScheduler.
SampleQbasedScheduling - Class in com.netflix.fenzo.samples
 
SampleQbasedScheduling() - Constructor for class com.netflix.fenzo.samples.SampleQbasedScheduling
 
ScaleDownAction - Class in com.netflix.fenzo
An autoscale action that indicates an autoscale group is to be scaled down.
ScaleUpAction - Class in com.netflix.fenzo
An autoscale action indicating that the autoscale group is to be scaled up.
scheduleOnce(List<? extends TaskRequest>, List<VirtualMachineLease>) - Method in class com.netflix.fenzo.TaskScheduler
Schedule a list of task requests by using any newly-added resource leases in addition to any previously-unused leases.
SchedulingResult - Class in com.netflix.fenzo
The result of a scheduling trial, as returned by scheduleOnce().
SchedulingResult(Map<String, VMAssignmentResult>) - Constructor for class com.netflix.fenzo.SchedulingResult
 
setActiveVmGroupAttributeName(String) - Method in class com.netflix.fenzo.TaskScheduler
Set how the scheduler determines to which group the VM (host) belongs.
setActiveVmGroups(List<String>) - Method in class com.netflix.fenzo.TaskScheduler
Set the list of VM group names that are active.
setAssignedResources(TaskRequest.AssignedResources) - Method in interface com.netflix.fenzo.TaskRequest
 
setAutoscalerCallback(Action1<AutoScaleAction>) - Method in class com.netflix.fenzo.TaskScheduler
Set the autoscale call back action.
setConsumedNamedResources(List<PreferentialNamedConsumableResourceSet.ConsumeResult>) - Method in class com.netflix.fenzo.TaskRequest.AssignedResources
 
setSla(TaskQueueSla) - Method in interface com.netflix.fenzo.queues.TaskQueue
Set SLA for the queue.
setSla(TaskQueueSla) - Method in class com.netflix.fenzo.queues.tiered.TieredQueue
 
setTaskToClusterAutoScalerMapGetter(Func1<QueuableTask, List<String>>) - Method in class com.netflix.fenzo.TaskSchedulingService
Set the getter function that maps a given queuable task object to a list of names of VM groups for which cluster autoscaling rules have been set.
setTotalResources(Map<VMResource, Double>) - Method in interface com.netflix.fenzo.queues.UsageTrackedQueue
Set the map of total resources available.
setUsageTrackedQueue(UsageTrackedQueue) - Method in class com.netflix.fenzo.TaskTracker
 
shutdown() - Method in class com.netflix.fenzo.samples.SampleFramework
Shuts down the Mesos driver.
shutdown() - Method in class com.netflix.fenzo.TaskScheduler
Mark task scheduler as shutdown and shutdown any thread pool executors created.
shutdown() - Method in class com.netflix.fenzo.TaskSchedulingService
Mark this scheduler as shutdown and prevent any further scheduling iterations from starting.
slaveLost(SchedulerDriver, Protos.SlaveID) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
Upon slave lost notification, tell Fenzo scheduler to expire all leases with the given slave ID.
start() - Method in class com.netflix.fenzo.samples.SampleFramework
 
start() - Method in class com.netflix.fenzo.TaskSchedulingService
Start this scheduling service.
statusUpdate(SchedulerDriver, Protos.TaskStatus) - Method in class com.netflix.fenzo.samples.SampleFramework.MesosScheduler
Update Fenzo scheduler of task completion if received status indicates a terminal state.
subtract(ResAllocs, ResAllocs) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
success(T) - Static method in class com.netflix.fenzo.queues.Assignable
 

T

TaskAssignmentResult - Class in com.netflix.fenzo
Encapsulates the results of attempting to assign a task to a host.
TaskGenerator - Class in com.netflix.fenzo.samples
A simple task generator to use with SampleFramework.
TaskGenerator(BlockingQueue<TaskRequest>, int, int) - Constructor for class com.netflix.fenzo.samples.TaskGenerator
 
taskGroupName() - Method in interface com.netflix.fenzo.TaskRequest
Get the name of the task group that this task request belongs to.
TaskIdAttributesTuple(String, QAttributes) - Constructor for class com.netflix.fenzo.queues.QAttributes.TaskIdAttributesTuple
 
TaskIterator - Interface in com.netflix.fenzo
 
TaskQueue - Interface in com.netflix.fenzo.queues
This interface defines a task queue that contains all tasks that are either pending resource allocation or assigned resources while continuing to run.
TaskQueue.TaskState - Enum in com.netflix.fenzo.queues
Tasks in a queue are said to be in one of two states.
TaskQueueException - Exception in com.netflix.fenzo.queues
 
TaskQueueException(String) - Constructor for exception com.netflix.fenzo.queues.TaskQueueException
 
TaskQueueException(String, Throwable) - Constructor for exception com.netflix.fenzo.queues.TaskQueueException
 
TaskQueueException(Exception) - Constructor for exception com.netflix.fenzo.queues.TaskQueueException
 
TaskQueueMultiException - Exception in com.netflix.fenzo.queues
An exception that wraps multiple exceptions caught during a scheduling iteration of the queue, to be returned at the end of scheduling iteration.
TaskQueueMultiException(List<Exception>) - Constructor for exception com.netflix.fenzo.queues.TaskQueueMultiException
 
TaskQueues - Class in com.netflix.fenzo.queues
A class to create instances of various TaskQueue implementations.
TaskQueues() - Constructor for class com.netflix.fenzo.queues.TaskQueues
 
TaskQueueSla - Interface in com.netflix.fenzo.queues
 
TaskRequest - Interface in com.netflix.fenzo
Describes a task to be assigned to a host and its requirements.
TaskRequest.AssignedResources - Class in com.netflix.fenzo
 
TaskRequest.NamedResourceSetRequest - Class in com.netflix.fenzo
 
TaskScheduler - Class in com.netflix.fenzo
A scheduling service that you can use to optimize the assignment of tasks to hosts within a Mesos framework.
TaskScheduler.Builder - Class in com.netflix.fenzo
The Builder is how you construct a TaskScheduler object with particular characteristics.
TaskSchedulingService - Class in com.netflix.fenzo
A task scheduling service that maintains a scheduling loop to continuously assign resources to tasks pending in the queue.
TaskSchedulingService.Builder - Class in com.netflix.fenzo
 
TaskTracker - Class in com.netflix.fenzo
Class to keep track of task assignments.
TaskTracker.ActiveTask - Class in com.netflix.fenzo
An active task in the scheduler.
TaskTrackerState - Interface in com.netflix.fenzo
The state of the tasks that are tracked by the task scheduler.
TieredQueue - Class in com.netflix.fenzo.queues.tiered
A tiered queuing system where queues are arranged in multiple tiers and then among multiple buckets within each tier.
TieredQueue(int) - Constructor for class com.netflix.fenzo.queues.tiered.TieredQueue
Construct a tiered queue system with the given number of tiers.
TieredQueueSlas - Class in com.netflix.fenzo.queues.tiered
 
TieredQueueSlas(Map<Integer, ResAllocs>, Map<Integer, Map<String, ResAllocs>>) - Constructor for class com.netflix.fenzo.queues.tiered.TieredQueueSlas
 
toResAllocs(String, Map<VMResource, Double>) - Static method in class com.netflix.fenzo.sla.ResAllocsUtil
 
toString() - Method in class com.netflix.fenzo.AssignmentFailure
Returns a String representation of this assignment failure, with details about the resource that caused the failure and its current level of allocation and availability on the target.
toString() - Method in class com.netflix.fenzo.ConstraintFailure
Returns a textual description of the constraint failure that combines the name of the constraint and the reason why it was violated by the target.
toString() - Method in class com.netflix.fenzo.plugins.VMLeaseObject
 
toString() - Method in class com.netflix.fenzo.SchedulingResult
 
toString() - Method in class com.netflix.fenzo.TaskAssignmentResult
 
toString() - Method in class com.netflix.fenzo.VMAssignmentResult
 

U

UniqueHostAttrConstraint - Class in com.netflix.fenzo.plugins
A unique constraint evaluator that constrains tasks according to a given host attribute.
UniqueHostAttrConstraint(Func1<String, Set<String>>) - Constructor for class com.netflix.fenzo.plugins.UniqueHostAttrConstraint
Create this constraint evaluator with the given co-tasks of a group.
UniqueHostAttrConstraint(Func1<String, Set<String>>, String) - Constructor for class com.netflix.fenzo.plugins.UniqueHostAttrConstraint
Create this constraint evaluator with the given co-tasks of a group and a given host attribute name.
UsageTrackedQueue - Interface in com.netflix.fenzo.queues
This interface represents a queue entity whose usage is tracked.
UsageTrackedQueue.ResUsage - Class in com.netflix.fenzo.queues
 

V

valueOf(String) - Static method in enum com.netflix.fenzo.AutoScaleAction.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.netflix.fenzo.queues.TaskQueue.TaskState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.netflix.fenzo.VMResource
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.netflix.fenzo.AutoScaleAction.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.netflix.fenzo.queues.TaskQueue.TaskState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.netflix.fenzo.VMResource
Returns an array containing the constants of this enum type, in the order they are declared.
VirtualMachineCurrentState - Interface in com.netflix.fenzo
Represents the current state of the host (virtual machine) that Fenzo is considering for a task assignment.
VirtualMachineLease - Interface in com.netflix.fenzo
A representation of a lease (resource offer).
VirtualMachineLease.Range - Class in com.netflix.fenzo
Describes a [beginning, end] range.
VMAssignmentResult - Class in com.netflix.fenzo
Result of resource assignments for a host (VM).
VMAssignmentResult(String, List<VirtualMachineLease>, Set<TaskAssignmentResult>) - Constructor for class com.netflix.fenzo.VMAssignmentResult
 
VMLeaseObject - Class in com.netflix.fenzo.plugins
An adapter class to transform a Mesos resource offer to a Fenzo VirtualMachineLease.
VMLeaseObject(Protos.Offer) - Constructor for class com.netflix.fenzo.plugins.VMLeaseObject
 
VMResource - Enum in com.netflix.fenzo
Enumeration of resources avaialble on hosts (VMs)
VMTaskFitnessCalculator - Interface in com.netflix.fenzo
Interface representing a task fitness calculator, or scheduling optimization plugin.

W

withAutoScaleByAttributeName(String) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Call this method to indicate which host attribute you want your task scheduler to use in order to distinguish which hosts are in which autoscaling groups.
withAutoScaleDownBalancedByAttributeName(String) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Call this method to tell the autoscaler to try to maintain a balance of host varieties when it scales down a cluster.
withAutoScalerCallback(Action1<AutoScaleAction>) - Method in class com.netflix.fenzo.TaskScheduler.Builder
 
withAutoScalerMapHostnameAttributeName(String) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Use the given host attribute name to determine the alternate hostname of virtual machine to use as an argument for an autoscaling action.
withAutoScaleRule(AutoScaleRule) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Adds an autoscaling rule that governs the behavior by which this scheduler will autoscale hosts of a certain type.
withCores(double) - Method in class com.netflix.fenzo.sla.ResAllocsBuilder
Limits the number of cores the task group can use to the number you pass in to this method.
withDelayAutoscaleDownBySecs(long) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Delay the autoscale down actions to reduce unnecessary actions due to short periods of breach of scale down policy rules.
withDelayAutoscaleUpBySecs(long) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Delay the autoscale up actions to reduce unnecessary actions due to short periods of breach of scale up policy rules.
withDisk(double) - Method in class com.netflix.fenzo.sla.ResAllocsBuilder
Limits the amount of disk space the task group can use to the number of MB you pass in to this method.
withFitnessCalculator(VMTaskFitnessCalculator) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Call this method to add a fitness calculator that your scheduler will use to compute the suitability of a particular host for a particular task.
withFitnessGoodEnoughFunction(Func1<Double, Boolean>) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Use the given function to determine if the fitness of a host for a task is good enough that the task scheduler should stop looking for a more fit host.
withInitialResAllocs(Map<String, ResAllocs>) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Call this method to set the initial limitations on how many resources will be available to each task group.
withLeaseOfferExpirySecs(long) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Call this method to set the expiration time for resource offers.
withLeaseRejectAction(Action1<VirtualMachineLease>) - Method in class com.netflix.fenzo.TaskScheduler.Builder
(Required) Call this method to establish a method that your task scheduler will call to notify you that it has rejected a resource offer.
withLoopIntervalMillis(long) - Method in class com.netflix.fenzo.TaskSchedulingService.Builder
Use the given milli seconds as minimum delay between two consecutive scheduling iterations.
withMaxDelayMillis(long) - Method in class com.netflix.fenzo.TaskSchedulingService.Builder
Use the given milli seconds as the maximum delay between two consecutive scheduling iterations.
withMaxOffersToReject(int) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Call this method to set the maximum number of offers to reject within a time period equal to lease expiry seconds, set with leaseOfferExpirySecs().
withMemory(double) - Method in class com.netflix.fenzo.sla.ResAllocsBuilder
Limits the amount of memory the task group can use to the number of MB you pass in to this method.
withNetworkMbps(double) - Method in class com.netflix.fenzo.sla.ResAllocsBuilder
Limits the amount of bandwidth the task group can use to the number of megabits per second you pass in to this method.
withPreSchedulingLoopHook(Action0) - Method in class com.netflix.fenzo.TaskSchedulingService.Builder
Use the given action to call before starting a new scheduling iteration.
withRejectAllExpiredOffers() - Method in class com.netflix.fenzo.TaskScheduler.Builder
Indicate that all offers older than the set expiry time must be rejected.
withSchedulingResultCallback(Action1<SchedulingResult>) - Method in class com.netflix.fenzo.TaskSchedulingService.Builder
Use the given callback to give scheduling results to at the end of each scheduling iteration.
withSingleOfferPerVM(boolean) - Method in class com.netflix.fenzo.TaskScheduler.Builder
Indicate that the cluster receives resource offers only once per VM (host).
withTaskQuue(TaskQueue) - Method in class com.netflix.fenzo.TaskSchedulingService.Builder
Use the given instance of TaskQueue from which to get tasks to assign resource to.
withTaskScheduler(TaskScheduler) - Method in class com.netflix.fenzo.TaskSchedulingService.Builder
Use the given instance of TaskScheduler for scheduling resources.
A B C D E F G H I L M N O P Q R S T U V W 
Skip navigation links