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:

FunctionInvoker<I,O>, FunctionInvokerChooser

@Requires(beans=com.amazonaws.services.lambda.AWSLambdaAsync.class)
 @Singleton
public class AWSLambdaFunctionExecutor<I,O>
extends Object
implements FunctionInvoker<I,O>, 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, ByteBufferFactory byteBufferFactory, JsonMediaTypeCodec jsonMediaTypeCodec, ExecutorService ioExecutor) Constructor.

Method Summary

Modifier and Type	Method and Description
<I1,O2> Optional<FunctionInvoker<I1,O2>>	choose(FunctionDefinition definition) Chooses a FunctionInvoker.
O	invoke(FunctionDefinition definition, I input, Argument<O> outputType) Invoke the given function definition for the given input and expected response type.

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,
                                    ByteBufferFactory byteBufferFactory,
                                    JsonMediaTypeCodec jsonMediaTypeCodec,
                                    @Named(value="io")
                                    ExecutorService ioExecutor)

Constructor.

Parameters:

asyncClient - asyncClient

byteBufferFactory - byteBufferFactory

jsonMediaTypeCodec - jsonMediaTypeCodec

ioExecutor - ioExecutor

Method Detail

invoke

public O invoke(FunctionDefinition definition,
                I input,
                Argument<O> outputType)

Description copied from interface: FunctionInvoker

Invoke the given function definition for the given input and expected response type.

Specified by:

invoke in interface FunctionInvoker<I,O>

Parameters:

definition - The definition

input - The input

outputType - The response type

Returns:

The result

choose

public <I1,O2> Optional<FunctionInvoker<I1,O2>> choose(FunctionDefinition definition)

Description copied from interface: FunctionInvokerChooser

Chooses a FunctionInvoker.

Specified by:

choose in interface FunctionInvokerChooser

Type Parameters:

I1 - input type

O2 - output type

Parameters:

definition - The definition

Returns:

An Optional instance of FunctionInvoker