Package io.streamthoughts.azkarra.http.query

Class RestApiQueryCall<K,V>

java.lang.Object

io.streamthoughts.azkarra.api.query.DecorateQuery<QueryRequest>

io.streamthoughts.azkarra.http.query.RestApiQueryCall<K,V>

Type Parameters:

K - the expected type for the record key.

V - the expected type for the record value.

All Implemented Interfaces:

Query, QueryCall<K,V>

public class RestApiQueryCall<K,V>
extends DecorateQuery<QueryRequest>
implements QueryCall<K,V>

A RestApiQueryCall can be used to execute an interactive query on a remote instance.

Nested Class Summary

Nested classes/interfaces inherited from interface io.streamthoughts.azkarra.api.query.QueryCall

QueryCall.QueryCallFactory

Field Summary

Fields inherited from class io.streamthoughts.azkarra.api.query.DecorateQuery

query

Constructor Summary

Constructors

Constructor	Description
RestApiQueryCall(String applicationId, Endpoint localEndpoint, Endpoint remoteEndpoint, AzkarraV1Api api, QueryRequest request)	Creates a new RestApiQueryCall instance.

Method Summary

Modifier and Type	Method	Description
void	cancel()	Cancels the QueryCall, if possible.
QueryResult<K,V>	execute(QueryOptions options)	Executes this QueryCall.
CompletableFuture<QueryResult<K,V>>	executeAsync(QueryOptions options)	Executes this QueryCall asynchronously.
void	executeAsync(QueryOptions options, Consumer<QueryResult<K,V>> resultCallback)	Executes this QueryCall asynchronously.
boolean	isCanceled()
boolean	isExecuted()
QueryCall<K,V>	renew()	Create a new, identical QueryCall to this one which can be re-executed even if this call has already been.

Methods inherited from class io.streamthoughts.azkarra.api.query.DecorateQuery

equals, getParams, getStoreName, getStoreOperation, getStoreType, hashCode

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.streamthoughts.azkarra.api.query.Query

getParams, getStoreName, getStoreOperation, getStoreType

Constructor Detail

RestApiQueryCall

public RestApiQueryCall(String applicationId,
                        Endpoint localEndpoint,
                        Endpoint remoteEndpoint,
                        AzkarraV1Api api,
                        QueryRequest request)

Creates a new RestApiQueryCall instance.

Parameters:

applicationId - the application.id.

localEndpoint - the local Endpoint from which this remote query is executed.

remoteEndpoint - the remote Endpoint to query.

api - the AzkarraV1Api.

request - the QueryRequest to execute.

Method Detail

execute

public QueryResult<K,V> execute(QueryOptions options)

Executes this QueryCall.

Specified by:

execute in interface QueryCall<K,V>

Parameters:

options - the options to be used.

Returns:

the QueryResult.

executeAsync

public CompletableFuture<QueryResult<K,V>> executeAsync(QueryOptions options)

Executes this QueryCall asynchronously.

Specified by:

executeAsync in interface QueryCall<K,V>

Parameters:

options - the options to be used.

Returns:

a CompletableFuture of QueryResult.

executeAsync

public void executeAsync(QueryOptions options,
                         Consumer<QueryResult<K,V>> resultCallback)

Executes this QueryCall asynchronously.

Specified by:

executeAsync in interface QueryCall<K,V>

Parameters:

options - the options to be used.

resultCallback - the callback to be invoked when this QueryCall complete with either a success result or a failure exception.

cancel

public void cancel()

Cancels the QueryCall, if possible. QueryCall that are already complete cannot be canceled.

Specified by:

cancel in interface QueryCall<K,V>

isExecuted

public boolean isExecuted()

Specified by:

isExecuted in interface QueryCall<K,V>

Returns:

true if this QueryCall has already been executed.

isCanceled

public boolean isCanceled()

Specified by:

isCanceled in interface QueryCall<K,V>

Returns:

true if this QueryCall has already been canceled.

renew

public QueryCall<K,V> renew()

Create a new, identical QueryCall to this one which can be re-executed even if this call has already been.

Specified by:

renew in interface QueryCall<K,V>