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.quorum |
This package defines interfaces and implementations for a quorum of highly
available services.
|
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. |
Modifier and Type | Class and Description |
---|---|
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.
|
Modifier and Type | Field and Description |
---|---|
protected QuorumMember<S> |
QuorumReadImpl.member |
Constructor and Description |
---|
QuorumCommitImpl(QuorumMember<S> member) |
QuorumPipelineImpl(QuorumMember<S> member) |
QuorumReadImpl(QuorumMember<S> member) |
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. |
Modifier and Type | Class and Description |
---|---|
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 . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractQuorumMember<S extends Remote>
Abstract base class for a
QuorumMember . |
Modifier and Type | Method and Description |
---|---|
QuorumMember<S> |
Quorum.getMember()
Return the
QuorumMember iff the quorum is running. |
QuorumMember<S> |
AbstractQuorum.getMember() |
QuorumMember<?> |
MockQuorumFixture.getMember(UUID serviceId)
Resolve a known
QuorumMember for the fixture. |
QuorumMember<S> |
QuorumActor.getQuorumMember()
The service on whose behalf this class is acting.
|
QuorumMember<S> |
AbstractQuorum.QuorumActorBase.getQuorumMember() |
Modifier and Type | Method and Description |
---|---|
QuorumActor<S,QuorumMember<S>> |
QuorumMember.getActor()
Return the actor for this
QuorumMember . |
QuorumActor<S,QuorumMember<S>> |
AbstractQuorumMember.getActor()
Return the actor for this
QuorumMember (it is allocated by
AbstractQuorum.start(QuorumClient) ). |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.