io.micronaut.function.client.aws

Class AWSLambdaFunctionExecutor<I,O>

java.lang.Object

io.micronaut.function.client.aws.AWSLambdaFunctionExecutor<I,O>

Type Parameters:

I - input type

O - output type

All Implemented Interfaces:

io.micronaut.function.client.FunctionInvoker<I,O>, io.micronaut.function.client.FunctionInvokerChooser

@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

A FunctionInvoker for invoking functions on AWS.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

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.

Method Summary

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)

Methods inherited from class java.lang.Object

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

Constructor Detail

AWSLambdaFunctionExecutor

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)

Constructor.

Parameters:

asyncClient - asyncClient

byteBufferFactory - byteBufferFactory

jsonMediaTypeCodec - jsonMediaTypeCodec

ioExecutor - ioExecutor

Method Detail

invoke

public O invoke(io.micronaut.function.client.FunctionDefinition definition,
                I input,
                io.micronaut.core.type.Argument<O> outputType)

Specified by:

invoke in interface io.micronaut.function.client.FunctionInvoker<I,O>

choose

public <I1,O2> java.util.Optional<io.micronaut.function.client.FunctionInvoker<I1,O2>> choose(io.micronaut.function.client.FunctionDefinition definition)

Specified by:

choose in interface io.micronaut.function.client.FunctionInvokerChooser