org.springframework.cloud.fn.tasklauncher

Class TaskLauncherFunction

java.lang.Object

org.springframework.cloud.fn.tasklauncher.TaskLauncherFunction

All Implemented Interfaces:

Function<LaunchRequest,Optional<Long>>, org.springframework.beans.factory.InitializingBean

public class TaskLauncherFunction
extends Object
implements Function<LaunchRequest,Optional<Long>>, org.springframework.beans.factory.InitializingBean

A Function that submits a task LaunchRequest to a Data Flow server. This will check if the Data Flow task platform is at capacity. If not, will submit the task launch request, otherwise it will return and log a warning message.

Author:

David Turanski

Constructor Summary

Constructors

Constructor and Description
TaskLauncherFunction(org.springframework.cloud.dataflow.rest.client.TaskOperations taskOperations)

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
Optional<Long>	apply(LaunchRequest launchRequest)
boolean	platformIsAcceptingNewTasks()
void	setPlatformName(String platformName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

TaskLauncherFunction

public TaskLauncherFunction(org.springframework.cloud.dataflow.rest.client.TaskOperations taskOperations)

Method Detail

apply

public Optional<Long> apply(LaunchRequest launchRequest)

Specified by:

apply in interface Function<LaunchRequest,Optional<Long>>

Parameters:

launchRequest - the task launch request for the Data Flow server.

Returns:

an Optional<Long> containing the task Id if the request is accepted or empty otherwise.

platformIsAcceptingNewTasks

public boolean platformIsAcceptingNewTasks()

setPlatformName

public void setPlatformName(String platformName)

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean