Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view

Large diffs are not rendered by default.

Large diffs are not rendered by default.

Large diffs are not rendered by default.

Large diffs are not rendered by default.

Large diffs are not rendered by default.

Large diffs are not rendered by default.

Original file line number Diff line number Diff line change
Expand Up @@ -1096,6 +1096,115 @@ default DebeziumDb2ComponentBuilder snapshotMode(
doSetProperty("snapshotMode", snapshotMode);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the data should be snapshotted or not.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: db2
*
* @param snapshotModeConfigurationBasedSnapshotData the value to set
* @return the dsl builder
*/
default DebeziumDb2ComponentBuilder snapshotModeConfigurationBasedSnapshotData(
boolean snapshotModeConfigurationBasedSnapshotData) {
doSetProperty("snapshotModeConfigurationBasedSnapshotData", snapshotModeConfigurationBasedSnapshotData);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the data should be snapshotted or not in
* case of error.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: db2
*
* @param snapshotModeConfigurationBasedSnapshotOnDataError the value to
* set
* @return the dsl builder
*/
default DebeziumDb2ComponentBuilder snapshotModeConfigurationBasedSnapshotOnDataError(
boolean snapshotModeConfigurationBasedSnapshotOnDataError) {
doSetProperty("snapshotModeConfigurationBasedSnapshotOnDataError", snapshotModeConfigurationBasedSnapshotOnDataError);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the schema should be snapshotted or not
* in case of error.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: db2
*
* @param snapshotModeConfigurationBasedSnapshotOnSchemaError the value
* to set
* @return the dsl builder
*/
default DebeziumDb2ComponentBuilder snapshotModeConfigurationBasedSnapshotOnSchemaError(
boolean snapshotModeConfigurationBasedSnapshotOnSchemaError) {
doSetProperty("snapshotModeConfigurationBasedSnapshotOnSchemaError", snapshotModeConfigurationBasedSnapshotOnSchemaError);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the schema should be snapshotted or not.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: db2
*
* @param snapshotModeConfigurationBasedSnapshotSchema the value to set
* @return the dsl builder
*/
default DebeziumDb2ComponentBuilder snapshotModeConfigurationBasedSnapshotSchema(
boolean snapshotModeConfigurationBasedSnapshotSchema) {
doSetProperty("snapshotModeConfigurationBasedSnapshotSchema", snapshotModeConfigurationBasedSnapshotSchema);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the stream should start or not after
* snapshot.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: db2
*
* @param snapshotModeConfigurationBasedStartStream the value to set
* @return the dsl builder
*/
default DebeziumDb2ComponentBuilder snapshotModeConfigurationBasedStartStream(
boolean snapshotModeConfigurationBasedStartStream) {
doSetProperty("snapshotModeConfigurationBasedStartStream", snapshotModeConfigurationBasedStartStream);
return this;
}
/**
* When 'snapshot.mode' is set as custom, this setting must be set to
* specify a the name of the custom implementation provided in the
* 'name()' method. The implementations must implement the 'Snapshotter'
* interface and is called on each app boot to determine whether to do a
* snapshot.
*
* The option is a: <code>java.lang.String</code> type.
*
* Group: db2
*
* @param snapshotModeCustomName the value to set
* @return the dsl builder
*/
default DebeziumDb2ComponentBuilder snapshotModeCustomName(
java.lang.String snapshotModeCustomName) {
doSetProperty("snapshotModeCustomName", snapshotModeCustomName);
return this;
}
/**
* This property contains a comma-separated list of fully-qualified
* tables (DB_NAME.TABLE_NAME) or (SCHEMA_NAME.TABLE_NAME), depending on
Expand Down Expand Up @@ -1370,6 +1479,12 @@ protected boolean setPropertyOnComponent(
case "snapshotIncludeCollectionList": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotIncludeCollectionList((java.lang.String) value); return true;
case "snapshotLockTimeoutMs": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotLockTimeoutMs((long) value); return true;
case "snapshotMode": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotModeConfigurationBasedSnapshotData": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotModeConfigurationBasedSnapshotData((boolean) value); return true;
case "snapshotModeConfigurationBasedSnapshotOnDataError": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotModeConfigurationBasedSnapshotOnDataError((boolean) value); return true;
case "snapshotModeConfigurationBasedSnapshotOnSchemaError": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotModeConfigurationBasedSnapshotOnSchemaError((boolean) value); return true;
case "snapshotModeConfigurationBasedSnapshotSchema": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotModeConfigurationBasedSnapshotSchema((boolean) value); return true;
case "snapshotModeConfigurationBasedStartStream": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotModeConfigurationBasedStartStream((boolean) value); return true;
case "snapshotModeCustomName": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotModeCustomName((java.lang.String) value); return true;
case "snapshotSelectStatementOverrides": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotSelectStatementOverrides((java.lang.String) value); return true;
case "snapshotTablesOrderByRowCount": getOrCreateConfiguration((DebeziumDb2Component) component).setSnapshotTablesOrderByRowCount((java.lang.String) value); return true;
case "sourceinfoStructMaker": getOrCreateConfiguration((DebeziumDb2Component) component).setSourceinfoStructMaker((java.lang.String) value); return true;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -633,25 +633,6 @@ default DebeziumMongodbComponentBuilder mongodbAuthsource(
doSetProperty("mongodbAuthsource", mongodbAuthsource);
return this;
}
/**
* The method used to connect to MongoDB cluster. Options include:
* 'replica_set' to individually connect to each replica set / shard
* 'sharded' (the default) to connect via single connection obtained
* from connection string.
*
* The option is a: <code>java.lang.String</code> type.
*
* Default: sharded
* Group: mongodb
*
* @param mongodbConnectionMode the value to set
* @return the dsl builder
*/
default DebeziumMongodbComponentBuilder mongodbConnectionMode(
java.lang.String mongodbConnectionMode) {
doSetProperty("mongodbConnectionMode", mongodbConnectionMode);
return this;
}
/**
* Database connection string.
*
Expand Down Expand Up @@ -1142,6 +1123,115 @@ default DebeziumMongodbComponentBuilder snapshotMode(
doSetProperty("snapshotMode", snapshotMode);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the data should be snapshotted or not.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: mongodb
*
* @param snapshotModeConfigurationBasedSnapshotData the value to set
* @return the dsl builder
*/
default DebeziumMongodbComponentBuilder snapshotModeConfigurationBasedSnapshotData(
boolean snapshotModeConfigurationBasedSnapshotData) {
doSetProperty("snapshotModeConfigurationBasedSnapshotData", snapshotModeConfigurationBasedSnapshotData);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the data should be snapshotted or not in
* case of error.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: mongodb
*
* @param snapshotModeConfigurationBasedSnapshotOnDataError the value to
* set
* @return the dsl builder
*/
default DebeziumMongodbComponentBuilder snapshotModeConfigurationBasedSnapshotOnDataError(
boolean snapshotModeConfigurationBasedSnapshotOnDataError) {
doSetProperty("snapshotModeConfigurationBasedSnapshotOnDataError", snapshotModeConfigurationBasedSnapshotOnDataError);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the schema should be snapshotted or not
* in case of error.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: mongodb
*
* @param snapshotModeConfigurationBasedSnapshotOnSchemaError the value
* to set
* @return the dsl builder
*/
default DebeziumMongodbComponentBuilder snapshotModeConfigurationBasedSnapshotOnSchemaError(
boolean snapshotModeConfigurationBasedSnapshotOnSchemaError) {
doSetProperty("snapshotModeConfigurationBasedSnapshotOnSchemaError", snapshotModeConfigurationBasedSnapshotOnSchemaError);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the schema should be snapshotted or not.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: mongodb
*
* @param snapshotModeConfigurationBasedSnapshotSchema the value to set
* @return the dsl builder
*/
default DebeziumMongodbComponentBuilder snapshotModeConfigurationBasedSnapshotSchema(
boolean snapshotModeConfigurationBasedSnapshotSchema) {
doSetProperty("snapshotModeConfigurationBasedSnapshotSchema", snapshotModeConfigurationBasedSnapshotSchema);
return this;
}
/**
* When 'snapshot.mode' is set as configuration_based, this setting
* permits to specify whenever the stream should start or not after
* snapshot.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
* Group: mongodb
*
* @param snapshotModeConfigurationBasedStartStream the value to set
* @return the dsl builder
*/
default DebeziumMongodbComponentBuilder snapshotModeConfigurationBasedStartStream(
boolean snapshotModeConfigurationBasedStartStream) {
doSetProperty("snapshotModeConfigurationBasedStartStream", snapshotModeConfigurationBasedStartStream);
return this;
}
/**
* When 'snapshot.mode' is set as custom, this setting must be set to
* specify a the name of the custom implementation provided in the
* 'name()' method. The implementations must implement the 'Snapshotter'
* interface and is called on each app boot to determine whether to do a
* snapshot.
*
* The option is a: <code>java.lang.String</code> type.
*
* Group: mongodb
*
* @param snapshotModeCustomName the value to set
* @return the dsl builder
*/
default DebeziumMongodbComponentBuilder snapshotModeCustomName(
java.lang.String snapshotModeCustomName) {
doSetProperty("snapshotModeCustomName", snapshotModeCustomName);
return this;
}
/**
* The name of the SourceInfoStructMaker class that returns SourceInfo
* schema and struct.
Expand Down Expand Up @@ -1274,7 +1364,6 @@ protected boolean setPropertyOnComponent(
case "maxQueueSize": getOrCreateConfiguration((DebeziumMongodbComponent) component).setMaxQueueSize((int) value); return true;
case "maxQueueSizeInBytes": getOrCreateConfiguration((DebeziumMongodbComponent) component).setMaxQueueSizeInBytes((long) value); return true;
case "mongodbAuthsource": getOrCreateConfiguration((DebeziumMongodbComponent) component).setMongodbAuthsource((java.lang.String) value); return true;
case "mongodbConnectionMode": getOrCreateConfiguration((DebeziumMongodbComponent) component).setMongodbConnectionMode((java.lang.String) value); return true;
case "mongodbConnectionString": getOrCreateConfiguration((DebeziumMongodbComponent) component).setMongodbConnectionString((java.lang.String) value); return true;
case "mongodbConnectTimeoutMs": getOrCreateConfiguration((DebeziumMongodbComponent) component).setMongodbConnectTimeoutMs((int) value); return true;
case "mongodbHeartbeatFrequencyMs": getOrCreateConfiguration((DebeziumMongodbComponent) component).setMongodbHeartbeatFrequencyMs((int) value); return true;
Expand Down Expand Up @@ -1304,6 +1393,12 @@ protected boolean setPropertyOnComponent(
case "snapshotIncludeCollectionList": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotIncludeCollectionList((java.lang.String) value); return true;
case "snapshotMaxThreads": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotMaxThreads((int) value); return true;
case "snapshotMode": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotMode((java.lang.String) value); return true;
case "snapshotModeConfigurationBasedSnapshotData": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotModeConfigurationBasedSnapshotData((boolean) value); return true;
case "snapshotModeConfigurationBasedSnapshotOnDataError": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotModeConfigurationBasedSnapshotOnDataError((boolean) value); return true;
case "snapshotModeConfigurationBasedSnapshotOnSchemaError": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotModeConfigurationBasedSnapshotOnSchemaError((boolean) value); return true;
case "snapshotModeConfigurationBasedSnapshotSchema": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotModeConfigurationBasedSnapshotSchema((boolean) value); return true;
case "snapshotModeConfigurationBasedStartStream": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotModeConfigurationBasedStartStream((boolean) value); return true;
case "snapshotModeCustomName": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSnapshotModeCustomName((java.lang.String) value); return true;
case "sourceinfoStructMaker": getOrCreateConfiguration((DebeziumMongodbComponent) component).setSourceinfoStructMaker((java.lang.String) value); return true;
case "tombstonesOnDelete": getOrCreateConfiguration((DebeziumMongodbComponent) component).setTombstonesOnDelete((boolean) value); return true;
case "topicNamingStrategy": getOrCreateConfiguration((DebeziumMongodbComponent) component).setTopicNamingStrategy((java.lang.String) value); return true;
Expand Down
Loading