Package io.micronaut.function.client.aws.v2

Class AwsLambdaFunctionExecutor<I,O>

java.lang.Object

io.micronaut.function.client.aws.v2.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=software.amazon.awssdk.services.lambda.LambdaAsyncClient.class)
@Singleton
@Internal
public class AwsLambdaFunctionExecutor<I,O>
extends 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	Description
protected	AwsLambdaFunctionExecutor(software.amazon.awssdk.services.lambda.LambdaClient syncClient, software.amazon.awssdk.services.lambda.LambdaAsyncClient asyncClient, io.micronaut.core.io.buffer.ByteBufferFactory<?,?> byteBufferFactory, io.micronaut.json.codec.JsonMediaTypeCodec mediaTypeCodec, ExecutorService executor, io.micronaut.core.convert.ConversionService conversionService)	Constructor.

Method Summary

Modifier and Type	Method	Description
<I1, O2> 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 Details

AwsLambdaFunctionExecutor

protected AwsLambdaFunctionExecutor(software.amazon.awssdk.services.lambda.LambdaClient syncClient,
 software.amazon.awssdk.services.lambda.LambdaAsyncClient asyncClient,
 io.micronaut.core.io.buffer.ByteBufferFactory<?,?> byteBufferFactory,
 io.micronaut.json.codec.JsonMediaTypeCodec mediaTypeCodec,
 @Named("blocking")
 ExecutorService executor,
 io.micronaut.core.convert.ConversionService conversionService)

Constructor.

Parameters:

syncClient - Lambda Sync Client

asyncClient - Lambda Async Client

byteBufferFactory - byteBufferFactory

mediaTypeCodec - JsonMediaTypeCodec

executor - blocking executor

conversionService - ConversionService

Method Details

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>
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