Package | Description |
---|---|
org.opendaylight.controller.cluster.access.commands |
This package defines the messages used to interact with the CDS backend implementation.
|
org.opendaylight.controller.cluster.access.concepts |
This package defines basic concepts used to interact with the CDS backend implementation.
|
org.opendaylight.controller.cluster.databroker.actors.dds |
This package contains implementation required by the DistributedDataStore frontend.
|
org.opendaylight.controller.cluster.datastore | |
org.opendaylight.controller.cluster.datastore.messages | |
org.opendaylight.controller.cluster.datastore.persisted |
Persisted backend structures.
|
Modifier and Type | Method and Description |
---|---|
TransactionIdentifier |
ModifyTransactionRequestBuilder.getIdentifier() |
Constructor and Description |
---|
AbortLocalTransactionRequest(TransactionIdentifier identifier,
akka.actor.ActorRef replyTo) |
CommitLocalTransactionRequest(TransactionIdentifier identifier,
long sequence,
akka.actor.ActorRef replyTo,
org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification mod,
Exception delayedFailure,
boolean coordinated) |
ExistsTransactionRequest(TransactionIdentifier identifier,
long sequence,
akka.actor.ActorRef replyTo,
org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier path,
boolean snapshotOnly) |
ExistsTransactionSuccess(TransactionIdentifier target,
long sequence,
boolean exists) |
IncrementTransactionSequenceRequest(TransactionIdentifier identifier,
long sequence,
akka.actor.ActorRef replyTo,
boolean snapshotOnly,
long increment) |
IncrementTransactionSequenceSuccess(TransactionIdentifier target,
long sequence) |
ModifyTransactionRequestBuilder(TransactionIdentifier identifier,
akka.actor.ActorRef replyTo) |
ModifyTransactionSuccess(TransactionIdentifier identifier,
long sequence) |
ReadTransactionRequest(TransactionIdentifier identifier,
long sequence,
akka.actor.ActorRef replyTo,
org.opendaylight.yangtools.yang.data.api.YangInstanceIdentifier path,
boolean snapshotOnly) |
ReadTransactionSuccess(TransactionIdentifier identifier,
long sequence,
Optional<org.opendaylight.yangtools.yang.data.api.schema.NormalizedNode<?,?>> data) |
TransactionAbortRequest(TransactionIdentifier target,
long sequence,
akka.actor.ActorRef replyTo) |
TransactionAbortSuccess(TransactionIdentifier identifier,
long sequence) |
TransactionCanCommitSuccess(TransactionIdentifier identifier,
long sequence) |
TransactionCommitSuccess(TransactionIdentifier identifier,
long sequence) |
TransactionDoCommitRequest(TransactionIdentifier target,
long sequence,
akka.actor.ActorRef replyTo) |
TransactionPreCommitRequest(TransactionIdentifier target,
long sequence,
akka.actor.ActorRef replyTo) |
TransactionPreCommitSuccess(TransactionIdentifier identifier,
long sequence) |
TransactionPurgeRequest(TransactionIdentifier target,
long sequence,
akka.actor.ActorRef replyTo) |
TransactionPurgeResponse(TransactionIdentifier identifier,
long sequence) |
Modifier and Type | Method and Description |
---|---|
static TransactionIdentifier |
TransactionIdentifier.readFrom(DataInput in) |
Modifier and Type | Method and Description |
---|---|
TransactionIdentifier |
AbstractClientHandle.getIdentifier() |
Modifier and Type | Method and Description |
---|---|
protected TransactionIdentifier |
ShardTransaction.getTransactionId() |
Constructor and Description |
---|
RemoteTransactionContext(TransactionIdentifier identifier,
akka.actor.ActorSelection actor,
ActorContext actorContext,
short remoteTransactionVersion,
OperationLimiter limiter) |
ShardTransaction(akka.actor.ActorRef shardActor,
ShardStats shardStats,
TransactionIdentifier transactionId) |
ThreePhaseCommitCohortProxy(ActorContext actorContext,
List<org.opendaylight.controller.cluster.datastore.ThreePhaseCommitCohortProxy.CohortInfo> cohorts,
TransactionIdentifier transactionId) |
TransactionReadyReplyMapper(ActorContext actorContext,
TransactionIdentifier identifier) |
Modifier and Type | Method and Description |
---|---|
TransactionIdentifier |
CreateTransactionReply.getTransactionId() |
TransactionIdentifier |
CreateTransaction.getTransactionId() |
TransactionIdentifier |
ForwardedReadyTransaction.getTransactionId() |
TransactionIdentifier |
ReadyLocalTransaction.getTransactionId() |
TransactionIdentifier |
BatchedModifications.getTransactionId() |
TransactionIdentifier |
AbstractThreePhaseCommitMessage.getTransactionId() |
Constructor and Description |
---|
AbortTransaction(TransactionIdentifier transactionID,
short version) |
AbstractThreePhaseCommitMessage(TransactionIdentifier transactionId,
short version) |
BatchedModifications(TransactionIdentifier transactionId,
short version) |
CanCommitTransaction(TransactionIdentifier transactionID,
short version) |
CommitTransaction(TransactionIdentifier transactionID,
short version) |
CreateTransaction(TransactionIdentifier transactionId,
int transactionType,
short version) |
CreateTransactionReply(String transactionPath,
TransactionIdentifier transactionId,
short version) |
ForwardedReadyTransaction(TransactionIdentifier transactionId,
short txnClientVersion,
ReadWriteShardDataTreeTransaction transaction,
boolean doImmediateCommit,
Optional<SortedSet<String>> participatingShardNames) |
ReadyLocalTransaction(TransactionIdentifier transactionId,
org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeModification modification,
boolean doCommitOnReady,
Optional<SortedSet<String>> participatingShardNames) |
Modifier and Type | Method and Description |
---|---|
Map.Entry<TransactionIdentifier,org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate> |
CommitTransactionPayload.getCandidate() |
Modifier and Type | Method and Description |
---|---|
static CommitTransactionPayload |
CommitTransactionPayload.create(TransactionIdentifier transactionId,
org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate candidate) |
static CommitTransactionPayload |
CommitTransactionPayload.create(TransactionIdentifier transactionId,
org.opendaylight.yangtools.yang.data.api.schema.tree.DataTreeCandidate candidate,
int initialSerializedBufferCapacity) |
static PurgeTransactionPayload |
PurgeTransactionPayload.create(TransactionIdentifier transactionId,
int initialSerializedBufferCapacity) |
static AbortTransactionPayload |
AbortTransactionPayload.create(TransactionIdentifier transactionId,
int initialSerializedBufferCapacity) |
Copyright © 2019 OpenDaylight. All rights reserved.