org.apache.flink.statefun.flink.datastream

Class AsyncRequestReplyFunctionBuilder

java.lang.Object

org.apache.flink.statefun.flink.datastream.StatefulFunctionBuilder

org.apache.flink.statefun.flink.datastream.AsyncRequestReplyFunctionBuilder

public class AsyncRequestReplyFunctionBuilder
extends StatefulFunctionBuilder

A builder for async RequestReply remote function type.

Method Summary

Modifier and Type	Method and Description
AsyncRequestReplyFunctionBuilder	withConnectionPoolMaxSize(int size) The maximum connection pool size.
AsyncRequestReplyFunctionBuilder	withConnectTimeout(java.time.Duration duration) Set a timeout for connecting to function endpoints.
AsyncRequestReplyFunctionBuilder	withMaxNumBatchRequests(int maxNumBatchRequests) Sets the max messages to batch together for a specific address.
AsyncRequestReplyFunctionBuilder	withMaxRequestDuration(java.time.Duration duration) Set a maximum request duration.
AsyncRequestReplyFunctionBuilder	withMaxRequestOrResponseSizeInBytes(int maxSizeInBytes) The maximum size for a request or response payload.
AsyncRequestReplyFunctionBuilder	withPooledConnectionTTL(java.time.Duration duration) The amount of time a connection will live in the connection pool.

Methods inherited from class org.apache.flink.statefun.flink.datastream.StatefulFunctionBuilder

asyncRequestReplyFunctionBuilder, requestReplyFunctionBuilder

Methods inherited from class java.lang.Object

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

Method Detail

withMaxRequestDuration

public AsyncRequestReplyFunctionBuilder withMaxRequestDuration(java.time.Duration duration)

Set a maximum request duration. This duration spans the complete call, including connecting to the function endpoint, writing the request, function processing, and reading the response.

Parameters:

duration - the duration after which the request is considered failed.

Returns:

this builder.

withConnectTimeout

public AsyncRequestReplyFunctionBuilder withConnectTimeout(java.time.Duration duration)

Set a timeout for connecting to function endpoints.

Parameters:

duration - the duration after which a connect attempt is considered failed.

Returns:

this builder.

withPooledConnectionTTL

public AsyncRequestReplyFunctionBuilder withPooledConnectionTTL(java.time.Duration duration)

The amount of time a connection will live in the connection pool. Set to zero to disable, the connection will be evicted from the pool after that time.

Parameters:

duration - the duration after which a connection will be evicted from the pool.

Returns:

this builder.

withConnectionPoolMaxSize

public AsyncRequestReplyFunctionBuilder withConnectionPoolMaxSize(int size)

The maximum connection pool size.

Parameters:

size - the max size of the connection pool.

Returns:

this builder.

withMaxRequestOrResponseSizeInBytes

public AsyncRequestReplyFunctionBuilder withMaxRequestOrResponseSizeInBytes(int maxSizeInBytes)

The maximum size for a request or response payload.

Parameters:

maxSizeInBytes - the max size of the request or response payload.

Returns:

this builder.

withMaxNumBatchRequests

public AsyncRequestReplyFunctionBuilder withMaxNumBatchRequests(int maxNumBatchRequests)

Sets the max messages to batch together for a specific address.

Parameters:

maxNumBatchRequests - the maximum number of requests to batch for an address.

Returns:

this builder.