org.springframework.cloud.function.deployer

Class FunctionExtractingFunctionCatalog

java.lang.Object

org.springframework.cloud.function.deployer.FunctionExtractingFunctionCatalog

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, FunctionInspector, org.springframework.cloud.function.core.FunctionCatalog

public class FunctionExtractingFunctionCatalog
extends Object
implements org.springframework.cloud.function.core.FunctionCatalog, FunctionInspector, org.springframework.beans.factory.DisposableBean

Constructor Summary

Constructors

Constructor and Description
FunctionExtractingFunctionCatalog()
FunctionExtractingFunctionCatalog(String name, String... profiles)

Method Summary

Modifier and Type	Method and Description
Object	convert(Object function, String value)
String	deploy(String name, String path, String... args)
Map<String,Object>	deployed()
void	destroy()
Set<String>	getConsumerNames()
Set<String>	getFunctionNames()
Class<?>	getInputType(Object function)
Class<?>	getInputWrapper(Object function)
String	getName(Object function)
Class<?>	getOutputType(Object function)
Class<?>	getOutputWrapper(Object function)
Set<String>	getSupplierNames()
boolean	isMessage(Object function)
<T> Consumer<T>	lookupConsumer(String name)
<T,R> Function<T,R>	lookupFunction(String name)
<T> Supplier<T>	lookupSupplier(String name)
org.springframework.cloud.function.deployer.DeployedArtifact	undeploy(String name)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.cloud.function.context.FunctionInspector

isWrapper

Constructor Detail

FunctionExtractingFunctionCatalog

public FunctionExtractingFunctionCatalog()

FunctionExtractingFunctionCatalog

public FunctionExtractingFunctionCatalog(String name,
                                         String... profiles)

Method Detail

destroy

public void destroy()
             throws Exception

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Throws:

Exception

lookupConsumer

public <T> Consumer<T> lookupConsumer(String name)

Specified by:

lookupConsumer in interface org.springframework.cloud.function.core.FunctionCatalog

lookupFunction

public <T,R> Function<T,R> lookupFunction(String name)

Specified by:

lookupFunction in interface org.springframework.cloud.function.core.FunctionCatalog

lookupSupplier

public <T> Supplier<T> lookupSupplier(String name)

Specified by:

lookupSupplier in interface org.springframework.cloud.function.core.FunctionCatalog

getSupplierNames

public Set<String> getSupplierNames()

Specified by:

getSupplierNames in interface org.springframework.cloud.function.core.FunctionCatalog

getFunctionNames

public Set<String> getFunctionNames()

Specified by:

getFunctionNames in interface org.springframework.cloud.function.core.FunctionCatalog

getConsumerNames

public Set<String> getConsumerNames()

Specified by:

getConsumerNames in interface org.springframework.cloud.function.core.FunctionCatalog

isMessage

public boolean isMessage(Object function)

Specified by:

isMessage in interface FunctionInspector

getInputType

public Class<?> getInputType(Object function)

Specified by:

getInputType in interface FunctionInspector

getOutputType

public Class<?> getOutputType(Object function)

Specified by:

getOutputType in interface FunctionInspector

getInputWrapper

public Class<?> getInputWrapper(Object function)

Specified by:

getInputWrapper in interface FunctionInspector

getOutputWrapper

public Class<?> getOutputWrapper(Object function)

Specified by:

getOutputWrapper in interface FunctionInspector

convert

public Object convert(Object function,
                      String value)

Specified by:

convert in interface FunctionInspector

getName

public String getName(Object function)

Specified by:

getName in interface FunctionInspector

deploy

public String deploy(String name,
                     String path,
                     String... args)

undeploy

public org.springframework.cloud.function.deployer.DeployedArtifact undeploy(String name)

deployed

public Map<String,Object> deployed()