org.corfudb.runtime.view

Class SequencerView

java.lang.Object

org.corfudb.runtime.view.AbstractView

org.corfudb.runtime.view.SequencerView

public class SequencerView
extends AbstractView

Created by mwei on 12/10/15.

Nested Class Summary

Nested classes/interfaces inherited from class org.corfudb.runtime.view.AbstractView

AbstractView.LayoutFunction<V,R,A extends Throwable,B extends Throwable,C extends Throwable,D extends Throwable>

Constructor Summary

Constructors

Constructor and Description
SequencerView(CorfuRuntime runtime)

Method Summary

Modifier and Type	Method and Description
StreamAddressSpace	getStreamAddressSpace(StreamAddressRange streamsAddressesRange) Retrieve a stream's address space from sequencer server.
Map<UUID,StreamAddressSpace>	getStreamsAddressSpace(List<StreamAddressRange> streamsAddressesRange) Retrieve multiple streams address space.
TokenResponse	next(TxResolutionInfo conflictInfo, UUID... streamIds) Acquire a token for a number of streams if there are no conflicts.
TokenResponse	next(UUID... streamIds) Return the next token in the sequencer for a particular stream.
TokenResponse	nextToken(Set<UUID> streamIDs, int numTokens) Deprecated.
TokenResponse	nextToken(Set<UUID> streamIDs, int numTokens, TxResolutionInfo conflictInfo) Deprecated.
TokenResponse	query(UUID... streamIds) Return the next token in the sequencer for the global tail or the tails of multiple streams.
void	trimCache(long address)

Methods inherited from class org.corfudb.runtime.view.AbstractView

getCurrentLayout, layoutHelper, layoutHelper

Methods inherited from class java.lang.Object

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

Constructor Detail

SequencerView

public SequencerView(CorfuRuntime runtime)

Method Detail

query

public TokenResponse query(UUID... streamIds)

Return the next token in the sequencer for the global tail or the tails of multiple streams.

Parameters:

streamIds - the streams to query

Returns:

the global tail or a list of tails

next

public TokenResponse next(UUID... streamIds)

Return the next token in the sequencer for a particular stream.

Parameters:

streamIds - The stream IDs to retrieve from.

Returns:

The first token retrieved.

getStreamAddressSpace

public StreamAddressSpace getStreamAddressSpace(StreamAddressRange streamsAddressesRange)

Retrieve a stream's address space from sequencer server.

Parameters:

streamsAddressesRange - range of streams address space to request.

Returns:

address space composed of the trim mark and collection of all addresses belonging to this stream.

getStreamsAddressSpace

public Map<UUID,StreamAddressSpace> getStreamsAddressSpace(List<StreamAddressRange> streamsAddressesRange)

Retrieve multiple streams address space.

Parameters:

streamsAddressesRange - list of streams and ranges to be requested.

Returns:

address space for each stream in the request.

next

public TokenResponse next(TxResolutionInfo conflictInfo,
                          UUID... streamIds)

Acquire a token for a number of streams if there are no conflicts.

Parameters:

conflictInfo - transaction conflict info

streamIds - streams to acquire the token for

Returns:

First token to be written for the streams if there are no conflicts

nextToken

@Deprecated
public TokenResponse nextToken(Set<UUID> streamIDs,
                                           int numTokens)

Deprecated.

Return the next token in the sequencer for a particular stream.

If numTokens == 0, then the streamAddressesMap returned is the last handed out token for each stream (if streamIDs is not empty). The token returned is the global address as previously defined, namely, max global address across all the streams.

Parameters:

streamIDs - The stream IDs to retrieve from.

numTokens - The number of tokens to reserve.

Returns:

The first token retrieved.

nextToken

@Deprecated
public TokenResponse nextToken(Set<UUID> streamIDs,
                                           int numTokens,
                                           TxResolutionInfo conflictInfo)

Deprecated.

trimCache

public void trimCache(long address)