Uses of Class
org.corfudb.runtime.CorfuRuntime

Packages that use CorfuRuntime

Package	Description
org.corfudb.generator
org.corfudb.infrastructure
org.corfudb.infrastructure.management
org.corfudb.infrastructure.orchestrator
org.corfudb.infrastructure.orchestrator.actions
org.corfudb.infrastructure.orchestrator.workflows
org.corfudb.protocols.logprotocol
org.corfudb.protocols.wireprotocol
org.corfudb.recovery
org.corfudb.runtime
org.corfudb.runtime.object	This package contains the object layer for Corfu.
org.corfudb.runtime.view
org.corfudb.runtime.view.stream
org.corfudb.runtime.view.workflows
org.corfudb.universe.node.client
org.corfudb.util
org.corfudb.util.serializer

Uses of CorfuRuntime in org.corfudb.generator

Constructors in org.corfudb.generator with parameters of type CorfuRuntime

Constructor and Description
State(int numStreams, int numKeys, CorfuRuntime rt)

Uses of CorfuRuntime in org.corfudb.infrastructure

Methods in org.corfudb.infrastructure that return CorfuRuntime

Modifier and Type	Method and Description
CorfuRuntime	ManagementAgent.getCorfuRuntime() Returns a connected instance of the CorfuRuntime.

Uses of CorfuRuntime in org.corfudb.infrastructure.management

Methods in org.corfudb.infrastructure.management with parameters of type CorfuRuntime

Modifier and Type	Method and Description
static boolean	ReconfigurationEventHandler.handleFailure(IReconfigurationHandlerPolicy failureHandlerPolicy, Layout currentLayout, CorfuRuntime corfuRuntime, Set<String> failedServers) Takes in the existing layout and a set of failed nodes.
static boolean	ReconfigurationEventHandler.handleHealing(CorfuRuntime runtime, Set<String> healedServers, Duration retryQueryTimeout) Takes in the existing layout and a set of healed nodes.
static boolean	ReconfigurationEventHandler.handleMergeSegments(CorfuRuntime runtime, Layout layout, Duration retryQueryTimeout) Launches a workflow to restore redundancy and merge all segments.
PollReport	IDetector.poll(Layout layout, CorfuRuntime corfuRuntime, SequencerMetrics sequencerMetrics) Executes the detector which runs the failure or healing detecting algorithm.
PollReport	FailureDetector.poll(Layout layout, CorfuRuntime corfuRuntime, SequencerMetrics sequencerMetrics) Executes the policy once.

Uses of CorfuRuntime in org.corfudb.infrastructure.orchestrator

Methods in org.corfudb.infrastructure.orchestrator with parameters of type CorfuRuntime

Modifier and Type	Method and Description
void	Action.execute(CorfuRuntime runtime, int numRetry) Execute the action.
abstract void	Action.impl(CorfuRuntime runtime) The implementation of the action

Constructor parameters in org.corfudb.infrastructure.orchestrator with type arguments of type CorfuRuntime

Constructor and Description
Orchestrator(SingletonResource<CorfuRuntime> runtime, ServerContext serverContext)

Uses of CorfuRuntime in org.corfudb.infrastructure.orchestrator.actions

Methods in org.corfudb.infrastructure.orchestrator.actions with parameters of type CorfuRuntime

Modifier and Type	Method and Description
void	RestoreRedundancyMergeSegments.impl(CorfuRuntime runtime)
static void	StateTransfer.transfer(Layout layout, Set<String> endpoints, CorfuRuntime runtime, Layout.LayoutSegment segment) Fetch and propagate the trimMark to the new/healing nodes.

Uses of CorfuRuntime in org.corfudb.infrastructure.orchestrator.workflows

Methods in org.corfudb.infrastructure.orchestrator.workflows with parameters of type CorfuRuntime

