I
- input typeO
- output type@Requires(beans=com.amazonaws.services.lambda.AWSLambdaAsync.class)
@Singleton
public class AWSLambdaFunctionExecutor<I,O>
extends java.lang.Object
implements io.micronaut.function.client.FunctionInvoker<I,O>, io.micronaut.function.client.FunctionInvokerChooser
FunctionInvoker
for invoking functions on AWS.Modifier | Constructor and Description |
---|---|
protected |
AWSLambdaFunctionExecutor(com.amazonaws.services.lambda.AWSLambdaAsync asyncClient,
io.micronaut.core.io.buffer.ByteBufferFactory byteBufferFactory,
io.micronaut.jackson.codec.JsonMediaTypeCodec jsonMediaTypeCodec,
java.util.concurrent.ExecutorService ioExecutor)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
<I1,O2> java.util.Optional<io.micronaut.function.client.FunctionInvoker<I1,O2>> |
choose(io.micronaut.function.client.FunctionDefinition definition) |
O |
invoke(io.micronaut.function.client.FunctionDefinition definition,
I input,
io.micronaut.core.type.Argument<O> outputType) |
protected AWSLambdaFunctionExecutor(com.amazonaws.services.lambda.AWSLambdaAsync asyncClient, io.micronaut.core.io.buffer.ByteBufferFactory byteBufferFactory, io.micronaut.jackson.codec.JsonMediaTypeCodec jsonMediaTypeCodec, @Named(value="io") java.util.concurrent.ExecutorService ioExecutor)
asyncClient
- asyncClientbyteBufferFactory
- byteBufferFactoryjsonMediaTypeCodec
- jsonMediaTypeCodecioExecutor
- ioExecutorpublic O invoke(io.micronaut.function.client.FunctionDefinition definition, I input, io.micronaut.core.type.Argument<O> outputType)
public <I1,O2> java.util.Optional<io.micronaut.function.client.FunctionInvoker<I1,O2>> choose(io.micronaut.function.client.FunctionDefinition definition)
choose
in interface io.micronaut.function.client.FunctionInvokerChooser