Package io.streamthoughts.azkarra.api.query

Class Queried

java.lang.Object

io.streamthoughts.azkarra.api.query.Queried

public class Queried
extends Object

Constructor Summary

Constructors

Constructor	Description
Queried(int retries, Duration retryBackoff, Duration queryTimeout, boolean remoteAccessAllowed, Long limit)	Creates a new Queried instance.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	hashCode()
static Queried	immediately()
Long	limit()	Gets the maximum number of records to return.
static Queried	locally()
Duration	queryTimeout()	Gets the maximum duration for executing the execute.
boolean	remoteAccessAllowed()	Gets whether remote access is allowed.
int	retries()	Gets the maximum number of attempts.
static Queried	retries(int retries, Duration retryBackoff)
Duration	retryBackoff()	Gets the time interval before attempting a new operation.
String	toString()
static Queried	with(Duration timeout)
Queried	withLimit(Long limit)
Queried	withQueryTimeout(Duration timeout)
Queried	withRemoteAccessAllowed(boolean remoteAccessAllowed)
Queried	withRetries(int retries)
Queried	withRetryBackoffMs(Duration retryBackoff)

Methods inherited from class java.lang.Object

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

Constructor Detail

Queried

public Queried(int retries,
               Duration retryBackoff,
               Duration queryTimeout,
               boolean remoteAccessAllowed,
               Long limit)

Creates a new Queried instance.

Parameters:

retries - retries.

retryBackoff - retryBackoff.

queryTimeout - queryTimeout.

remoteAccessAllowed - retryBackoff.

limit - limit.

Method Detail

with

public static Queried with(Duration timeout)

locally

public static Queried locally()

immediately

public static Queried immediately()

retries

public static Queried retries(int retries,
                              Duration retryBackoff)

withRemoteAccessAllowed

public Queried withRemoteAccessAllowed(boolean remoteAccessAllowed)

withQueryTimeout

public Queried withQueryTimeout(Duration timeout)

withRetries

public Queried withRetries(int retries)

withRetryBackoffMs

public Queried withRetryBackoffMs(Duration retryBackoff)

withLimit

public Queried withLimit(Long limit)

retries

public int retries()

Gets the maximum number of attempts.

Returns:

the number retries.

retryBackoff

public Duration retryBackoff()

Gets the time interval before attempting a new operation.

Returns:

the retry backoff.

remoteAccessAllowed

public boolean remoteAccessAllowed()

Gets whether remote access is allowed.

Returns:

true if remote access if allowed, false otherwise.

queryTimeout

public Duration queryTimeout()

Gets the maximum duration for executing the execute.

Returns:

the timeout.

limit

public Long limit()

Gets the maximum number of records to return. -1 is infinite.

Returns:

the limit.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object