Package | Description |
---|---|
com.bigdata.ha |
This package extends
com.bigdata.quorum to define local and
Remote interfaces for highly available services. |
com.bigdata.quorum |
This package defines interfaces and implementations for a quorum of highly
available services.
|
com.bigdata.rdf.sail.webapp.lbs | |
com.bigdata.rdf.sail.webapp.lbs.policy | |
com.bigdata.rdf.sail.webapp.lbs.policy.counters | |
com.bigdata.rdf.sail.webapp.lbs.policy.ganglia |
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 |
FutureTaskInvariantMon<T>
A
Future that allows you to cancel a computation if an invariant is
violated. |
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 | Interface and Description |
---|---|
interface |
QuorumClient<S extends Remote>
A non-remote interface for a client which monitors the state of a quorum.
|
interface |
QuorumMember<S extends Remote>
A non-remote interface for a service which will participate in a quorum as a
member service (as opposed to a client service that merely watches the
quorum).
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractQuorumClient<S extends Remote>
Base class for
QuorumClient s. |
class |
AbstractQuorumMember<S extends Remote>
Abstract base class for a
QuorumMember . |
protected class |
MockQuorumFixture.MockQuorum.MockQuorumWatcher
Watcher propagates state changes observed in the
MockQuorumFixture2 to the MockQuorumFixture.MockQuorum . |
Modifier and Type | Method and Description |
---|---|
void |
Quorum.addListener(QuorumListener listener)
Add a listener
|
void |
AbstractQuorum.addListener(QuorumListener listener) |
void |
Quorum.removeListener(QuorumListener listener)
Remove a listener (the quorum's client is always a listener).
|
void |
AbstractQuorum.removeListener(QuorumListener listener) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractHostLBSPolicy
Abstract base class for an LBS policy that uses per-host load metrics.
|
class |
AbstractLBSPolicy
Abstract base class establishes a listener for quorum events, tracks the
services that are members of the quorum, and caches metadata about those
services (especially the requestURL at which they will respond).
|
Modifier and Type | Class and Description |
---|---|
class |
NOPLBSPolicy
This policy proxies all requests for update operations to the leader but
forwards read requests to the local service.
|
class |
RoundRobinLBSPolicy
Policy implements a round-robin over the services that are joined with the
met quorum.
|
Modifier and Type | Class and Description |
---|---|
class |
CountersLBSPolicy
Stochastically proxy the request to the services based on their load.
|
Modifier and Type | Class and Description |
---|---|
class |
GangliaLBSPolicy
Stochastically proxy the request to the services based on their load.
|
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.