Modifier and Type	Method and Description
void	AddNodeWorkflow.BootstrapNode.impl(CorfuRuntime runtime) Completes if bootstrap was successful.
void	AddNodeWorkflow.RestoreRedundancy.impl(CorfuRuntime runtime)

Uses of CorfuRuntime in org.corfudb.protocols.logprotocol

Fields in org.corfudb.protocols.logprotocol declared as CorfuRuntime

Modifier and Type	Field and Description
protected CorfuRuntime	LogEntry.runtime The runtime to use.

Methods in org.corfudb.protocols.logprotocol with parameters of type CorfuRuntime

Modifier and Type	Method and Description
static ICorfuSerializable	LogEntry.deserialize(io.netty.buffer.ByteBuf b, CorfuRuntime rt) The base LogEntry format is very simple.

Uses of CorfuRuntime in org.corfudb.protocols.wireprotocol

Methods in org.corfudb.protocols.wireprotocol with parameters of type CorfuRuntime

Modifier and Type	Method and Description
default LogEntry	ILogData.getLogEntry(CorfuRuntime runtime) Return the payload as a log entry.
Object	ILogData.getPayload(CorfuRuntime t)
Object	LogData.getPayload(CorfuRuntime runtime) Return the payload.
default boolean	ILogData.isLogEntry(CorfuRuntime runtime) Return whether or not this entry is a log entry.

Uses of CorfuRuntime in org.corfudb.recovery

Methods in org.corfudb.recovery with parameters of type CorfuRuntime

Modifier and Type	Method and Description
static LogEntry	RecoveryUtils.deserializeLogData(CorfuRuntime runtime, ILogData logData) Deserialize a logData by getting the logEntry Getting the underlying logEntry should trigger deserialization only once.

Constructors in org.corfudb.recovery with parameters of type CorfuRuntime

Constructor and Description
FastObjectLoader(CorfuRuntime corfuRuntime)

Uses of CorfuRuntime in org.corfudb.runtime

Fields in org.corfudb.runtime with type parameters of type CorfuRuntime

Modifier and Type	Field and Description
static BiFunction<CorfuRuntime,String,IClientRouter>	CorfuRuntime.overrideGetRouterFunction When set, overrides the default getRouterFunction.

Methods in org.corfudb.runtime that return CorfuRuntime

