ConfigPatchAll is a config patch that includes changes that shall be applied to all connector configurations across all connectors.
| 22 | // ConfigPatchAll is a config patch that includes changes that shall be applied to all connector |
| 23 | // configurations across all connectors. |
| 24 | type ConfigPatchAll struct { |
| 25 | // ConfigurationKeySelector defines what configuration keys (e.g. `tasks.max`) shall be |
| 26 | // matched. The Config patch will be applied to all configuration keys where the configuration |
| 27 | // key and connector class selector match. |
| 28 | ConfigurationKeySelector IncludeExcludeSelector |
| 29 | |
| 30 | // ConnectorClassSelector defines what connector classes |
| 31 | // (e.g. `org.apache.kafka.connect.mirror.MirrorSourceConnector`) shall be matched. |
| 32 | // The Config patch will be applied to all configuration keys where the configuration |
| 33 | // key and connector class selector match. |
| 34 | ConnectorClassSelector IncludeExcludeSelector |
| 35 | |
| 36 | // CommonAbbreviations is a list of abbreviations that shall be rendered upper-cased, |
| 37 | // when computing a display name based on a config key that has not set a display name. |
| 38 | CommonAbbreviations []string |
| 39 | |
| 40 | // Replacers is a map of strings that shall be replaced by another word. Only completed |
| 41 | // words will be matched. Keys must always be lower-cased. |
| 42 | Replacers map[string]string |
| 43 | } |
| 44 | |
| 45 | var _ ConfigPatch = (*ConfigPatchAll)(nil) |
| 46 |
nothing calls this directly
no outgoing calls
no test coverage detected