io.micronaut.function.client.http

Class HttpFunctionExecutor<I,O>

java.lang.Object

io.micronaut.function.client.http.HttpFunctionExecutor<I,O>

Type Parameters:

I - input type

O - output type

All Implemented Interfaces:

FunctionInvoker<I,O>, FunctionInvokerChooser, Closeable, AutoCloseable

@Singleton
public class HttpFunctionExecutor<I,O>
extends Object
implements FunctionInvoker<I,O>, Closeable, FunctionInvokerChooser

A FunctionExecutor that uses a HttpClient to execute a remote function definition.

Since:

1.0

Author:

graemerocher

Constructor Summary

Constructors

Constructor and Description
HttpFunctionExecutor(HttpClientConfiguration configuration, ThreadFactory threadFactory, NettyClientSslBuilder nettyClientSslBuilder, MediaTypeCodecRegistry codecRegistry, AnnotationMetadataResolver annotationMetadataResolver, HttpClientFilter... filters) Constructor.

Method Summary

Modifier and Type	Method and Description
<I1,O2> Optional<FunctionInvoker<I1,O2>>	choose(FunctionDefinition definition) Chooses a FunctionInvoker.
void	close()
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

HttpFunctionExecutor

public HttpFunctionExecutor(HttpClientConfiguration configuration,
                            @Named(value="netty")
                            ThreadFactory threadFactory,
                            NettyClientSslBuilder nettyClientSslBuilder,
                            MediaTypeCodecRegistry codecRegistry,
                            AnnotationMetadataResolver annotationMetadataResolver,
                            HttpClientFilter... filters)

Constructor.

Parameters:

configuration - configuration

threadFactory - threadFactory

nettyClientSslBuilder - nettyClientSslBuilder

codecRegistry - codecRegistry

annotationMetadataResolver - annotationMetadataResolver

filters - filters

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

close

@PreDestroy
public void close()
                       throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException