Package io.debezium.snapshot

Class SnapshotLockProvider

java.lang.Object

io.debezium.snapshot.SnapshotLockProvider

All Implemented Interfaces:

ServiceProvider<SnapshotLock>

public class SnapshotLockProvider
extends Object
implements ServiceProvider<SnapshotLock>

An implementation of the ServiceProvider contract for the SnapshotLock.

Author:

Mario Fiore Vitale

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOGGER
(package private) final List<SnapshotLock>	snapshotLockImplementations

Constructor Summary

Constructors

Constructor	Description
SnapshotLockProvider()
SnapshotLockProvider(List<SnapshotLock> snapshotLockImplementations)

Method Summary

Modifier and Type	Method	Description
SnapshotLock	createService(io.debezium.config.Configuration configuration, ServiceRegistry serviceRegistry)	Creates or provides a desired service.
Class<SnapshotLock>	getServiceClass()	Get the service class that should be initiated or provided.
String	snapshotLockingMode(CommonConnectorConfig configuration)

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

snapshotLockImplementations

final List<SnapshotLock> snapshotLockImplementations

Constructor Details

SnapshotLockProvider

public SnapshotLockProvider()

SnapshotLockProvider

public SnapshotLockProvider(List<SnapshotLock> snapshotLockImplementations)

Method Details

createService

public SnapshotLock createService(io.debezium.config.Configuration configuration,
 ServiceRegistry serviceRegistry)

Description copied from interface: ServiceProvider

Creates or provides a desired service.

Specified by:

createService in interface ServiceProvider<SnapshotLock>

Parameters:

configuration - the connector configuration

serviceRegistry - the service registry

Returns:

the constructed service

getServiceClass

public Class<SnapshotLock> getServiceClass()

Description copied from interface: ServiceProvider

Get the service class that should be initiated or provided. The service class should be unique in the registry.

Specified by:

getServiceClass in interface ServiceProvider<SnapshotLock>

Returns:

the service class

snapshotLockingMode

public String snapshotLockingMode(CommonConnectorConfig configuration)