Uses of Class
org.corfudb.protocols.wireprotocol.TokenResponse

Packages that use TokenResponse

Package	Description
org.corfudb.runtime.clients
org.corfudb.runtime.object	This package contains the object layer for Corfu.
org.corfudb.runtime.object.transactions
org.corfudb.runtime.view
org.corfudb.runtime.view.stream

Uses of TokenResponse in org.corfudb.runtime.clients

Methods in org.corfudb.runtime.clients that return types with arguments of type TokenResponse

Modifier and Type	Method and Description
CompletableFuture<TokenResponse>	SequencerClient.nextToken(List<UUID> streamIDs, long numTokens) Fetches the next available token from the sequencer.
CompletableFuture<TokenResponse>	SequencerClient.nextToken(List<UUID> streamIDs, long numTokens, TxResolutionInfo conflictInfo) Fetches the next available token from the sequencer.

Uses of TokenResponse in org.corfudb.runtime.object

Method parameters in org.corfudb.runtime.object with type arguments of type TokenResponse

Modifier and Type	Method and Description
long	ISMRStream.append(SMREntry entry, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Deprecated. Append a SMREntry to the stream, returning the global address it was written at.
long	ISMRStream.append(SMREntry entry, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Deprecated. Append a SMREntry to the stream, returning the global address it was written at.
long	StreamViewSMRAdapter.append(SMREntry entry, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Deprecated. Append a SMREntry to the stream, returning the global address it was written at.
long	StreamViewSMRAdapter.append(SMREntry entry, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Deprecated. Append a SMREntry to the stream, returning the global address it was written at.

Uses of TokenResponse in org.corfudb.runtime.object.transactions

Method parameters in org.corfudb.runtime.object.transactions with type arguments of type TokenResponse

Modifier and Type	Method and Description
long	WriteSetSMRStream.append(SMREntry entry, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Deprecated.
long	WriteSetSMRStream.append(SMREntry entry, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Deprecated.

Uses of TokenResponse in org.corfudb.runtime.view

Methods in org.corfudb.runtime.view that return TokenResponse

Modifier and Type	Method and Description
TokenResponse	SequencerView.next(TxResolutionInfo conflictInfo, UUID... streamIds) Acquire a token for a number of streams if there are no conflicts.
TokenResponse	SequencerView.next(UUID... streamIds) Return the next token in the sequencer for a particular stream.
TokenResponse	SequencerView.nextToken(Set<UUID> streamIDs, int numTokens) Deprecated.
TokenResponse	SequencerView.nextToken(Set<UUID> streamIDs, int numTokens, TxResolutionInfo conflictInfo) Deprecated.
TokenResponse	SequencerView.query(UUID... streamIds) Return the next token in the sequencer for the global tail or the tails of multiple streams.

Uses of TokenResponse in org.corfudb.runtime.view.stream

Method parameters in org.corfudb.runtime.view.stream with type arguments of type TokenResponse

Modifier and Type	Method and Description
long	AbstractQueuedStreamView.append(Object object, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Append an object to the stream, returning the global address it was written at.
long	AbstractQueuedStreamView.append(Object object, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Append an object to the stream, returning the global address it was written at.
long	ThreadSafeStreamView.append(Object object, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback)
long	ThreadSafeStreamView.append(Object object, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback)
long	IStreamView.append(Object object, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Append an object to the stream, returning the global address it was written at.
long	IStreamView.append(Object object, Function<TokenResponse,Boolean> acquisitionCallback, Function<TokenResponse,Boolean> deacquisitionCallback) Append an object to the stream, returning the global address it was written at.