org.corfudb.protocols.wireprotocol

Interface IMetadata

All Known Subinterfaces:

ILogData

All Known Implementing Classes:

LogData, WriteRequest

public interface IMetadata

Created by mwei on 9/18/15.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	IMetadata.DataRank
static class	IMetadata.LogUnitMetadataType

Field Summary

Fields

Modifier and Type	Field and Description
static Map<Byte,IMetadata.LogUnitMetadataType>	metadataTypeMap

Method Summary

Modifier and Type	Method and Description
default void	clearCommit()
default boolean	containsStream(UUID stream) Get whether or not this entry contains a given stream.
default Map<UUID,Long>	getBackpointerMap()
default UUID	getCheckpointedStreamId()
default Long	getCheckpointedStreamStartLogAddress() Returns the tail of the checkpointed stream at the time of taking the checkpoint snapshot.
default UUID	getCheckpointId()
default CheckpointEntry.CheckpointEntryType	getCheckpointType() Get checkpoint type.
default UUID	getClientId()
default Long	getEpoch() Get Log's epoch.
default Long	getGlobalAddress() Get Log's global address (global tail).
EnumMap<IMetadata.LogUnitMetadataType,Object>	getMetadataMap()
default IMetadata.DataRank	getRank() Get the rank of this append.
default Set<UUID>	getStreams() Get the streams that belong to this append.
default Long	getThreadId()
default Token	getToken()
default boolean	hasCheckpointMetadata()
default void	setBackpointerMap(Map<UUID,Long> backpointerMap)
default void	setCheckpointedStreamId(UUID Id)
default void	setCheckpointedStreamStartLogAddress(Long startLogAddress)
default void	setCheckpointId(UUID id)
default void	setCheckpointType(CheckpointEntry.CheckpointEntryType type)
default void	setClientId(UUID clientId)
default void	setCommit()
default void	setEpoch(Long epoch)
default void	setGlobalAddress(Long address)
default void	setRank(IMetadata.DataRank rank) Set the rank of this append.
default void	setThreadId(Long threadId)

Field Detail

metadataTypeMap

static final Map<Byte,IMetadata.LogUnitMetadataType> metadataTypeMap

Method Detail

getMetadataMap

EnumMap<IMetadata.LogUnitMetadataType,Object> getMetadataMap()

getStreams

default Set<UUID> getStreams()

Get the streams that belong to this append.

Returns:

A set of streams that belong to this append.

containsStream

default boolean containsStream(UUID stream)

Get whether or not this entry contains a given stream.

Parameters:

stream - The stream to check.

Returns:

True, if the entry contains the given stream.

getRank

@Nullable
default IMetadata.DataRank getRank()

Get the rank of this append.

Returns:

The rank of this append.

setRank

default void setRank(@Nullable
                     IMetadata.DataRank rank)

Set the rank of this append.

Parameters:

rank - The rank of this append.

getBackpointerMap

default Map<UUID,Long> getBackpointerMap()

setBackpointerMap

default void setBackpointerMap(Map<UUID,Long> backpointerMap)

setGlobalAddress

default void setGlobalAddress(Long address)

setEpoch

default void setEpoch(Long epoch)

setClientId

default void setClientId(UUID clientId)

getClientId

@Nullable
default UUID getClientId()

setThreadId

default void setThreadId(Long threadId)

getThreadId

@Nullable
default Long getThreadId()

getGlobalAddress

default Long getGlobalAddress()

Get Log's global address (global tail).

Returns:

global address

getEpoch

default Long getEpoch()

Get Log's epoch.

Returns:

epoch.

getToken

default Token getToken()

clearCommit

default void clearCommit()

setCommit

default void setCommit()

hasCheckpointMetadata

default boolean hasCheckpointMetadata()

getCheckpointType

@Nullable
default CheckpointEntry.CheckpointEntryType getCheckpointType()

Get checkpoint type.

setCheckpointType

default void setCheckpointType(CheckpointEntry.CheckpointEntryType type)

getCheckpointId

@Nullable
default UUID getCheckpointId()

setCheckpointId

default void setCheckpointId(UUID id)

getCheckpointedStreamId

default UUID getCheckpointedStreamId()

setCheckpointedStreamId

default void setCheckpointedStreamId(UUID Id)

getCheckpointedStreamStartLogAddress

default Long getCheckpointedStreamStartLogAddress()

Returns the tail of the checkpointed stream at the time of taking the checkpoint snapshot.

setCheckpointedStreamStartLogAddress

default void setCheckpointedStreamStartLogAddress(Long startLogAddress)