Package uk.sky.cqlmigrate

Class CassandraLockConfig.CassandraLockConfigBuilder

java.lang.Object

uk.sky.cqlmigrate.LockConfig.LockConfigBuilder

uk.sky.cqlmigrate.CassandraLockConfig.CassandraLockConfigBuilder

Enclosing class:

CassandraLockConfig

public static class CassandraLockConfig.CassandraLockConfigBuilder
extends LockConfig.LockConfigBuilder

Field Summary

Fields inherited from class uk.sky.cqlmigrate.LockConfig.LockConfigBuilder

clientId, pollingInterval, timeout, unlockOnFailure

Method Summary

Modifier and Type	Method	Description
CassandraLockConfig	build()
CassandraLockConfig.CassandraLockConfigBuilder	unlockOnFailure()	Release the lock in case of failure.
CassandraLockConfig.CassandraLockConfigBuilder	withConsistencyLevel(com.datastax.driver.core.ConsistencyLevel consistencyLevel)
CassandraLockConfig.CassandraLockConfigBuilder	withLockKeyspace(java.lang.String lockKeyspace)
CassandraLockConfig.CassandraLockConfigBuilder	withPollingInterval(java.time.Duration pollingInterval)	Duration to wait after each attempt to acquire the lock.
CassandraLockConfig.CassandraLockConfigBuilder	withTimeout(java.time.Duration timeout)	Duration to attempt to acquire lock for.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

withPollingInterval

public CassandraLockConfig.CassandraLockConfigBuilder withPollingInterval(java.time.Duration pollingInterval)

Description copied from class: LockConfig.LockConfigBuilder

Duration to wait after each attempt to acquire the lock.

Overrides:

withPollingInterval in class LockConfig.LockConfigBuilder

Parameters:

pollingInterval - defaults to 500 milliseconds.

Returns:

this

withTimeout

public CassandraLockConfig.CassandraLockConfigBuilder withTimeout(java.time.Duration timeout)

Description copied from class: LockConfig.LockConfigBuilder

Duration to attempt to acquire lock for.

Overrides:

withTimeout in class LockConfig.LockConfigBuilder

Parameters:

timeout - defaults to 1 minute

Returns:

this

unlockOnFailure

public CassandraLockConfig.CassandraLockConfigBuilder unlockOnFailure()

Description copied from class: LockConfig.LockConfigBuilder

Release the lock in case of failure. Note: default behavior is to leave the lock behind if any failures occurred during migration. This was done to prevent accidental data corruption and bring manual attention to the problem. Use 'unlockOnFailure' to override the default behavior and force cqlmigrate to release the lock.

Overrides:

unlockOnFailure in class LockConfig.LockConfigBuilder

Returns:

this

withConsistencyLevel

public CassandraLockConfig.CassandraLockConfigBuilder withConsistencyLevel(com.datastax.driver.core.ConsistencyLevel consistencyLevel)

withLockKeyspace

public CassandraLockConfig.CassandraLockConfigBuilder withLockKeyspace(java.lang.String lockKeyspace)

build

public CassandraLockConfig build()

Overrides:

build in class LockConfig.LockConfigBuilder