Package uk.sky.cqlmigrate

Class CassandraNoOpLockConfig.CassandraNoOpLockConfigBuilder

java.lang.Object

uk.sky.cqlmigrate.LockConfig.LockConfigBuilder

uk.sky.cqlmigrate.CassandraNoOpLockConfig.CassandraNoOpLockConfigBuilder

Enclosing class:

CassandraNoOpLockConfig

public static class CassandraNoOpLockConfig.CassandraNoOpLockConfigBuilder
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
CassandraNoOpLockConfig	build()
CassandraNoOpLockConfig.CassandraNoOpLockConfigBuilder	unlockOnFailure()	Release the lock in case of failure.
CassandraNoOpLockConfig.CassandraNoOpLockConfigBuilder	withPollingInterval(java.time.Duration pollingInterval)	Duration to wait after each attempt to acquire the lock.
CassandraNoOpLockConfig.CassandraNoOpLockConfigBuilder	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 CassandraNoOpLockConfig.CassandraNoOpLockConfigBuilder 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 CassandraNoOpLockConfig.CassandraNoOpLockConfigBuilder 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 CassandraNoOpLockConfig.CassandraNoOpLockConfigBuilder 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

build

public CassandraNoOpLockConfig build()

Overrides:

build in class LockConfig.LockConfigBuilder