com.sleepycat.je.rep

Class TimeConsistencyPolicy

java.lang.Object

com.sleepycat.je.rep.TimeConsistencyPolicy

All Implemented Interfaces:

ReplicaConsistencyPolicy

public class TimeConsistencyPolicy
extends java.lang.Object
implements ReplicaConsistencyPolicy

A consistency policy which describes the amount of time the Replica is allowed to lag the Master. The application can use this policy to ensure that this node sees all transactions that were committed on the Master before the lag interval.

Effective use of this policy requires that the clocks on the Master and Replica are synchronized by using a protocol like NTP

Consistency policies are specified at either a per-transaction level through TransactionConfig.setConsistencyPolicy(com.sleepycat.je.ReplicaConsistencyPolicy) or as an replication node wide default through ReplicationConfig.setConsistencyPolicy(com.sleepycat.je.ReplicaConsistencyPolicy)

See Also:

Managing Consistency

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NAME The name:"TimeConsistencyPolicy" associated with this policy.

Constructor Summary

Constructors

Constructor and Description
TimeConsistencyPolicy(long permissibleLag, java.util.concurrent.TimeUnit permissibleLagUnit, long timeout, java.util.concurrent.TimeUnit timeoutUnit) Specifies the amount of time by which the Replica is allowed to lag the master when initiating a transaction.

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
java.lang.String	getName() Returns the name:"TimeConsistencyPolicy", associated with this policy.
long	getPermissibleLag(java.util.concurrent.TimeUnit unit) Returns the allowed time lag associated with this policy.
long	getTimeout(java.util.concurrent.TimeUnit unit) Returns the consistency timeout associated with this policy.
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

NAME

public static final java.lang.String NAME

The name:"TimeConsistencyPolicy" associated with this policy. The name can be used when constructing policy property values for use in je.properties files.

See Also:

Constant Field Values

Constructor Detail

TimeConsistencyPolicy

public TimeConsistencyPolicy(long permissibleLag,
                             java.util.concurrent.TimeUnit permissibleLagUnit,
                             long timeout,
                             java.util.concurrent.TimeUnit timeoutUnit)

Specifies the amount of time by which the Replica is allowed to lag the master when initiating a transaction. The Replica ensures that all transactions that were committed on the Master before this lag interval are available at the Replica before allowing a transaction to proceed with Environment.beginTransaction. Effective use of this policy requires that the clocks on the Master and Replica are synchronized by using a protocol like NTP.

Parameters:

permissibleLag - the time interval by which the Replica may be out of date with respect to the Master when a transaction is initiated on the Replica.

permissibleLagUnit - the TimeUnit for the permissibleLag parameter.

timeout - the amount of time to wait for the consistency to be reached.

timeoutUnit - the TimeUnit for the timeout parameter.

Throws:

java.lang.IllegalArgumentException - if the permissibleLagUnit or timeoutUnit is null.

Method Detail

getName

public java.lang.String getName()

Returns the name:"TimeConsistencyPolicy", associated with this policy.

Specified by:

getName in interface ReplicaConsistencyPolicy

See Also:

NAME

getPermissibleLag

public long getPermissibleLag(java.util.concurrent.TimeUnit unit)

Returns the allowed time lag associated with this policy.

Parameters:

unit - the TimeUnit of the returned value.

Returns:

the permissible lag time in the specified unit.

getTimeout

public long getTimeout(java.util.concurrent.TimeUnit unit)

Returns the consistency timeout associated with this policy.

Specified by:

getTimeout in interface ReplicaConsistencyPolicy

Parameters:

unit - the TimeUnit of the returned value.

Returns:

the consistency timeout in the specified unit.

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object