Package io.debezium.heartbeat

Interface DebeziumHeartbeatFactory

All Known Implementing Classes:

DatabaseHeartbeatFactory, HeartbeatFactory

public interface DebeziumHeartbeatFactory

factory interface for creating the appropriate Heartbeat implementation based on the connector and context

Method Summary

Modifier and Type	Method	Description
default Optional<Heartbeat>	getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)
default Heartbeat.ScheduledHeartbeat	getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)

Method Details

getHeartbeat

default Optional<Heartbeat> getHeartbeat(CommonConnectorConfig connectorConfig,
 HeartbeatConnectionProvider connectionProvider,
 HeartbeatErrorHandler errorHandler,
 ChangeEventQueue<DataChangeEvent> queue)

getScheduledHeartbeat

default Heartbeat.ScheduledHeartbeat getScheduledHeartbeat(CommonConnectorConfig connectorConfig,
 HeartbeatConnectionProvider connectionProvider,
 HeartbeatErrorHandler errorHandler,
 ChangeEventQueue<DataChangeEvent> queue)