Uses of Interface
com.bigdata.ha.HAGlue

Packages that use HAGlue

Package	Description
com.bigdata.ha	This package extends com.bigdata.quorum to define local and Remote interfaces for highly available services.
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
com.bigdata.service	This package provides implementations of bigdata services (metadata service, data service, transaction manager service.

Uses of HAGlue in com.bigdata.ha

Classes in com.bigdata.ha with type parameters of type HAGlue

Modifier and Type	Interface and Description
interface	QuorumService<S extends HAGlue> A non-remote interface for a member service in a Quorum defining methods to support service specific high availability operations such as reading on another member of the quorum, the 2-phase quorum commit protocol, replicating writes, etc.
class	QuorumServiceBase<S extends HAGlue,L extends AbstractJournal> Abstract implementation provides the logic for distributing messages for the quorum 2-phase commit protocol, failover reads, etc.

Constructor parameters in com.bigdata.ha with type arguments of type HAGlue

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

Uses of HAGlue in com.bigdata.journal

Classes in com.bigdata.journal that implement HAGlue

Modifier and Type	Class and Description
protected class	AbstractJournal.BasicHA Implementation hooks into the various low-level operations required to support HA for the journal.

Methods in com.bigdata.journal that return HAGlue

Modifier and Type	Method and Description
protected HAGlue	AbstractJournal.newHAGlue(UUID serviceId) Factory for the HADelegate object for this AbstractJournal.

Methods in com.bigdata.journal that return types with arguments of type HAGlue

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

Method parameters in com.bigdata.journal with type arguments of type HAGlue

Modifier and Type	Method and Description
protected void	AbstractJournal.doLocalCommit(QuorumService<HAGlue> localService, IRootBlockView rootBlock) Local commit protocol (HA).
void	WORMStrategy.writeOnStream(OutputStream os, AbstractJournal.ISnapshotData snapshotData, Quorum<HAGlue,QuorumService<HAGlue>> quorum, long token)
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	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)
void	RWStrategy.writeOnStream(OutputStream os, AbstractJournal.ISnapshotData snapshotData, Quorum<HAGlue,QuorumService<HAGlue>> quorum, long token)

Constructor parameters in com.bigdata.journal with type arguments of type HAGlue

Constructor and Description
AbstractJournal.BasicHA.VoteNoTask(QuorumService<HAGlue> localService)
AbstractJournal(Properties properties, Quorum<HAGlue,QuorumService<HAGlue>> quorum) Create or re-open a journal as part of a highly available Quorum.
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)
Journal(Properties properties, Quorum<HAGlue,QuorumService<HAGlue>> quorum)

Uses of HAGlue in com.bigdata.quorum

Constructor parameters in com.bigdata.quorum with type arguments of type HAGlue

Constructor and Description
QuorumTokenTransitions(long currentQuorumToken, long newQuorumToken, QuorumService<HAGlue> service, long haReady)

Uses of HAGlue in com.bigdata.rwstore

Method parameters in com.bigdata.rwstore with type arguments of type HAGlue

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

Uses of HAGlue in com.bigdata.service

Methods in com.bigdata.service with parameters of type HAGlue

Modifier and Type	Method and Description
abstract Callable<IHANotifyReleaseTimeResponse>	AbstractHATransactionService.newGatherMinimumVisibleCommitTimeTask(HAGlue leader, UUID serviceId, IHAGatherReleaseTimeRequest req) Factory for the Gather task that will be executed by the follower.