Hierarchy For All Packages

Package Hierarchies:

• org.corfudb.annotations,
• org.corfudb.comm,
• org.corfudb.generator,
• org.corfudb.generator.distributions,
• org.corfudb.generator.operations,
• org.corfudb.infrastructure,
• org.corfudb.infrastructure.log,
• org.corfudb.infrastructure.management,
• org.corfudb.infrastructure.management.failuredetector,
• org.corfudb.infrastructure.orchestrator,
• org.corfudb.infrastructure.orchestrator.actions,
• org.corfudb.infrastructure.orchestrator.workflows,
• org.corfudb.infrastructure.utils,
• org.corfudb.metrics,
• org.corfudb.protocols.logprotocol,
• org.corfudb.protocols.wireprotocol,
• org.corfudb.protocols.wireprotocol.failuredetector,
• org.corfudb.protocols.wireprotocol.orchestrator,
• org.corfudb.recovery,
• org.corfudb.runtime,
• org.corfudb.runtime.clients,
• org.corfudb.runtime.collections,
• org.corfudb.runtime.exceptions,
• org.corfudb.runtime.exceptions.unrecoverable,
• org.corfudb.runtime.object,
• org.corfudb.runtime.object.transactions,
• org.corfudb.runtime.view,
• org.corfudb.runtime.view.replication,
• org.corfudb.runtime.view.stream,
• org.corfudb.runtime.view.workflows,
• org.corfudb.samples,
• org.corfudb.security.sasl,
• org.corfudb.security.sasl.plaintext,
• org.corfudb.security.tls,
• org.corfudb.shell,
• org.corfudb.universe,
• org.corfudb.universe.group,
• org.corfudb.universe.group.cluster,
• org.corfudb.universe.group.cluster.docker,
• org.corfudb.universe.group.cluster.vm,
• org.corfudb.universe.logging,
• org.corfudb.universe.node,
• org.corfudb.universe.node.client,
• org.corfudb.universe.node.server,
• org.corfudb.universe.node.server.docker,
• org.corfudb.universe.node.server.vm,
• org.corfudb.universe.node.stress,
• org.corfudb.universe.node.stress.vm,
• org.corfudb.universe.scenario,
• org.corfudb.universe.scenario.action,
• org.corfudb.universe.scenario.fixture,
• org.corfudb.universe.scenario.spec,
• org.corfudb.universe.universe,
• org.corfudb.universe.universe.docker,
• org.corfudb.universe.universe.process,
• org.corfudb.universe.universe.vm,
• org.corfudb.universe.util,
• org.corfudb.util,
• org.corfudb.util.concurrent,
• org.corfudb.util.retry,
• org.corfudb.util.serializer

Class Hierarchy

