Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.service.paxos |
Modifier and Type | Method and Description |
---|---|
static void |
SystemKeyspace.savePaxosCommit(Commit commit) |
static void |
SystemKeyspace.savePaxosPromise(Commit promise) |
static void |
SystemKeyspace.savePaxosProposal(Commit proposal) |
Modifier and Type | Field and Description |
---|---|
Commit |
PrepareResponse.inProgressCommit |
Commit |
PrepareCallback.mostRecentCommit |
Commit |
PrepareResponse.mostRecentCommit |
Commit |
PrepareCallback.mostRecentInProgressCommit |
Commit |
PrepareCallback.mostRecentInProgressCommitWithUpdate |
Modifier and Type | Method and Description |
---|---|
Commit |
Commit.CommitSerializer.deserialize(DataInputPlus in,
int version) |
static Commit |
Commit.emptyCommit(DecoratedKey key,
CFMetaData metadata) |
static Commit |
Commit.newPrepare(DecoratedKey key,
CFMetaData metadata,
java.util.UUID ballot) |
static Commit |
Commit.newProposal(java.util.UUID ballot,
PartitionUpdate update) |
Modifier and Type | Method and Description |
---|---|
static void |
PaxosState.commit(Commit proposal) |
boolean |
Commit.isAfter(Commit other) |
static PrepareResponse |
PaxosState.prepare(Commit toPrepare) |
static java.lang.Boolean |
PaxosState.propose(Commit proposal) |
void |
Commit.CommitSerializer.serialize(Commit commit,
DataOutputPlus out,
int version) |
long |
Commit.CommitSerializer.serializedSize(Commit commit,
int version) |
Modifier and Type | Method and Description |
---|---|
void |
CommitVerbHandler.doVerb(MessageIn<Commit> message,
int id) |
void |
PrepareVerbHandler.doVerb(MessageIn<Commit> message,
int id) |
void |
ProposeVerbHandler.doVerb(MessageIn<Commit> message,
int id) |
Constructor and Description |
---|
PaxosState(Commit promised,
Commit accepted,
Commit mostRecentCommit) |
PrepareResponse(boolean promised,
Commit inProgressCommit,
Commit mostRecentCommit) |
Copyright © 2020 The Apache Software Foundation