grepros.plugins.auto.postgres.PostgresSink Member List

This is the complete list of members for grepros.plugins.auto.postgres.PostgresSink, including all inherited members.

__enter__(self)grepros.outputs.Sink
__exit__(self, exc_type, exc_value, traceback)grepros.outputs.Sink
__init__(self, args=None, **kwargs)grepros.plugins.auto.postgres.PostgresSink
_argsgrepros.plugins.auto.sqlbase.SqlMixinprivate
_batch_metagrepros.outputs.Sinkprivate
_checkedsgrepros.plugins.auto.dbbase.BaseDataSinkprivate
_close_printedgrepros.plugins.auto.dbbase.BaseDataSinkprivate
_connect(self)grepros.plugins.auto.postgres.PostgresSinkprivate
_convert_column_value(self, value, typename)grepros.plugins.auto.sqlbase.SqlMixinprivate
_convert_time_value(self, value, typename)grepros.plugins.auto.sqlbase.SqlMixinprivate
_countsgrepros.outputs.Sinkprivate
_cursorgrepros.plugins.auto.dbbase.BaseDataSinkprivate
_dialectgrepros.plugins.auto.dbbase.BaseDataSinkprivate
_ensure_columns(self, cols)grepros.plugins.auto.dbbase.BaseDataSinkprivate
_ensure_execute(self, sql, args)grepros.plugins.auto.dbbase.BaseDataSinkprivate
_ensure_stamp_index(self, topic, msg, stamp=None, index=None)grepros.outputs.Sinkprivate
_execute_insert(self, sql, args)grepros.plugins.auto.postgres.PostgresSinkprivate
_executemany(self, sql, argses)grepros.plugins.auto.postgres.PostgresSinkprivate
_executescript(self, sql)grepros.plugins.auto.postgres.PostgresSinkprivate
_get_dialect_option(self, option)grepros.plugins.auto.sqlbase.SqlMixinprivate
_get_next_id(self, table)grepros.plugins.auto.postgres.PostgresSinkprivate
_id_queuegrepros.plugins.auto.postgres.PostgresSinkprivate
_init_db(self)grepros.plugins.auto.postgres.PostgresSinkprivate
_load_schema(self)grepros.plugins.auto.postgres.PostgresSinkprivate
_make_column_names(self, col_names)grepros.plugins.auto.sqlbase.SqlMixinprivate
_make_column_type(self, typename, fallback=None)grepros.plugins.auto.sqlbase.SqlMixinprivate
_make_column_value(self, value, typename=None)grepros.plugins.auto.postgres.PostgresSinkprivate
_make_cursor(self)grepros.plugins.auto.dbbase.BaseDataSinkprivate
_make_db_label(self)grepros.plugins.auto.postgres.PostgresSinkprivate
_make_entity_name(self, category, args)grepros.plugins.auto.sqlbase.SqlMixinprivate
_make_message_insert_sql(self, topic, msg, extra_cols=())grepros.plugins.auto.sqlbase.SqlMixinprivate
_make_name(self, category, name, existing=())grepros.plugins.auto.sqlbase.SqlMixinprivate
_make_topic_data(self, topic, msg, exclude_cols=())grepros.plugins.auto.sqlbase.SqlMixinprivate
_make_topic_insert_sql(self, topic, msg)grepros.plugins.auto.sqlbase.SqlMixinprivate
_make_type_data(self, msg, extra_cols=(), rootmsg=None)grepros.plugins.auto.sqlbase.SqlMixinprivate
_make_type_insert_sql(self, msg)grepros.plugins.auto.sqlbase.SqlMixinprivate
_make_update_sql(self, table, values, where=())grepros.plugins.auto.sqlbase.SqlMixinprivate
_nested_countsgrepros.plugins.auto.dbbase.BaseDataSinkprivate
_nestinggrepros.plugins.auto.dbbase.BaseDataSinkprivate
_populate_type(self, topic, msg, stamp, rootmsg=None, parent_type=None, parent_id=None)grepros.plugins.auto.dbbase.BaseDataSinkprivate
_process_message(self, topic, msg, stamp)grepros.plugins.auto.dbbase.BaseDataSinkprivate
_process_topic(self, topic, msg)grepros.plugins.auto.dbbase.BaseDataSinkprivate
_process_type(self, msg, rootmsg=None)grepros.plugins.auto.dbbase.BaseDataSinkprivate
_schemagrepros.plugins.auto.sqlbase.SqlMixinprivate
_sql_cachegrepros.plugins.auto.sqlbase.SqlMixinprivate
_sql_queuegrepros.plugins.auto.dbbase.BaseDataSinkprivate
_topicsgrepros.plugins.auto.sqlbase.SqlMixinprivate
_typesgrepros.plugins.auto.sqlbase.SqlMixinprivate
_validate_dialect(self)grepros.plugins.auto.sqlbase.SqlMixinprivate
_validate_dialect_file(self)grepros.plugins.auto.sqlbase.SqlMixinprivate
argsgrepros.outputs.Sink
autodetect(cls, target)grepros.plugins.auto.postgres.PostgresSink
bind(self, source)grepros.outputs.Sink
close(self)grepros.plugins.auto.dbbase.BaseDataSink
close_output(self)grepros.plugins.auto.dbbase.BaseDataSink
COMMIT_INTERVALgrepros.plugins.auto.dbbase.BaseDataSinkstatic
COMMIT_INTERVALgrepros.plugins.auto.dbbase.BaseDataSink
dbgrepros.plugins.auto.dbbase.BaseDataSink
DEFAULT_ARGSgrepros.plugins.auto.dbbase.BaseDataSinkstatic
DEFAULT_DIALECTgrepros.plugins.auto.sqlbase.SqlMixinstatic
DIALECTSgrepros.plugins.auto.sqlbase.SqlMixinstatic
emit(self, topic, msg, stamp=None, match=None, index=None)grepros.plugins.auto.dbbase.BaseDataSink
emit_meta(self)grepros.outputs.Sink
ENGINEgrepros.plugins.auto.postgres.PostgresSinkstatic
FILE_EXTENSIONSgrepros.outputs.Sinkstatic
flush(self)grepros.outputs.Sink
ID_SEQUENCE_STEPgrepros.plugins.auto.postgres.PostgresSinkstatic
is_highlighting(self)grepros.outputs.Sink
KEYWORDSgrepros.plugins.auto.sqlbase.SqlMixinstatic
MESSAGE_TYPE_BASECOLSgrepros.plugins.auto.postgres.PostgresSinkstatic
MESSAGE_TYPE_NESTCOLSgrepros.plugins.auto.postgres.PostgresSinkstatic
MESSAGE_TYPE_TOPICCOLSgrepros.plugins.auto.postgres.PostgresSinkstatic
SELECT_TYPE_COLUMNSgrepros.plugins.auto.postgres.PostgresSinkstatic
sourcegrepros.outputs.Sink
thread_excepthook(self, text, exc)grepros.outputs.Sink
validgrepros.plugins.auto.postgres.PostgresSink
validate(self)grepros.plugins.auto.postgres.PostgresSink


grepros
Author(s): Erki Suurjaak
autogenerated on Sat Jan 6 2024 03:11:30