|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use VectorClock | |
---|---|
voldemort.client.protocol | Classes that abstract the serialization format for Voldemort client requests. |
voldemort.client.protocol.pb | A protocol buffers based client-side request format. |
voldemort.client.protocol.vold | Classes specific to our native Voldemort protocol. |
voldemort.rest | |
voldemort.versioning | Classes for operating on vector clocks and dealing with distributed state. |
Uses of VectorClock in voldemort.client.protocol |
---|
Methods in voldemort.client.protocol with parameters of type VectorClock | |
---|---|
void |
RequestFormat.writeDeleteRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
VectorClock version,
RequestRoutingType routingType)
|
void |
RequestFormat.writePutRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
byte[] value,
byte[] transforms,
VectorClock version,
RequestRoutingType routingType)
|
Uses of VectorClock in voldemort.client.protocol.pb |
---|
Methods in voldemort.client.protocol.pb that return VectorClock | |
---|---|
static VectorClock |
ProtoUtils.decodeClock(VProto.VectorClock encoded)
|
Methods in voldemort.client.protocol.pb with parameters of type VectorClock | |
---|---|
void |
ProtoBuffClientRequestFormat.writeDeleteRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
VectorClock version,
RequestRoutingType routingType)
|
void |
ProtoBuffClientRequestFormat.writePutRequest(java.io.DataOutputStream output,
java.lang.String storeName,
ByteArray key,
byte[] value,
byte[] transforms,
VectorClock version,
RequestRoutingType routingType)
|
Uses of VectorClock in voldemort.client.protocol.vold |
---|
Methods in voldemort.client.protocol.vold with parameters of type VectorClock | |
---|---|
void |
VoldemortNativeClientRequestFormat.writeDeleteRequest(java.io.DataOutputStream outputStream,
java.lang.String storeName,
ByteArray key,
VectorClock version,
RequestRoutingType routingType)
|
void |
VoldemortNativeClientRequestFormat.writePutRequest(java.io.DataOutputStream outputStream,
java.lang.String storeName,
ByteArray key,
byte[] value,
byte[] transforms,
VectorClock version,
RequestRoutingType routingType)
|
Uses of VectorClock in voldemort.rest |
---|
Fields in voldemort.rest declared as VectorClock | |
---|---|
protected VectorClock |
RestRequestValidator.parsedVectorClock
|
Methods in voldemort.rest that return VectorClock | |
---|---|
static VectorClock |
RestUtils.deserializeVectorClock(java.lang.String serializedVC)
|
Methods in voldemort.rest with parameters of type VectorClock | |
---|---|
static java.lang.String |
RestUtils.getSerializedVectorClock(VectorClock vc)
Function to serialize the given Vector clock into a string. |
Method parameters in voldemort.rest with type arguments of type VectorClock | |
---|---|
static java.lang.String |
RestUtils.getSerializedVectorClocks(java.util.List<VectorClock> vectorClocks)
Function to serialize the given list of Vector clocks into a string. |
Constructors in voldemort.rest with parameters of type VectorClock | |
---|---|
PutResponseSender(org.jboss.netty.channel.MessageEvent messageEvent,
VectorClock successfulPutVC)
|
|
PutResponseSender(org.jboss.netty.channel.MessageEvent messageEvent,
VectorClock successfulPutVC,
java.lang.String storeName,
ByteArray key)
Constructor called by Coordinator worker thread |
|
VectorClockWrapper(VectorClock vc)
|
Uses of VectorClock in voldemort.versioning |
---|
Methods in voldemort.versioning that return VectorClock | |
---|---|
VectorClock |
VectorClock.clone()
|
VectorClock |
VectorClock.incremented(int nodeId,
long time)
Get new vector clock based on this clock but incremented on index nodeId |
static VectorClock |
VectorClockUtils.makeClock(java.util.Set<java.lang.Integer> serverIds,
long clockValue,
long timestamp)
Generates a vector clock with the provided values |
static VectorClock |
VectorClockUtils.makeClockWithCurrentTime(java.util.Set<java.lang.Integer> serverIds)
Generates a vector clock with the provided nodes and current time stamp This clock can be used to overwrite the existing value avoiding obsolete version exceptions in most cases, except If the existing Vector Clock was generated in custom way. |
VectorClock |
VectorClock.merge(VectorClock clock)
|
Methods in voldemort.versioning with parameters of type VectorClock | |
---|---|
static Occurred |
VectorClockUtils.compare(VectorClock v1,
VectorClock v2)
Compare two VectorClocks, the outcomes will be one of the following: -- Clock 1 is BEFORE clock 2, if there exists an nodeId such that c1(nodeId) <= c2(nodeId) and there does not exist another nodeId such that c1(nodeId) > c2(nodeId). |
void |
VectorClock.copyFromVectorClock(VectorClock vc)
Function to copy values from another VectorClock. |
VectorClock |
VectorClock.merge(VectorClock clock)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |