__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 | |
_args | grepros.plugins.auto.sqlbase.SqlMixin | private |
_batch_meta | grepros.outputs.Sink | private |
_checkeds | grepros.plugins.auto.dbbase.BaseDataSink | private |
_close_printed | grepros.plugins.auto.dbbase.BaseDataSink | private |
_connect(self) | grepros.plugins.auto.postgres.PostgresSink | private |
_convert_column_value(self, value, typename) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_convert_time_value(self, value, typename) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_counts | grepros.outputs.Sink | private |
_cursor | grepros.plugins.auto.dbbase.BaseDataSink | private |
_dialect | grepros.plugins.auto.dbbase.BaseDataSink | private |
_ensure_columns(self, cols) | grepros.plugins.auto.dbbase.BaseDataSink | private |
_ensure_execute(self, sql, args) | grepros.plugins.auto.dbbase.BaseDataSink | private |
_ensure_stamp_index(self, topic, msg, stamp=None, index=None) | grepros.outputs.Sink | private |
_execute_insert(self, sql, args) | grepros.plugins.auto.postgres.PostgresSink | private |
_executemany(self, sql, argses) | grepros.plugins.auto.postgres.PostgresSink | private |
_executescript(self, sql) | grepros.plugins.auto.postgres.PostgresSink | private |
_get_dialect_option(self, option) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_get_next_id(self, table) | grepros.plugins.auto.postgres.PostgresSink | private |
_id_queue | grepros.plugins.auto.postgres.PostgresSink | private |
_init_db(self) | grepros.plugins.auto.postgres.PostgresSink | private |
_load_schema(self) | grepros.plugins.auto.postgres.PostgresSink | private |
_make_column_names(self, col_names) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_make_column_type(self, typename, fallback=None) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_make_column_value(self, value, typename=None) | grepros.plugins.auto.postgres.PostgresSink | private |
_make_cursor(self) | grepros.plugins.auto.dbbase.BaseDataSink | private |
_make_db_label(self) | grepros.plugins.auto.postgres.PostgresSink | private |
_make_entity_name(self, category, args) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_make_message_insert_sql(self, topic, msg, extra_cols=()) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_make_name(self, category, name, existing=()) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_make_topic_data(self, topic, msg, exclude_cols=()) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_make_topic_insert_sql(self, topic, msg) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_make_type_data(self, msg, extra_cols=(), rootmsg=None) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_make_type_insert_sql(self, msg) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_make_update_sql(self, table, values, where=()) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_nested_counts | grepros.plugins.auto.dbbase.BaseDataSink | private |
_nesting | grepros.plugins.auto.dbbase.BaseDataSink | private |
_populate_type(self, topic, msg, stamp, rootmsg=None, parent_type=None, parent_id=None) | grepros.plugins.auto.dbbase.BaseDataSink | private |
_process_message(self, topic, msg, stamp) | grepros.plugins.auto.dbbase.BaseDataSink | private |
_process_topic(self, topic, msg) | grepros.plugins.auto.dbbase.BaseDataSink | private |
_process_type(self, msg, rootmsg=None) | grepros.plugins.auto.dbbase.BaseDataSink | private |
_schema | grepros.plugins.auto.sqlbase.SqlMixin | private |
_sql_cache | grepros.plugins.auto.sqlbase.SqlMixin | private |
_sql_queue | grepros.plugins.auto.dbbase.BaseDataSink | private |
_topics | grepros.plugins.auto.sqlbase.SqlMixin | private |
_types | grepros.plugins.auto.sqlbase.SqlMixin | private |
_validate_dialect(self) | grepros.plugins.auto.sqlbase.SqlMixin | private |
_validate_dialect_file(self) | grepros.plugins.auto.sqlbase.SqlMixin | private |
args | grepros.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_INTERVAL | grepros.plugins.auto.dbbase.BaseDataSink | static |
COMMIT_INTERVAL | grepros.plugins.auto.dbbase.BaseDataSink | |
db | grepros.plugins.auto.dbbase.BaseDataSink | |
DEFAULT_ARGS | grepros.plugins.auto.dbbase.BaseDataSink | static |
DEFAULT_DIALECT | grepros.plugins.auto.sqlbase.SqlMixin | static |
DIALECTS | grepros.plugins.auto.sqlbase.SqlMixin | static |
emit(self, topic, msg, stamp=None, match=None, index=None) | grepros.plugins.auto.dbbase.BaseDataSink | |
emit_meta(self) | grepros.outputs.Sink | |
ENGINE | grepros.plugins.auto.postgres.PostgresSink | static |
FILE_EXTENSIONS | grepros.outputs.Sink | static |
flush(self) | grepros.outputs.Sink | |
ID_SEQUENCE_STEP | grepros.plugins.auto.postgres.PostgresSink | static |
is_highlighting(self) | grepros.outputs.Sink | |
KEYWORDS | grepros.plugins.auto.sqlbase.SqlMixin | static |
MESSAGE_TYPE_BASECOLS | grepros.plugins.auto.postgres.PostgresSink | static |
MESSAGE_TYPE_NESTCOLS | grepros.plugins.auto.postgres.PostgresSink | static |
MESSAGE_TYPE_TOPICCOLS | grepros.plugins.auto.postgres.PostgresSink | static |
SELECT_TYPE_COLUMNS | grepros.plugins.auto.postgres.PostgresSink | static |
source | grepros.outputs.Sink | |
thread_excepthook(self, text, exc) | grepros.outputs.Sink | |
valid | grepros.plugins.auto.postgres.PostgresSink | |
validate(self) | grepros.plugins.auto.postgres.PostgresSink | |