| |
- Method resolution order:
- PgDefaultCDCPlugin
- siirto.plugins.cdc.cdc_base.CDCBase
- siirto.base.Base
- builtins.object
Methods defined here:
- __init__(self, poll_frequency:int=1, *args, **kwargs) -> None
- Initialize self. See help(type(self)) for accurate signature.
- execute(self)
- This is the main method to derive when implementing an operator.
- setup_graceful_shutdown(self) -> None
- Handles the graceful shutdown of the process.
Cleans the slot from pg, if already created
:return:
Data and other attributes defined here:
- plugin_name = 'PgDefaultCDCPlugin'
- plugin_parameters = {'poll_frequency': {'type': <class 'float'>}}
- plugin_type = <PlugInType.CDC: 2>
Class methods inherited from siirto.plugins.cdc.cdc_base.CDCBase:
- get_object(plugin_name:str) from builtins.type
- Factory.
Get the cdc plugin object having name `plugin_name`
:param plugin_name: plugin name
:return: cdc plug_in
- load_derived_classes() from builtins.type
- load the derived cdc plugin classes available in the current directory and
ending with _plugin.py
Data descriptors inherited from siirto.base.Base:
- __dict__
- dictionary for instance variables (if defined)
- __weakref__
- list of weak references to the object (if defined)
|