Package | Description |
---|---|
com.bigdata.ha |
This package extends
com.bigdata.quorum to define local and
Remote interfaces for highly available services. |
com.bigdata.ha.msg |
Interfaces and implementations for HA message objects.
|
com.bigdata.journal |
The journal is an append-only persistence capable data structure
supporting atomic commit, named indices, and transactions.
|
Modifier and Type | Method and Description |
---|---|
Future<Void> |
QuorumServiceBase.receiveAndReplicate(IHASyncRequest req,
IHASendState snd,
IHAWriteMessage msg) |
Future<Void> |
QuorumPipelineImpl.receiveAndReplicate(IHASyncRequest req,
IHASendState snd,
IHAWriteMessage msg) |
Future<Void> |
HAPipelineGlue.receiveAndReplicate(IHASyncRequest req,
IHASendState snd,
IHAWriteMessage msg)
Accept metadata describing an NIO buffer transfer along the write
pipeline.
|
Future<Void> |
QuorumPipeline.receiveAndReplicate(IHASyncRequest req,
IHASendState snd,
IHAWriteMessage msg)
Return a
Future for a task which will replicate an NIO buffer
along the write pipeline. |
Modifier and Type | Class and Description |
---|---|
class |
HASendState |
Modifier and Type | Method and Description |
---|---|
static IHASendState |
HASendState.decode(byte[] a)
Decode the value returned by
HASendState.getMarker() . |
IHASendState |
HAMessageWrapper.getHASendState() |
IHASendState |
IHAMessageWrapper.getHASendState()
Return information about the state of the sending service.
|
Constructor and Description |
---|
HAMessageWrapper(IHASyncRequest req,
IHASendState snd,
IHAWriteMessageBase msg) |
Modifier and Type | Method and Description |
---|---|
Future<Void> |
AbstractJournal.BasicHA.receiveAndReplicate(IHASyncRequest req,
IHASendState snd,
IHAWriteMessage msg) |
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.