Package | Description |
---|---|
com.hazelcast.cluster.impl | |
com.hazelcast.crdt |
This package contains CRDT (conflict-free replicated data type)
implementations based on the Hazelcast infrastructure.
|
com.hazelcast.crdt.pncounter |
This package contains the PN (Positive-Negative) CRDT counter
implementation.
|
com.hazelcast.crdt.pncounter.operations |
Contains the operations for the
PNCounter member-side
implementation. |
Modifier and Type | Method and Description |
---|---|
boolean |
VectorClock.isAfter(VectorClock other)
Returns
true if this vector clock is causally strictly after the
provided vector clock. |
void |
VectorClock.merge(VectorClock other)
Merges the provided vector clock into this one by taking the maximum of
the logical timestamps for each replica.
|
Constructor and Description |
---|
VectorClock(VectorClock from) |
Modifier and Type | Method and Description |
---|---|
VectorClock |
CRDT.getCurrentVectorClock()
Returns the current vector clock which reflects the current CRDT state.
|
Modifier and Type | Method and Description |
---|---|
Map<String,VectorClock> |
CRDTReplicationContainer.getVectorClocks()
Returns the vector clocks for the CRDTs replicated by the replication
operation.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CRDTReplicationAwareService.clearCRDTState(Map<String,VectorClock> vectorClocks)
Removes all of the CRDTs with vector clocks equal to the provided vector
clocks.
|
CRDTReplicationContainer |
CRDTReplicationAwareService.prepareReplicationOperation(Map<String,VectorClock> lastReplicatedVectorClock,
int targetIndex)
Returns a replication operation for the provided vector clocks.
|
Constructor and Description |
---|
CRDTReplicationContainer(Operation operation,
Map<String,VectorClock> vectorClocks) |
Modifier and Type | Method and Description |
---|---|
VectorClock |
PNCounterImpl.getCurrentVectorClock() |
Modifier and Type | Method and Description |
---|---|
CRDTTimestampedLong |
PNCounterImpl.addAndGet(long delta,
VectorClock observedTimestamps)
Adds the given value to the current value.
|
CRDTTimestampedLong |
PNCounterImpl.get(VectorClock observedTimestamps)
Returns the current value of the counter.
|
CRDTTimestampedLong |
PNCounterImpl.getAndAdd(long delta,
VectorClock observedTimestamps)
Adds the given value to the current value.
|
CRDTTimestampedLong |
PNCounterImpl.getAndSubtract(long delta,
VectorClock observedTimestamps)
Subtracts the given value from the current value.
|
boolean |
PNCounterImpl.markMigrated(VectorClock vectorClock)
Marks this CRDT as migrated.
|
CRDTTimestampedLong |
PNCounterImpl.subtractAndGet(long delta,
VectorClock observedTimestamps)
Subtracts the given value from the current value.
|
Modifier and Type | Method and Description |
---|---|
boolean |
PNCounterService.clearCRDTState(Map<String,VectorClock> vectorClocks) |
CRDTReplicationContainer |
PNCounterService.prepareReplicationOperation(Map<String,VectorClock> previouslyReplicatedVectorClocks,
int targetIndex) |
Modifier and Type | Method and Description |
---|---|
VectorClock |
CRDTTimestampedLong.getVectorClock() |
Modifier and Type | Method and Description |
---|---|
void |
CRDTTimestampedLong.setVectorClock(VectorClock vectorClock) |
Constructor and Description |
---|
AddOperation(String name,
long delta,
boolean getBeforeUpdate,
VectorClock observedClock)
Creates the addition operation.
|
CRDTTimestampedLong(long value,
VectorClock vectorClock) |
GetOperation(String name,
VectorClock observedClock)
Constructs the operation.
|
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.