Modifier and Type	Method and Description
CorfuRuntime	CorfuRuntime.addLayoutServer(String layoutServer) Add a layout server to the list of servers known by the CorfuRuntime.
CorfuRuntime	CorfuRuntime.connect() Connect to the Corfu server instance.
CorfuRuntime	CorfuRuntime.enableSaslPlainText(String usernameFile, String passwordFile) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.enableTls(String keyStore, String ksPasswordFile, String trustStore, String tsPasswordFile) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
static CorfuRuntime	CorfuRuntime.fromParameters(CorfuRuntime.CorfuRuntimeParameters parameters) Factory method for generating new CorfuRuntimes given a set of CorfuRuntime.CorfuRuntimeParameters to configure the runtime with.
CorfuRuntime	CorfuRuntime.parseConfigurationString(String configurationString) Parse a configuration string and get a CorfuRuntime.
CorfuRuntime	CorfuRuntime.registerBeforeRpcHandler(Runnable handler) Deprecated.
CorfuRuntime	CorfuRuntime.registerSystemDownHandler(Runnable handler) Deprecated.
CorfuRuntime	CorfuRuntime.setBackpointersDisabled(boolean disable) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.setBulkReadSize(int size) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.setCacheDisabled(boolean disable) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.setCacheExpiryTime(int expiryTime) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.setHoleFillingDisabled(boolean disable) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.setLoadSmrMapsAtConnect(boolean enable) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.setNumCacheEntries(long numCacheEntries) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.setTimeoutInMinutesForFastLoading(int timeout) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.setTransactionLogging(boolean enable) If enabled, successful transactions will be written to a special transaction stream (i.e.
CorfuRuntime	CorfuRuntime.setTrimRetry(int trimRetry) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.
CorfuRuntime	CorfuRuntime.setWriteRetry(int writeRetry) Deprecated. Deprecated, set using CorfuRuntime.CorfuRuntimeParameters instead.

Methods in org.corfudb.runtime with parameters of type CorfuRuntime

Modifier and Type	Method and Description
Token	MultiCheckpointWriter.appendCheckpoints(CorfuRuntime rt, String author) Checkpoint multiple SMRMaps.

Constructors in org.corfudb.runtime with parameters of type CorfuRuntime

Constructor and Description
CheckpointWriter(CorfuRuntime rt, UUID streamId, String author, T map) Constructor for Checkpoint Writer for Corfu Maps.
ViewsGarbageCollector(CorfuRuntime runtime)

Uses of CorfuRuntime in org.corfudb.runtime.object

Methods in org.corfudb.runtime.object with parameters of type CorfuRuntime

Modifier and Type	Method and Description
static <T> T	CorfuCompileWrapperBuilder.getWrapper(Class<T> type, CorfuRuntime rt, UUID streamID, Object[] args, ISerializer serializer) Deprecated.

Constructors in org.corfudb.runtime.object with parameters of type CorfuRuntime

Constructor and Description
CorfuCompileProxy(CorfuRuntime rt, UUID streamID, Class<T> type, Object[] args, ISerializer serializer, Map<String,ICorfuSMRUpcallTarget<T>> upcallTargetMap, Map<String,IUndoFunction<T>> undoTargetMap, Map<String,IUndoRecordFunction<T>> undoRecordTargetMap, Set<String> resetSet) Deprecated.
StreamViewSMRAdapter(CorfuRuntime runtime, IStreamView streamView) Deprecated.

Uses of CorfuRuntime in org.corfudb.runtime.view

Methods in org.corfudb.runtime.view with parameters of type CorfuRuntime

Modifier and Type	Method and Description
Layout	IFailureHandlerPolicy.generateLayout(Layout currentLayout, CorfuRuntime corfuRuntime, Set<String> failedNodes, Set<String> healedNodes) Generates a new layout based on the set of failures.
Layout	IReconfigurationHandlerPolicy.generateLayout(Layout currentLayout, CorfuRuntime corfuRuntime, Set<String> failedNodes, Set<String> healedNodes) Generates a new layout based on the set of failures.
Layout	ConservativeFailureHandlerPolicy.generateLayout(Layout originalLayout, CorfuRuntime corfuRuntime, Set<String> failedNodes, Set<String> healedNodes) Modifies the layout by marking the failed nodes as unresponsive but still keeping them in the layout and sequencer servers lists.
IReplicationProtocol	Layout.ReplicationMode.getReplicationProtocol(CorfuRuntime r)
abstract IStreamView	Layout.ReplicationMode.getStreamView(CorfuRuntime r, UUID streamId, StreamOptions options)
abstract IStreamView	Layout.ReplicationMode.getUnsafeStreamView(CorfuRuntime r, UUID streamId, StreamOptions options)

Constructors in org.corfudb.runtime.view with parameters of type CorfuRuntime

Constructor and Description
AbstractView(CorfuRuntime runtime)
AddressSpaceView(CorfuRuntime runtime) Constructor for the Address Space View.
LayoutManagementView(CorfuRuntime runtime)
LayoutView(CorfuRuntime runtime)
ManagementView(CorfuRuntime runtime)
ObjectsView(CorfuRuntime runtime)
RuntimeLayout(Layout layout, CorfuRuntime corfuRuntime) Constructor taking a reference of the layout to stamp the clients.
SequencerView(CorfuRuntime runtime)
StreamsView(CorfuRuntime runtime)

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

Constructors in org.corfudb.runtime.view.stream with parameters of type CorfuRuntime

Constructor and Description
AbstractContextStreamView(CorfuRuntime runtime, UUID id, BiFunction<UUID,Long,T> contextFactory) Create a new abstract context stream view.
AbstractQueuedStreamView(CorfuRuntime runtime, UUID streamId) Create a new queued stream view.
AddressMapStreamView(CorfuRuntime runtime, UUID streamId)
AddressMapStreamView(CorfuRuntime runtime, UUID streamId, StreamOptions options) Create a new address map stream view.
BackpointerStreamView(CorfuRuntime runtime, UUID streamId)
BackpointerStreamView(CorfuRuntime runtime, UUID streamId, StreamOptions options) Create a new backpointer stream view.
ThreadSafeStreamView(CorfuRuntime runtime, UUID streamId)
ThreadSafeStreamView(CorfuRuntime runtime, UUID streamId, StreamOptions options)

Uses of CorfuRuntime in org.corfudb.runtime.view.workflows

Fields in org.corfudb.runtime.view.workflows declared as CorfuRuntime

Modifier and Type	Field and Description
protected CorfuRuntime	WorkflowRequest.runtime

Constructors in org.corfudb.runtime.view.workflows with parameters of type CorfuRuntime

Constructor and Description
AddNode(String endpointToAdd, CorfuRuntime runtime, int retry, Duration timeout, Duration pollPeriod)
ForceRemoveNode(String endpointToRemove, CorfuRuntime runtime, int retry, Duration timeout, Duration pollPeriod)
HealNode(String endpointToHeal, CorfuRuntime runtime, int retry, Duration timeout, Duration pollPeriod)
RemoveNode(String endpointToRemove, CorfuRuntime runtime, int retry, Duration timeout, Duration pollPeriod)
RestoreRedundancyMergeSegments(String endpointToRestoreRedundancy, CorfuRuntime runtime, int retry, Duration timeout, Duration pollPeriod) Create a Merge segments workflow request.

Uses of CorfuRuntime in org.corfudb.universe.node.client

Methods in org.corfudb.universe.node.client that return CorfuRuntime

Modifier and Type	Method and Description
CorfuRuntime	CorfuClient.getRuntime() See CorfuRuntime()
CorfuRuntime	LocalCorfuClient.getRuntime()

Uses of CorfuRuntime in org.corfudb.util

Methods in org.corfudb.util with parameters of type CorfuRuntime

Modifier and Type	Method and Description
static TailsResponse	Utils.getAllTails(Layout layout, CorfuRuntime runtime) Fetches the max global log tail and all stream tails from the log unit cluster.
static StreamsAddressResponse	Utils.getLogAddressSpace(Layout layout, CorfuRuntime runtime) Retrieve the space of addresses of the log, i.e., for all streams in the log.
static long	Utils.getLogTail(Layout layout, CorfuRuntime runtime) Get global log tail.
static void	Utils.printLogAnatomy(CorfuRuntime runtime, ILogData logData) Print the anatomy of a LogData

Uses of CorfuRuntime in org.corfudb.util.serializer

Methods in org.corfudb.util.serializer with parameters of type CorfuRuntime

Modifier and Type	Method and Description
default Object	ISerializer.clone(Object o, CorfuRuntime rt) Clone an object through serialization.
Object	JsonSerializer.deserialize(io.netty.buffer.ByteBuf b, CorfuRuntime rt) Deserialize an object from a given byte buffer.
Object	JavaSerializer.deserialize(io.netty.buffer.ByteBuf b, CorfuRuntime rt) Deserialize an object from a given byte buffer.
Object	PrimitiveSerializer.deserialize(io.netty.buffer.ByteBuf b, CorfuRuntime rt) Deserialize an object from a given byte buffer.
Object	CorfuSerializer.deserialize(io.netty.buffer.ByteBuf b, CorfuRuntime rt) Deserialize an object from a given byte buffer.
Object	ISerializer.deserialize(io.netty.buffer.ByteBuf b, CorfuRuntime rt) Deserialize an object from a given byte buffer.