io.picodata.driver.core

Class RequestFutureManager

java.lang.Object

io.picodata.driver.core.RequestFutureManager

All Implemented Interfaces:

AutoCloseable

public class RequestFutureManager
extends Object
implements AutoCloseable

Keeps track of submitted requests, finishing them by timeout and allowing asynchronous request processing

Constructor Summary

Constructors

Constructor and Description
RequestFutureManager(TarantoolClientConfig config, ScheduledExecutorService timeoutScheduler) Basic constructor.

Method Summary

Modifier and Type	Method and Description
void	close()
TarantoolRequestMetadata	getRequest(Long requestId) Get a request me instance bound to the passed request ID
TarantoolRequestMetadata	submitRequest(TarantoolRequest request) Submit a request ID for tracking.
TarantoolRequestMetadata	submitRequest(TarantoolRequest request, int requestTimeout) Submit a request ID for tracking.

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestFutureManager

public RequestFutureManager(TarantoolClientConfig config,
                            ScheduledExecutorService timeoutScheduler)

Basic constructor.

Parameters:

config - tarantool client configuration

timeoutScheduler - scheduled executor for handling request timeouts

Method Detail

submitRequest

public TarantoolRequestMetadata submitRequest(TarantoolRequest request)

Submit a request ID for tracking. Provides a CompletableFuture for tracking the request completion. The request timeout is taken from the client configuration

Parameters:

request - request to Tarantool server

Returns:

TarantoolRequestMetadata metadata holder with request future that completes when a response is received from Tarantool server or request timeout is expired

submitRequest

public TarantoolRequestMetadata submitRequest(TarantoolRequest request,
                                              int requestTimeout)

Submit a request ID for tracking. Provides a CompletableFuture for tracking the request completion. The request timeout is taken from the client configuration

Parameters:

request - request to Tarantool server

requestTimeout - timeout after which the request will be automatically failed, milliseconds

Returns:

TarantoolRequestMetadata metadata holder with request future that completes when a response is received from Tarantool server or request timeout is expired

getRequest

public TarantoolRequestMetadata getRequest(Long requestId)

Get a request me instance bound to the passed request ID

Parameters:

requestId - ID of a request to Tarantool server (sync ID)

Returns:

CompletableFuture that completes when a response is received from Tarantool server

close

public void close()

Specified by:

close in interface AutoCloseable