Uses of Interface
com.bigdata.quorum.Quorum

Packages that use Quorum

Package	Description
com.bigdata.ha	This package extends com.bigdata.quorum to define local and Remote interfaces for highly available services.
com.bigdata.io.writecache	Low-level write cache service.
com.bigdata.journal	The journal is an append-only persistence capable data structure supporting atomic commit, named indices, and transactions.
com.bigdata.quorum	This package defines interfaces and implementations for a quorum of highly available services.
com.bigdata.rwstore

Uses of Quorum in com.bigdata.ha

Constructors in com.bigdata.ha with parameters of type Quorum

Constructor and Description
FutureTaskInvariantMon(Callable<T> callable, Quorum<HAGlue,QuorumService<HAGlue>> quorum)
FutureTaskInvariantMon(Runnable runnable, T result, Quorum<HAGlue,QuorumService<HAGlue>> quorum)
JoinedAndNonJoinedServices(Quorum<HAGlue,QuorumService<HAGlue>> quorum)

Uses of Quorum in com.bigdata.io.writecache

Methods in com.bigdata.io.writecache that return Quorum

Modifier and Type	Method and Description
protected Quorum<HAPipelineGlue,QuorumMember<HAPipelineGlue>>	WriteCacheService.getQuorum() The object which manages Quorum state changes on the behalf of this service.

Methods in com.bigdata.io.writecache with parameters of type Quorum

Modifier and Type	Method and Description
protected long	TestWORMWriteCacheService.doStressTest(int nbuffers, int nrecs, int maxreclen, double largeRecordRate, boolean useChecksums, boolean isHighlyAvailable, StoreTypeEnum storeType, Quorum quorum) A stress test for the WriteCacheService.

Constructors in com.bigdata.io.writecache with parameters of type Quorum

Constructor and Description
WriteCacheService(int nwriteBuffers, int minCleanListSize, int nreadBuffers, boolean prefixWrites, int compactionThreshold, int hotCacheSize, int hotCacheThreshold, boolean useChecksum, long fileExtent, IReopenChannel<? extends Channel> opener, Quorum quorum, IBackingReader reader) Allocates N buffers from the DirectBufferPool.

Uses of Quorum in com.bigdata.journal

Methods in com.bigdata.journal that return Quorum

Modifier and Type	Method and Description
Quorum<HAGlue,QuorumService<HAGlue>>	JournalDelegate.getQuorum()
Quorum<HAGlue,QuorumService<HAGlue>>	AbstractJournal.getQuorum()
Quorum<HAGlue,QuorumService<HAGlue>>	IJournal.getQuorum() The Quorum for this service -or- null if the service is not running with a quorum.

Methods in com.bigdata.journal with parameters of type Quorum

Modifier and Type	Method and Description
void	WORMStrategy.writeOnStream(OutputStream os, AbstractJournal.ISnapshotData snapshotData, Quorum<HAGlue,QuorumService<HAGlue>> quorum, long token)
void	IHABufferStrategy.writeOnStream(OutputStream os, AbstractJournal.ISnapshotData coreData, Quorum<HAGlue,QuorumService<HAGlue>> quorum, long token) Write a consistent snapshot of the committed state of the backing store.
void	RWStrategy.writeOnStream(OutputStream os, AbstractJournal.ISnapshotData snapshotData, Quorum<HAGlue,QuorumService<HAGlue>> quorum, long token)

Constructors in com.bigdata.journal with parameters of type Quorum

Constructor and Description
AbstractJournal(Properties properties, Quorum<HAGlue,QuorumService<HAGlue>> quorum) Create or re-open a journal as part of a highly available Quorum.
Journal(Properties properties, Quorum<HAGlue,QuorumService<HAGlue>> quorum)

Uses of Quorum in com.bigdata.quorum

Classes in com.bigdata.quorum that implement Quorum

Modifier and Type	Class and Description
class	AbstractQuorum<S extends Remote,C extends QuorumClient<S>> Abstract base class handles much of the logic for the distribution of RMI calls from the leader to the follower and for the HA write pipeline.
static class	MockQuorumFixture.MockQuorum<S extends Remote,C extends QuorumMember<S>> Mock Quorum implementation with increased visibility of some methods so we can pump state changes into the MockQuorumFixture2.

Methods in com.bigdata.quorum that return Quorum

Modifier and Type	Method and Description
Quorum<?,?>	QuorumClient.getQuorum() The quorum that is being monitored.
Quorum<?,?>	AbstractQuorumClient.getQuorum() The quorum that is being monitored.
Quorum<S,C>	QuorumActor.getQuourm() The Quorum.
Quorum<S,C>	AbstractQuorum.QuorumActorBase.getQuourm()

Methods in com.bigdata.quorum with parameters of type Quorum

Modifier and Type	Method and Description
void	QuorumClient.start(Quorum<?,?> quorum) Life cycle message sent when the client will begin to receive messages from the Quorum.
void	AbstractQuorumClient.start(Quorum<?,?> quorum)

Uses of Quorum in com.bigdata.rwstore

Methods in com.bigdata.rwstore with parameters of type Quorum

Modifier and Type	Method and Description
void	RWStore.writeOnStream(OutputStream os, AbstractJournal.ISnapshotData snapshotData, Quorum<HAGlue,QuorumService<HAGlue>> quorum, long token)
void	RWStore.writeOnStream2(OutputStream os, Set<Map.Entry<Long,byte[]>> snapshotData, Quorum<HAGlue,QuorumService<HAGlue>> quorum, long token)

Constructors in com.bigdata.rwstore with parameters of type Quorum

Constructor and Description
RWStore(FileMetadata fileMetadata, Quorum<?,?> quorum) The ALLOC_SIZES must be initialized from either the file or the properties associated with the fileMetadataView
RWWriteCacheService(int nbuffers, int minCleanListSize, int readBuffers, boolean prefixWrites, int compactionThreshold, int hotCacheSize, int hotCacheThreshold, long fileExtent, IReopenChannel<? extends Channel> opener, Quorum quorum, IBackingReader reader)