• java.lang.Object
  • java.util.AbstractCollection<E> (implements java.util.Collection<E>)
    • java.util.AbstractQueue<E> (implements java.util.Queue<E>)
      • java.util.concurrent.ArrayBlockingQueue<E> (implements java.util.concurrent.BlockingQueue<E>, java.io.Serializable)
        • org.corfudb.recovery.FastObjectLoader.BoundedQueue<E>
  • org.corfudb.runtime.view.stream.AbstractContextStreamView<T> (implements java.lang.AutoCloseable, org.corfudb.runtime.view.stream.IStreamView)
    • org.corfudb.runtime.view.stream.AbstractQueuedStreamView
      • org.corfudb.runtime.view.stream.AddressMapStreamView
      • org.corfudb.runtime.view.stream.BackpointerStreamView
  • org.corfudb.universe.group.cluster.AbstractCorfuCluster<P,U> (implements org.corfudb.universe.group.cluster.CorfuCluster)
    • org.corfudb.universe.group.cluster.docker.DockerCorfuCluster
    • org.corfudb.universe.group.cluster.vm.VmCorfuCluster
  • org.corfudb.universe.node.server.AbstractCorfuServer<T,U> (implements org.corfudb.universe.node.server.CorfuServer)
    • org.corfudb.universe.node.server.docker.DockerCorfuServer
    • org.corfudb.universe.node.server.vm.VmCorfuServer
  • org.corfudb.runtime.object.AbstractCorfuWrapper<T> (implements org.corfudb.runtime.object.ICorfuSMRProxyWrapper<T>)
    • org.corfudb.runtime.collections.FGMap<K,V> (implements java.util.Map<K,V>)
  • java.util.AbstractMap<K,V> (implements java.util.Map<K,V>)
    • java.util.HashMap<K,V> (implements java.lang.Cloneable, java.util.Map<K,V>, java.io.Serializable)
      • org.corfudb.runtime.collections.SMRMap<K,V> (implements org.corfudb.runtime.collections.ISMRMap<K,V>)
  • javax.annotation.processing.AbstractProcessor (implements javax.annotation.processing.Processor)
    • org.corfudb.annotations.ObjectAnnotationProcessor
  • org.corfudb.runtime.view.replication.AbstractReplicationProtocol (implements org.corfudb.runtime.view.replication.IReplicationProtocol)
    • org.corfudb.runtime.view.replication.ChainReplicationProtocol
    • org.corfudb.runtime.view.replication.QuorumReplicationProtocol
  • org.corfudb.infrastructure.AbstractServer
    • org.corfudb.infrastructure.BaseServer
    • org.corfudb.infrastructure.LayoutServer
    • org.corfudb.infrastructure.LogUnitServer
    • org.corfudb.infrastructure.ManagementServer
    • org.corfudb.infrastructure.SequencerServer
  • org.corfudb.runtime.view.stream.AbstractStreamContext (implements java.lang.Comparable<T>)
  • org.corfudb.runtime.object.transactions.AbstractTransactionalContext (implements java.lang.Comparable<T>)
    • org.corfudb.runtime.object.transactions.OptimisticTransactionalContext
      • org.corfudb.runtime.object.transactions.WriteAfterWriteTransactionalContext
    • org.corfudb.runtime.object.transactions.SnapshotTransactionalContext
  • org.corfudb.universe.universe.AbstractUniverse<P> (implements org.corfudb.universe.universe.Universe)
    • org.corfudb.universe.universe.docker.DockerUniverse
    • org.corfudb.universe.universe.vm.VmUniverse
  • org.corfudb.runtime.view.AbstractView
    • org.corfudb.runtime.view.AddressSpaceView
    • org.corfudb.runtime.view.LayoutManagementView
    • org.corfudb.runtime.view.LayoutView
    • org.corfudb.runtime.view.ManagementView
    • org.corfudb.runtime.view.ObjectsView
    • org.corfudb.runtime.view.SequencerView
    • org.corfudb.runtime.view.StreamsView
  • org.corfudb.infrastructure.orchestrator.Action
    • org.corfudb.infrastructure.orchestrator.workflows.AddNodeWorkflow.BootstrapNode
    • org.corfudb.infrastructure.orchestrator.workflows.AddNodeWorkflow.RestoreRedundancy
    • org.corfudb.infrastructure.orchestrator.actions.RestoreRedundancyMergeSegments
  • org.corfudb.universe.scenario.action.Action.AbstractAction<R> (implements org.corfudb.universe.scenario.action.Action<R>)
  • org.corfudb.protocols.wireprotocol.orchestrator.AddNodeRequest (implements org.corfudb.protocols.wireprotocol.orchestrator.CreateRequest)
    • org.corfudb.protocols.wireprotocol.orchestrator.RemoveNodeRequest
      • org.corfudb.protocols.wireprotocol.orchestrator.ForceRemoveNodeRequest
  • org.corfudb.infrastructure.orchestrator.workflows.AddNodeWorkflow (implements org.corfudb.infrastructure.orchestrator.IWorkflow)
    • org.corfudb.infrastructure.orchestrator.workflows.HealNodeWorkflow
  • org.corfudb.runtime.view.Address
  • org.corfudb.infrastructure.log.AddressMetaData
  • org.corfudb.runtime.view.replication.AlwaysHoleFillPolicy (implements org.corfudb.runtime.view.replication.IHoleFillPolicy)
  • org.corfudb.universe.universe.vm.ApplianceManager
  • org.corfudb.runtime.clients.BaseClient (implements org.corfudb.runtime.clients.IClient)
  • org.corfudb.samples.BaseCorfuAppUtils
    • org.corfudb.samples.BatchedWriteTransaction
    • org.corfudb.samples.SimpleAtomicTransaction
    • org.corfudb.samples.SimpleUseBaseCorfuCollections
    • org.corfudb.samples.SimpleUseCustomBaseCorfuObject
    • org.corfudb.samples.WriteOnlySimpleTransaction
    • org.corfudb.samples.WriteWriteTXs
  • org.corfudb.runtime.clients.BaseHandler (implements org.corfudb.runtime.clients.IClient)
  • org.corfudb.infrastructure.BatchProcessor (implements java.lang.AutoCloseable)
  • org.corfudb.infrastructure.BatchWriterOperation<T>
  • org.corfudb.runtime.BootstrapUtil
  • org.corfudb.util.CFUtils
  • io.netty.channel.ChannelHandlerAdapter (implements io.netty.channel.ChannelHandler)
    • io.netty.channel.ChannelInboundHandlerAdapter (implements io.netty.channel.ChannelInboundHandler)
      • io.netty.handler.codec.ByteToMessageDecoder
        • org.corfudb.protocols.wireprotocol.NettyCorfuMessageDecoder
      • io.netty.channel.ChannelDuplexHandler (implements io.netty.channel.ChannelOutboundHandler)
        • org.corfudb.protocols.wireprotocol.ClientHandshakeHandler
        • org.corfudb.protocols.wireprotocol.InboundMsgFilterHandler
        • org.corfudb.security.sasl.plaintext.PlainTextSaslNettyClient
        • org.corfudb.infrastructure.ServerHandshakeHandler
      • org.corfudb.infrastructure.NettyServerRouter (implements org.corfudb.infrastructure.IServerRouter)
      • io.netty.channel.SimpleChannelInboundHandler<I>
        • org.corfudb.runtime.clients.NettyClientRouter (implements org.corfudb.runtime.clients.IClientRouter)
        • org.corfudb.security.sasl.plaintext.PlainTextSaslNettyServer
    • io.netty.channel.ChannelOutboundHandlerAdapter (implements io.netty.channel.ChannelOutboundHandler)
      • io.netty.handler.codec.MessageToByteEncoder<I>
        • org.corfudb.protocols.wireprotocol.NettyCorfuMessageEncoder
  • org.corfudb.runtime.CheckpointWriter<T>
  • org.corfudb.universe.util.ClassUtils
  • org.corfudb.runtime.clients.ClientMsgHandler
  • org.corfudb.universe.node.client.ClientParams (implements org.corfudb.universe.node.Node.NodeParams<T>)
  • org.corfudb.infrastructure.management.ClusterAdvisorFactory
  • org.corfudb.infrastructure.management.failuredetector.ClusterGraph
  • org.corfudb.infrastructure.management.failuredetector.ClusterGraph.ClusterGraphHelper
  • org.corfudb.protocols.wireprotocol.ClusterState (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.infrastructure.management.ClusterStateAggregator
  • org.corfudb.infrastructure.management.ClusterStateCollector
  • org.corfudb.infrastructure.management.ClusterStateContext
  • org.corfudb.infrastructure.management.ClusterStateContext.HeartbeatCounter
  • org.corfudb.runtime.view.ClusterStatusReport
  • org.corfudb.infrastructure.management.CompleteGraphAdvisor (implements org.corfudb.infrastructure.management.ClusterAdvisor)
  • org.corfudb.runtime.object.transactions.ConflictSetInfo
    • org.corfudb.runtime.object.transactions.WriteSetInfo
  • org.corfudb.runtime.view.ConservativeFailureHandlerPolicy (implements org.corfudb.runtime.view.IReconfigurationHandlerPolicy)
  • org.corfudb.universe.group.cluster.CorfuClusterParams (implements org.corfudb.universe.group.Group.GroupParams)
  • org.corfudb.runtime.object.CorfuCompileProxy<T> (implements org.corfudb.runtime.object.ICorfuSMRProxyInternal<T>)
  • org.corfudb.runtime.object.CorfuCompileWrapperBuilder
  • org.corfudb.samples.CorfuCompoundObject
  • org.corfudb.samples.CorfuCompoundObject.Inner
  • org.corfudb.protocols.wireprotocol.CorfuMsg
    • org.corfudb.protocols.wireprotocol.CorfuPayloadMsg<T>
    • org.corfudb.protocols.wireprotocol.JSONPayloadMsg<T>
    • org.corfudb.protocols.wireprotocol.LayoutMsg
  • org.corfudb.infrastructure.CorfuMsgHandler
  • org.corfudb.runtime.CorfuRuntime
  • org.corfudb.runtime.CorfuRuntime.CorfuRuntimeParameters
  • org.corfudb.util.serializer.CorfuSerializer (implements org.corfudb.util.serializer.ISerializer)
  • org.corfudb.infrastructure.CorfuServer
  • org.corfudb.universe.node.server.CorfuServerParams (implements org.corfudb.universe.node.Node.NodeParams<T>)
    • org.corfudb.universe.node.server.vm.VmCorfuServerParams
  • org.corfudb.samples.CorfuSharedCounter
  • org.corfudb.runtime.collections.CorfuTable<K,V> (implements org.corfudb.runtime.collections.ICorfuMap<K,V>)
  • org.corfudb.runtime.collections.CorfuTable.Index<K,V,I>
  • org.corfudb.generator.Correctness
  • org.corfudb.protocols.wireprotocol.orchestrator.CreateWorkflowResponse (implements org.corfudb.protocols.wireprotocol.orchestrator.Response)
  • org.corfudb.infrastructure.DataStore (implements org.corfudb.infrastructure.IDataStore)
  • org.corfudb.protocols.wireprotocol.DetectorMsg (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • java.util.Dictionary<K,V>
    • java.util.Hashtable<K,V> (implements java.lang.Cloneable, java.util.Map<K,V>, java.io.Serializable)
      • java.util.Properties
        • java.security.Provider
          • org.corfudb.security.sasl.plaintext.PlainTextSaslServerProvider
  • org.corfudb.universe.util.DockerManager
  • org.corfudb.protocols.wireprotocol.ExceptionMsg (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.util.retry.ExponentialBackoffRetry<E,F,G,H,O,A>
  • org.corfudb.infrastructure.management.FailureDetector (implements org.corfudb.infrastructure.management.IDetector)
  • org.corfudb.protocols.wireprotocol.failuredetector.FailureDetectorMetrics (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.failuredetector.FailureDetectorMetrics.ConnectivityGraph (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.universe.universe.docker.FakeDns
  • org.corfudb.recovery.FastObjectLoader
  • org.corfudb.protocols.wireprotocol.FillHoleRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.universe.scenario.fixture.Fixtures.AbstractUniverseFixture<T> (implements org.corfudb.universe.scenario.fixture.Fixture<T>)
    • org.corfudb.universe.scenario.fixture.Fixtures.UniverseFixture
    • org.corfudb.universe.scenario.fixture.Fixtures.VmUniverseFixture
  • org.corfudb.universe.scenario.fixture.Fixtures.FixtureUtil
  • org.corfudb.universe.scenario.fixture.Fixtures.TestFixtureConst
  • org.corfudb.infrastructure.orchestrator.workflows.ForceRemoveWorkflow (implements org.corfudb.infrastructure.orchestrator.IWorkflow)
  • org.corfudb.generator.Generator
  • org.corfudb.util.GitRepositoryState
  • org.corfudb.protocols.wireprotocol.HandshakeMsg (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.HandshakeResponse (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.HandshakeState
  • org.corfudb.protocols.wireprotocol.orchestrator.HealNodeRequest (implements org.corfudb.protocols.wireprotocol.orchestrator.CreateRequest)
  • org.corfudb.samples.HelloCorfu
  • org.corfudb.util.Holder<T>
  • org.corfudb.infrastructure.IDataStore.KvRecord<T>
  • org.corfudb.protocols.wireprotocol.ILogData.SerializationHandle (implements java.lang.AutoCloseable)
  • org.corfudb.protocols.wireprotocol.IMetadata.DataRank (implements java.lang.Comparable<T>)
  • org.corfudb.util.ImmuableListSetWrapper<E> (implements java.util.Set<E>)
  • org.corfudb.infrastructure.log.InMemoryStreamLog (implements org.corfudb.infrastructure.log.StreamLog, org.corfudb.infrastructure.log.StreamLogWithRankedAddressSpace)
  • org.corfudb.util.retry.IntervalRetry<E,F,G,H,O>
  • org.corfudb.universe.util.IpTablesUtil
  • org.corfudb.util.serializer.JavaSerializer (implements org.corfudb.util.serializer.ISerializer)
  • org.corfudb.util.serializer.JsonSerializer (implements org.corfudb.util.serializer.ISerializer)
  • org.corfudb.util.JsonUtils
  • org.corfudb.generator.distributions.Keys (implements org.corfudb.generator.distributions.DataSet)
  • org.corfudb.util.LambdaUtils
  • org.corfudb.runtime.view.Layout
  • org.corfudb.runtime.view.Layout.LayoutSegment
  • org.corfudb.runtime.view.Layout.LayoutStripe
  • org.corfudb.protocols.wireprotocol.LayoutBootstrapRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.runtime.view.LayoutBuilder
  • org.corfudb.runtime.clients.LayoutClient
  • org.corfudb.protocols.wireprotocol.LayoutCommittedRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.runtime.view.LayoutDeserializer (implements com.google.gson.JsonDeserializer<T>)
  • org.corfudb.runtime.clients.LayoutHandler (implements org.corfudb.runtime.clients.IClient, org.corfudb.runtime.clients.IHandler<C>)
  • org.corfudb.protocols.wireprotocol.LayoutPrepareRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.LayoutPrepareResponse (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.LayoutProposeRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.LayoutProposeResponse (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.universe.node.client.LocalCorfuClient (implements org.corfudb.universe.node.client.CorfuClient)
  • org.corfudb.util.LockUtils
  • org.corfudb.util.LockUtils.AutoCloseRwLock (implements java.lang.AutoCloseable)
  • org.corfudb.protocols.wireprotocol.LogData (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>, org.corfudb.protocols.wireprotocol.ILogData, org.corfudb.protocols.wireprotocol.IMetadata)
  • org.corfudb.protocols.logprotocol.LogEntry (implements org.corfudb.util.serializer.ICorfuSerializable)
    • org.corfudb.protocols.logprotocol.CheckpointEntry
    • org.corfudb.protocols.logprotocol.MultiObjectSMREntry (implements org.corfudb.protocols.logprotocol.ISMRConsumable)
    • org.corfudb.protocols.logprotocol.MultiSMREntry (implements org.corfudb.protocols.logprotocol.ISMRConsumable)
    • org.corfudb.protocols.logprotocol.SMREntry (implements org.corfudb.protocols.logprotocol.ISMRConsumable)
  • org.corfudb.universe.logging.LoggingParams
  • org.corfudb.infrastructure.log.LogMetadata
  • org.corfudb.runtime.clients.LogUnitClient
  • org.corfudb.runtime.clients.LogUnitHandler (implements org.corfudb.runtime.clients.IClient, org.corfudb.runtime.clients.IHandler<C>)
  • org.corfudb.infrastructure.LogUnitServer.LogUnitServerConfig
  • org.corfudb.generator.LongevityApp
  • org.corfudb.generator.LongevityRun
  • org.corfudb.infrastructure.ManagementAgent
  • org.corfudb.runtime.clients.ManagementClient
  • org.corfudb.runtime.clients.ManagementHandler (implements org.corfudb.runtime.clients.IClient, org.corfudb.runtime.clients.IHandler<C>)
  • org.corfudb.metrics.MBeanDumperApp
  • org.corfudb.util.MetricsUtils
  • org.corfudb.protocols.wireprotocol.MsgHandlingFilter (implements java.util.function.Function<T,R>)
  • org.corfudb.runtime.MultiCheckpointWriter<T>
  • org.corfudb.protocols.wireprotocol.MultipleReadRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.infrastructure.log.MultiReadWriteLock
  • org.corfudb.util.NetworkUtils
  • org.corfudb.runtime.view.replication.NeverHoleFillPolicy (implements org.corfudb.runtime.view.replication.IHoleFillPolicy)
  • org.corfudb.protocols.wireprotocol.failuredetector.NodeConnectivity (implements java.lang.Comparable<T>, org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.util.NodeLocator (implements java.io.Serializable)
  • org.corfudb.protocols.wireprotocol.failuredetector.NodeRank (implements java.lang.Comparable<T>, org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.runtime.NodeRouterPool
  • org.corfudb.protocols.wireprotocol.NodeState (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.NodeState.HeartbeatTimestamp (implements java.lang.Comparable<T>, org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.runtime.view.ObjectBuilder<T> (implements org.corfudb.runtime.object.IObjectBuilder<T>)
  • org.corfudb.runtime.view.ObjectsView.ObjectID<T>
  • org.corfudb.generator.operations.Operation
    • org.corfudb.generator.operations.CheckpointOperation
    • org.corfudb.generator.operations.NestedTxOperation
    • org.corfudb.generator.operations.OptimisticTxOperation
    • org.corfudb.generator.operations.ReadOperation
    • org.corfudb.generator.operations.RemoveOperation
    • org.corfudb.generator.operations.SleepOperation
    • org.corfudb.generator.operations.SnapshotTxOperation
    • org.corfudb.generator.operations.WriteAfterWriteTxOperation
    • org.corfudb.generator.operations.WriteOperation
  • org.corfudb.generator.distributions.OperationCount (implements org.corfudb.generator.distributions.DataSet)
  • org.corfudb.generator.distributions.Operations (implements org.corfudb.generator.distributions.DataSet)
  • org.corfudb.infrastructure.orchestrator.Orchestrator
  • org.corfudb.protocols.wireprotocol.orchestrator.OrchestratorMsg (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.orchestrator.OrchestratorResponse (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.infrastructure.utils.Persistence
  • org.corfudb.security.sasl.plaintext.PlainTextCallbackHandler (implements javax.security.auth.callback.CallbackHandler)
  • org.corfudb.security.sasl.plaintext.PlainTextLoginModule (implements javax.security.auth.spi.LoginModule)
  • org.corfudb.security.sasl.plaintext.PlainTextSaslServer (implements javax.security.sasl.SaslServer)
  • org.corfudb.security.sasl.plaintext.PlainTextSaslServer.PlainTextSaslServerFactory (implements javax.security.sasl.SaslServerFactory)
  • org.corfudb.infrastructure.management.PollReport
  • org.corfudb.util.serializer.PrimitiveSerializer (implements org.corfudb.util.serializer.ISerializer)
  • org.corfudb.universe.universe.process.ProcessUniverse (implements org.corfudb.universe.universe.Universe)
  • org.corfudb.protocols.wireprotocol.orchestrator.QueryRequest (implements org.corfudb.protocols.wireprotocol.orchestrator.Request)
  • org.corfudb.protocols.wireprotocol.orchestrator.QueryResponse (implements org.corfudb.protocols.wireprotocol.orchestrator.Response)
  • org.corfudb.runtime.view.QuorumFuturesFactory
  • org.corfudb.runtime.view.QuorumFuturesFactory.CompositeFuture<R> (implements java.util.concurrent.Future<V>)
  • org.corfudb.protocols.wireprotocol.RangeWriteMsg (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.infrastructure.Rank
  • org.corfudb.protocols.wireprotocol.ReadRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.ReadResponse (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.runtime.view.replication.ReadWaitHoleFillPolicy (implements org.corfudb.runtime.view.replication.IHoleFillPolicy)
  • org.corfudb.runtime.RebootUtil
  • org.corfudb.infrastructure.management.ReconfigurationEventHandler
  • org.corfudb.recovery.RecoveryUtils
  • org.corfudb.util.ReflectionUtils
  • org.corfudb.security.tls.ReloadableTrustManager (implements javax.net.ssl.X509TrustManager)
  • org.corfudb.infrastructure.RemoteMonitoringService (implements org.corfudb.infrastructure.MonitoringService)
  • org.corfudb.universe.group.cluster.vm.RemoteOperationHelper
  • org.corfudb.infrastructure.orchestrator.workflows.RemoveNodeWorkflow (implements org.corfudb.infrastructure.orchestrator.IWorkflow)
  • org.corfudb.protocols.wireprotocol.orchestrator.RestoreRedundancyMergeSegmentsRequest (implements org.corfudb.protocols.wireprotocol.orchestrator.CreateRequest)
  • org.corfudb.infrastructure.orchestrator.workflows.RestoreRedundancyMergeSegmentsWorkflow (implements org.corfudb.infrastructure.orchestrator.IWorkflow)
  • org.corfudb.runtime.view.RuntimeLayout
  • org.corfudb.security.sasl.SaslUtils
  • org.corfudb.universe.scenario.Scenario<D,T>
  • org.corfudb.universe.scenario.Scenario.ScenarioTest<T,R>
  • org.corfudb.universe.scenario.Scenario.ScenarioTestCase<T>
  • org.corfudb.runtime.view.SealServersHelper
  • org.corfudb.runtime.clients.SequencerClient
  • org.corfudb.runtime.clients.SequencerHandler (implements org.corfudb.runtime.clients.IClient, org.corfudb.runtime.clients.IHandler<C>)
  • org.corfudb.protocols.wireprotocol.SequencerMetrics (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.SequencerRecoveryMsg (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.infrastructure.SequencerServer.Config
  • org.corfudb.infrastructure.SequencerServerCache
  • org.corfudb.infrastructure.SequencerServerCache.ConflictTxStream
  • org.corfudb.util.serializer.Serializers
  • org.corfudb.infrastructure.ServerContext (implements java.lang.AutoCloseable)
  • org.corfudb.infrastructure.ServerThreadFactory (implements java.util.concurrent.ThreadFactory)
  • org.corfudb.infrastructure.ServerThreadFactory.ExceptionHandler (implements java.lang.Thread.UncaughtExceptionHandler)
  • org.corfudb.universe.node.server.ServerUtil
  • org.corfudb.shell.ShellMain
  • org.corfudb.util.concurrent.SingletonResource<T>
  • org.corfudb.universe.scenario.spec.Spec.AbstractSpec<T,R> (implements org.corfudb.universe.scenario.spec.Spec<T,R>)
  • java.util.Spliterators.AbstractSpliterator<T> (implements java.util.Spliterator<T>)
    • org.corfudb.runtime.view.stream.StreamSpliterator
  • org.corfudb.security.tls.SslContextConstructor
  • org.corfudb.generator.State
  • org.corfudb.infrastructure.orchestrator.actions.StateTransfer
  • org.corfudb.annotations.StaticMappingObject
  • org.corfudb.protocols.wireprotocol.StreamAddressRange
  • org.corfudb.runtime.view.stream.StreamAddressSpace
  • org.corfudb.infrastructure.log.StreamLogCompaction
  • org.corfudb.infrastructure.log.StreamLogDataStore
  • org.corfudb.infrastructure.log.StreamLogFiles (implements org.corfudb.infrastructure.log.StreamLog, org.corfudb.infrastructure.log.StreamLogWithRankedAddressSpace)
  • org.corfudb.infrastructure.log.StreamLogFiles.Checksum
  • org.corfudb.runtime.view.StreamOptions
  • org.corfudb.runtime.view.StreamOptions.StreamOptionsBuilder
  • org.corfudb.generator.distributions.Streams (implements org.corfudb.generator.distributions.DataSet)
  • org.corfudb.protocols.wireprotocol.StreamsAddressRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.StreamsAddressResponse (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.runtime.object.StreamViewSMRAdapter (implements org.corfudb.runtime.object.ISMRStream)
  • org.corfudb.generator.StringIndexer (implements org.corfudb.runtime.collections.CorfuTable.IndexRegistry<K,V>)
  • org.corfudb.protocols.wireprotocol.TailsRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.TailsResponse (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.runtime.view.stream.ThreadSafeStreamView (implements org.corfudb.runtime.view.stream.IStreamView)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Error
      • org.corfudb.runtime.exceptions.unrecoverable.UnrecoverableCorfuError
        • org.corfudb.runtime.exceptions.unrecoverable.SystemUnavailableError
        • org.corfudb.runtime.exceptions.unrecoverable.UnrecoverableCorfuInterruptedError
    • java.lang.Exception
      • org.corfudb.runtime.exceptions.AlreadyBootstrappedException
      • org.corfudb.protocols.wireprotocol.ExceptionMsg.DeserializationFailedException
      • org.corfudb.protocols.wireprotocol.ExceptionMsg.SerializationFailedException
      • org.corfudb.runtime.exceptions.HoleFillRequiredException
      • org.corfudb.runtime.exceptions.NoBootstrapException
      • org.corfudb.runtime.exceptions.OutrankedException
      • org.corfudb.util.retry.RetryNeededException
      • java.lang.RuntimeException
        • org.corfudb.runtime.exceptions.FastObjectLoaderException
        • org.corfudb.runtime.exceptions.LayoutModificationException
        • org.corfudb.runtime.exceptions.LogUnitException
          • org.corfudb.runtime.exceptions.AppendException
          • org.corfudb.runtime.exceptions.DataCorruptionException
          • org.corfudb.runtime.exceptions.DataOutrankedException
          • org.corfudb.runtime.exceptions.OutOfSpaceException
          • org.corfudb.runtime.exceptions.OverwriteException
          • org.corfudb.runtime.exceptions.TrimmedException
            • org.corfudb.runtime.exceptions.TrimmedUpcallException
          • org.corfudb.runtime.exceptions.ValueAdoptedException
        • org.corfudb.runtime.exceptions.NetworkException
        • org.corfudb.universe.node.NodeException
        • org.corfudb.runtime.exceptions.NoRollbackException
        • org.corfudb.runtime.exceptions.QuorumUnreachableException
        • org.corfudb.runtime.exceptions.RecoveryException
        • org.corfudb.runtime.exceptions.RetryExhaustedException
        • org.corfudb.runtime.exceptions.SerializerException
        • org.corfudb.runtime.exceptions.ServerNotReadyException
        • org.corfudb.runtime.exceptions.StaleTokenException
        • org.corfudb.runtime.exceptions.TransactionAbortedException
        • org.corfudb.universe.universe.UniverseException
        • org.corfudb.runtime.exceptions.UnreachableClusterException
        • org.corfudb.runtime.exceptions.WorkflowException
        • org.corfudb.runtime.exceptions.WorkflowResultUnknownException
        • org.corfudb.runtime.exceptions.WriteSizeException
        • org.corfudb.runtime.exceptions.WrongClusterException
        • org.corfudb.runtime.exceptions.WrongEpochException
  • org.corfudb.security.tls.TlsUtils
  • org.corfudb.protocols.wireprotocol.Token (implements java.lang.Comparable<T>, org.corfudb.protocols.wireprotocol.IToken)
  • org.corfudb.protocols.wireprotocol.TokenRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.protocols.wireprotocol.TokenResponse (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>, org.corfudb.protocols.wireprotocol.IToken)
  • org.corfudb.runtime.object.transactions.Transaction
  • org.corfudb.runtime.object.transactions.TransactionalContext
  • org.corfudb.protocols.wireprotocol.TrimRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • javax.net.ssl.TrustManagerFactory
    • io.netty.handler.ssl.util.SimpleTrustManagerFactory
      • org.corfudb.security.tls.ReloadableTrustManagerFactory
  • org.corfudb.protocols.wireprotocol.TxResolutionInfo (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
  • org.corfudb.universe.UniverseFactory
  • org.corfudb.universe.universe.UniverseParams
    • org.corfudb.universe.universe.vm.VmUniverseParams
  • org.corfudb.util.Utils
  • org.corfudb.util.UuidUtils
  • org.corfudb.util.Version
  • org.corfudb.protocols.wireprotocol.VersionInfo
  • org.corfudb.runtime.object.VersionLockedObject<T>
  • org.corfudb.runtime.ViewsGarbageCollector
  • org.corfudb.universe.node.stress.vm.VmStress (implements org.corfudb.universe.node.stress.Stress)
  • org.corfudb.runtime.view.workflows.WorkflowRequest
    • org.corfudb.runtime.view.workflows.AddNode
    • org.corfudb.runtime.view.workflows.HealNode
    • org.corfudb.runtime.view.workflows.RemoveNode
      • org.corfudb.runtime.view.workflows.ForceRemoveNode
    • org.corfudb.runtime.view.workflows.RestoreRedundancyMergeSegments
  • org.corfudb.protocols.wireprotocol.WriteRequest (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>, org.corfudb.protocols.wireprotocol.IMetadata)
  • org.corfudb.runtime.object.transactions.WriteSetSMRStream (implements org.corfudb.runtime.object.ISMRStream)

Interface Hierarchy

• org.corfudb.runtime.view.AbstractView.LayoutFunction<V,R,A,B,C,D>
• org.corfudb.universe.scenario.action.Action<R>
• java.lang.AutoCloseable
  • org.corfudb.infrastructure.log.MultiReadWriteLock.AutoCloseableLock
• java.util.function.BiFunction<T,U,R>
  • org.corfudb.runtime.collections.CorfuTable.IndexFunction<K,V,I>
  • org.corfudb.runtime.collections.CorfuTable.MultiValueIndexFunction<K,V,I>
• org.corfudb.comm.ChannelImplementation.EventLoopGroupGenerator
• org.corfudb.runtime.clients.ClientMsgHandler.Handler<T>
• org.corfudb.infrastructure.management.ClusterAdvisor
• java.lang.Comparable<T>
  • org.corfudb.universe.node.server.CorfuServer (also extends org.corfudb.universe.node.Node)
  • org.corfudb.protocols.wireprotocol.ILogData (also extends org.corfudb.protocols.wireprotocol.IMetadata)
  • org.corfudb.universe.node.Node.NodeParams<T>
• org.corfudb.infrastructure.CorfuServer.BootstrapConfigurer
• org.corfudb.runtime.collections.CorfuTable.IndexSpecification<K,V,I,P>
• org.corfudb.runtime.collections.CorfuTable.ProjectionFunction<K,V,I,P>
• org.corfudb.generator.distributions.DataSet
• org.corfudb.universe.scenario.fixture.Fixture<T>
• org.corfudb.universe.scenario.fixture.Fixtures
• org.corfudb.universe.group.Group
  • org.corfudb.universe.group.cluster.Cluster
    • org.corfudb.universe.group.cluster.CorfuCluster
  • org.corfudb.universe.group.cluster.CorfuCluster
• org.corfudb.universe.group.Group.GroupParams
• org.corfudb.runtime.clients.IClient
• org.corfudb.runtime.clients.IClientRouter
• org.corfudb.runtime.object.IConflictFunction
• org.corfudb.util.serializer.ICorfuHashable
• org.corfudb.protocols.wireprotocol.ICorfuPayload<T>
  • org.corfudb.protocols.wireprotocol.ITypedEnum<T>
• org.corfudb.protocols.wireprotocol.ICorfuPayload.PayloadConstructor<T>
• org.corfudb.util.serializer.ICorfuSerializable
• org.corfudb.runtime.object.ICorfuSMR<T>
• org.corfudb.runtime.object.ICorfuSMRAccess<R,T>
• org.corfudb.runtime.object.ICorfuSMRProxy<T>
  • org.corfudb.runtime.object.ICorfuSMRProxyInternal<T>
• org.corfudb.runtime.object.ICorfuSMRProxyWrapper<T>
• org.corfudb.runtime.object.ICorfuSMRUpcallTarget<R>
• org.corfudb.infrastructure.IDataStore
• org.corfudb.infrastructure.management.IDetector
• org.corfudb.runtime.view.IFailureHandlerPolicy
• org.corfudb.runtime.clients.IHandler<C>
• org.corfudb.runtime.view.replication.IHoleFillPolicy
• org.corfudb.protocols.wireprotocol.IMetadata
  • org.corfudb.protocols.wireprotocol.ILogData (also extends java.lang.Comparable<T>)
• org.corfudb.runtime.object.IObjectBuilder<T>
• org.corfudb.runtime.view.IReconfigurationHandlerPolicy
• org.corfudb.runtime.view.replication.IReplicationProtocol
• org.corfudb.util.retry.IRetry<E,F,G,H,O,A>
• org.corfudb.util.retry.IRetryable<E,F,G,H,T>
• org.corfudb.util.serializer.ISerializer
• org.corfudb.infrastructure.IServerRouter
• org.corfudb.protocols.logprotocol.ISMRConsumable
• org.corfudb.runtime.collections.ISMRObject
  • org.corfudb.runtime.collections.ISMRMap<K,V> (also extends java.util.Map<K,V>)
• org.corfudb.runtime.object.ISMRStream
• java.lang.Iterable<T>
  • org.corfudb.runtime.collections.CorfuTable.IndexRegistry<K,V>
• java.util.Iterator<E>
  • org.corfudb.runtime.view.stream.IStreamView
• org.corfudb.protocols.wireprotocol.IToken
• org.corfudb.runtime.object.IUndoFunction<R>
• org.corfudb.runtime.object.IUndoRecordFunction<R>
• org.corfudb.infrastructure.orchestrator.IWorkflow
• java.util.Map<K,V>
  • org.corfudb.runtime.collections.ICorfuMap<K,V>
  • org.corfudb.runtime.collections.ISMRMap<K,V> (also extends org.corfudb.runtime.collections.ISMRObject)
• org.corfudb.infrastructure.MonitoringService
• org.corfudb.universe.node.Node
  • org.corfudb.universe.node.client.CorfuClient
  • org.corfudb.universe.node.server.CorfuServer (also extends java.lang.Comparable<T>)
• org.corfudb.protocols.wireprotocol.orchestrator.Request
  • org.corfudb.protocols.wireprotocol.orchestrator.CreateRequest
• org.corfudb.protocols.wireprotocol.orchestrator.Response
• org.corfudb.universe.scenario.spec.Spec<T,R>
• org.corfudb.infrastructure.log.StreamLog
  • org.corfudb.infrastructure.log.StreamLogWithRankedAddressSpace
• org.corfudb.universe.node.stress.Stress
• java.util.function.Supplier<T>
  • org.corfudb.runtime.collections.CorfuTable.IndexName
• org.corfudb.universe.universe.Universe

Annotation Type Hierarchy

• org.corfudb.annotations.ConflictParameter (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.Mutator (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.DontInstrument (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.CorfuObject (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.Instrumented (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.TransactionalMethod (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.InterfaceOverride (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.PassThrough (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.MutatorAccessor (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.Accessor (implements java.lang.annotation.Annotation)
• org.corfudb.annotations.InstrumentedCorfuObject (implements java.lang.annotation.Annotation)
• org.corfudb.protocols.wireprotocol.CorfuPayload (implements java.lang.annotation.Annotation)
• org.corfudb.runtime.clients.ClientHandler (implements java.lang.annotation.Annotation)
• org.corfudb.infrastructure.ServerHandler (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.corfudb.annotations.ObjectType
    • org.corfudb.annotations.ConstructorType
    • org.corfudb.annotations.StateSource
    • org.corfudb.util.Sleep
    • org.corfudb.util.NodeLocator.Protocol
    • org.corfudb.util.CorfuComponent
    • org.corfudb.protocols.logprotocol.CheckpointEntry.CheckpointEntryType
    • org.corfudb.protocols.logprotocol.CheckpointEntry.CheckpointDictKey
    • org.corfudb.protocols.logprotocol.LogEntry.LogEntryType
    • org.corfudb.protocols.wireprotocol.TokenType (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
    • org.corfudb.protocols.wireprotocol.SequencerMetrics.SequencerStatus
    • org.corfudb.protocols.wireprotocol.ClientHandshakeHandler.ClientHandshakeEvent
    • org.corfudb.protocols.wireprotocol.IMetadata.LogUnitMetadataType (implements org.corfudb.protocols.wireprotocol.ITypedEnum<T>)
    • org.corfudb.protocols.wireprotocol.DataType (implements org.corfudb.protocols.wireprotocol.ICorfuPayload<T>)
    • org.corfudb.protocols.wireprotocol.CorfuMsgType
    • org.corfudb.protocols.wireprotocol.orchestrator.OrchestratorResponseType
    • org.corfudb.protocols.wireprotocol.orchestrator.OrchestratorRequestType
    • org.corfudb.protocols.wireprotocol.failuredetector.NodeConnectivity.NodeConnectivityType
    • org.corfudb.protocols.wireprotocol.failuredetector.NodeConnectivity.ConnectionStatus
    • org.corfudb.protocols.wireprotocol.failuredetector.FailureDetectorMetrics.FailureDetectorAction
    • org.corfudb.runtime.object.transactions.TransactionType
    • org.corfudb.runtime.view.ClusterStatusReport.NodeStatus
    • org.corfudb.runtime.view.ClusterStatusReport.ClusterStatus
    • org.corfudb.runtime.view.ClusterStatusReport.ConnectivityStatus
    • org.corfudb.runtime.view.ClusterStatusReport.ClusterStatusReliability
    • org.corfudb.runtime.view.Layout.ReplicationMode
    • org.corfudb.runtime.view.ObjectOpenOptions
    • org.corfudb.runtime.view.CacheOption
    • org.corfudb.runtime.view.stream.AbstractQueuedStreamView.BackpointerOp
    • org.corfudb.runtime.view.stream.IStreamView.SearchDirection
    • org.corfudb.runtime.collections.ISMRMap.UndoNullable
    • org.corfudb.runtime.exceptions.AbortCause
    • org.corfudb.runtime.exceptions.OverwriteCause
    • org.corfudb.comm.ChannelImplementation
    • org.corfudb.infrastructure.RemoteMonitoringService.DetectorTask
    • org.corfudb.infrastructure.BatchWriterOperation.Type
    • org.corfudb.infrastructure.AbstractServer.ServerState
    • org.corfudb.infrastructure.management.ClusterType
    • org.corfudb.infrastructure.orchestrator.ActionStatus
    • org.corfudb.universe.universe.Universe.UniverseMode
    • org.corfudb.universe.node.server.CorfuServer.Mode
    • org.corfudb.universe.node.server.CorfuServer.Persistence
    • org.corfudb.universe.node.Node.NodeType