dbIngest Namespace Reference

Classes
class	dbIngest
class	dbIngestConfig
class	NewXFilesHandler
class	QueryCancellationWatchdog
class	TimeoutError

Functions
	_run_logdump_thread (logger_name, logdump_dir, logdump_args, name, message_queue, record_class)

Variables
	log = logging.getLogger(__name__)
int	RETRY_WAIT_SEC = 2
int	CREATE_CONNECTION_TIMEOUT_SEC = 2
int	EXIT_TIMEOUT_SEC = 2
	main = dbIngest.console_app

Function Documentation

_run_logdump_thread()

dbIngest._run_logdump_thread (   logger_name,   logdump_dir,   logdump_args,   name,   message_queue,   record_class  )

protected

Definition at line 94 of file dbIngest.py.

References log.

Variable Documentation

CREATE_CONNECTION_TIMEOUT_SEC

int dbIngest.CREATE_CONNECTION_TIMEOUT_SEC = 2

Definition at line 91 of file dbIngest.py.

EXIT_TIMEOUT_SEC

int dbIngest.EXIT_TIMEOUT_SEC = 2

Definition at line 92 of file dbIngest.py.

log

dbIngest.log = logging.getLogger(__name__)

Definition at line 32 of file dbIngest.py.

Referenced by dbIngest.dbIngest._ensure_connected(), _run_logdump_thread(), dbIngest.dbIngest.ingest_line(), dbIngest.dbIngest.launch_followers(), dbIngest.dbIngest.loop(), and dbIngest.dbIngest.refresh_properties().

main

dbIngest.main = dbIngest.console_app

Definition at line 324 of file dbIngest.py.

RETRY_WAIT_SEC

int dbIngest.RETRY_WAIT_SEC = 2

Definition at line 90 of file dbIngest.py.