Package com.couchbase.client.core.transaction.getmulti

Class CoreGetMultiState

java.lang.Object

com.couchbase.client.core.transaction.getmulti.CoreGetMultiState

@Internal
public class CoreGetMultiState
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
Instant	deadline
static final Duration	DEFAULT_INITIAL_DOC_FETCH_BOUND
static final Duration	DEFAULT_READ_SKEW_BOUND
static final List<CoreTransactionOptionalGetMultiResult>	EMPTY_GET_MULTI_RESULT_LIST
static final List<CoreTransactionGetMultiSpec>	EMPTY_GET_MULTI_SPEC_LIST
final CoreGetMultiOptions	options
final List<CoreTransactionGetMultiSpec>	originalSpecs
final boolean	replicasFromPreferredServerGroup

Constructor Summary

Constructors

Constructor	Description
CoreGetMultiState(List<CoreTransactionGetMultiSpec> toFetch, Instant deadline, boolean replicasFromPreferredServerGroup, CoreGetMultiOptions options)

Method Summary

Modifier and Type	Method	Description
List<CoreTransactionOptionalGetMultiResult>	alreadyFetched()
CoreGetMultiSignalAndReason	assertInReadSkewResolutionState()
CoreGetMultiSignalAndReason	assertValidState()
boolean	deadlineExceededSoon()
List<CoreTransactionGetMultiResult>	fetchedAndPresent()
CoreGetMultiPhase	phase()
void	reset(CoreTransactionLogger logger)
List<CoreTransactionGetMultiSpec>	toFetch()
String	toString()
CoreGetMultiSignalAndReason	update(CoreTransactionLogger logger, List<CoreTransactionGetMultiSpec> toFetch, List<CoreTransactionOptionalGetMultiResult> alreadyFetched, CoreGetMultiPhase mode, Instant deadline)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_INITIAL_DOC_FETCH_BOUND

public static final Duration DEFAULT_INITIAL_DOC_FETCH_BOUND

DEFAULT_READ_SKEW_BOUND

public static final Duration DEFAULT_READ_SKEW_BOUND

EMPTY_GET_MULTI_SPEC_LIST

public static final List<CoreTransactionGetMultiSpec> EMPTY_GET_MULTI_SPEC_LIST

EMPTY_GET_MULTI_RESULT_LIST

public static final List<CoreTransactionOptionalGetMultiResult> EMPTY_GET_MULTI_RESULT_LIST

originalSpecs

public final List<CoreTransactionGetMultiSpec> originalSpecs

options

public final CoreGetMultiOptions options

deadline

public Instant deadline

replicasFromPreferredServerGroup

public final boolean replicasFromPreferredServerGroup

Constructor Details

CoreGetMultiState

public CoreGetMultiState(List<CoreTransactionGetMultiSpec> toFetch,
 Instant deadline,
 boolean replicasFromPreferredServerGroup,
 CoreGetMultiOptions options)

Method Details

toString

public String toString()

Overrides:

toString in class Object

deadlineExceededSoon

public boolean deadlineExceededSoon()

toFetch

public List<CoreTransactionGetMultiSpec> toFetch()

update

public CoreGetMultiSignalAndReason update(CoreTransactionLogger logger,
 List<CoreTransactionGetMultiSpec> toFetch,
 List<CoreTransactionOptionalGetMultiResult> alreadyFetched,
 CoreGetMultiPhase mode,
 Instant deadline)

alreadyFetched

public List<CoreTransactionOptionalGetMultiResult> alreadyFetched()

phase

public CoreGetMultiPhase phase()

fetchedAndPresent

public List<CoreTransactionGetMultiResult> fetchedAndPresent()

assertInReadSkewResolutionState

public CoreGetMultiSignalAndReason assertInReadSkewResolutionState()

assertValidState

public CoreGetMultiSignalAndReason assertValidState()

reset

public void reset(CoreTransactionLogger logger)