Uses of Interface
io.debezium.heartbeat.Heartbeat.ScheduledHeartbeat
Packages that use Heartbeat.ScheduledHeartbeat
-
Uses of Heartbeat.ScheduledHeartbeat in io.debezium.heartbeat
Classes in io.debezium.heartbeat that implement Heartbeat.ScheduledHeartbeatModifier and TypeClassDescriptionclassComposite Heartbeat solutions (Queue, Database...)classDefault implementation of HeartbeatFields in io.debezium.heartbeat declared as Heartbeat.ScheduledHeartbeatModifier and TypeFieldDescriptionstatic final Heartbeat.ScheduledHeartbeatHeartbeat.ScheduledHeartbeat.NOOP_HEARTBEATprivate final Heartbeat.ScheduledHeartbeatCompositeHeartbeat.scheduledHeartbeatMethods in io.debezium.heartbeat that return Heartbeat.ScheduledHeartbeatModifier and TypeMethodDescriptiondefault Heartbeat.ScheduledHeartbeatDebeziumHeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) HeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue) Create a heartbeat instance that can be scheduled with some delay based onCommonConnectorConfigConstructors in io.debezium.heartbeat with parameters of type Heartbeat.ScheduledHeartbeatModifierConstructorDescriptionCompositeHeartbeat(Heartbeat.ScheduledHeartbeat scheduledHeartbeat, Heartbeat... heartbeat) CompositeHeartbeat(Heartbeat.ScheduledHeartbeat scheduledHeartbeat, List<Heartbeat> heartbeats) -
Uses of Heartbeat.ScheduledHeartbeat in io.debezium.pipeline
Fields in io.debezium.pipeline declared as Heartbeat.ScheduledHeartbeatModifier and TypeFieldDescriptionprivate final Heartbeat.ScheduledHeartbeatEventDispatcher.heartbeatConstructors in io.debezium.pipeline with parameters of type Heartbeat.ScheduledHeartbeatModifierConstructorDescriptionEventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventDispatcher.InconsistentSchemaHandler<P, T> inconsistentSchemaHandler, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, TransactionMonitor transactionMonitor, SignalProcessor<P, ?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer) EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventDispatcher.InconsistentSchemaHandler<P, T> inconsistentSchemaHandler, EventMetadataProvider metadataProvider, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, SignalProcessor<P, ?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer) EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, DebeziumHeaderProducer debeziumHeaderProducer) EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, SignalProcessor<P, ?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer)