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 |
---|---|
protected abstract void |
QuorumServiceBase.handleReplicatedWrite(IHASyncRequest req,
IHAWriteMessage msg,
ByteBuffer data)
Core implementation handles the message and payload when received on a
service.
|
protected abstract void |
QuorumPipelineImpl.handleReplicatedWrite(IHASyncRequest req,
IHAWriteMessage msg,
ByteBuffer data)
Core implementation handles the message and payload when received on a
service.
|
protected abstract void |
QuorumServiceBase.incReceive(IHASyncRequest req,
IHAWriteMessage msg,
int nreads,
int rdlen,
int rem)
Core implementation of callback for monitoring progress of replicated
writes.
|
protected abstract void |
QuorumPipelineImpl.incReceive(IHASyncRequest req,
IHAWriteMessage msg,
int nreads,
int rdlen,
int rem)
Notify that some payload bytes have been incrementally received for an
IHAMessage . |
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. |
Future<Void> |
QuorumServiceBase.replicate(IHASyncRequest req,
IHAWriteMessage msg,
ByteBuffer b) |
Future<Void> |
QuorumPipelineImpl.replicate(IHASyncRequest req,
IHAWriteMessage msg,
ByteBuffer b) |
Future<Void> |
QuorumPipeline.replicate(IHASyncRequest req,
IHAWriteMessage msg,
ByteBuffer b)
Return a
Future for a task which will replicate an NIO buffer
along the write pipeline. |
Modifier and Type | Interface and Description |
---|---|
interface |
IHALogRequest
Message requesting the root blocks and other metadata for an HA Log file.
|
interface |
IHARebuildRequest
Message requesting raw blocks from the backing file for a store.
|
Modifier and Type | Class and Description |
---|---|
class |
HALogRequest |
class |
HARebuildRequest |
Modifier and Type | Method and Description |
---|---|
IHASyncRequest |
HAMessageWrapper.getHASyncRequest() |
IHASyncRequest |
IHAMessageWrapper.getHASyncRequest()
Return the optional
IHASyncRequest . |
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.