dbIngest.dbIngest Class Reference

Inheritance diagram for dbIngest.dbIngest:

Collaboration diagram for dbIngest.dbIngest:

Public Member Functions
	launch_followers (self, dev)
	refresh_properties (self)
	setup (self)
	rescan_files (self)
	ingest_line (self, line)
	loop (self)

Public Attributes
	last_update_ts_sec
	records_since_startup
	records_per_sec
	user_log_queue
	user_log_threads
	telem_queue
	telem_threads
	startup_ts_sec
	fs_queue
	fs_observer

Static Public Attributes
dbIngestConfig	config
list	telem_threads [tuple[str, threading.Thread]]
queue	telem_queue .Queue
BaseObserverSubclassCallable	fs_observer
queue	fs_queue .Queue
float	last_update_ts_sec
float	startup_ts_sec
float	records_since_startup
list	user_log_threads [tuple[str, threading.Thread]]
queue	user_log_queue .Queue

Protected Attributes
	_connections
	_should_connect

Static Protected Attributes
list	_connections [psycopg.Connection]
bool	_should_connect = True

Detailed Description

Definition at line 97 of file dbIngest.py.

Member Function Documentation

ingest_line()

dbIngest.dbIngest.ingest_line	(		self,
			line
	)

Definition at line 232 of file dbIngest.py.

launch_followers()

dbIngest.dbIngest.launch_followers	(		self,
			dev
	)

Definition at line 113 of file dbIngest.py.

loop()

dbIngest.dbIngest.loop

(

self

)

Definition at line 237 of file dbIngest.py.

refresh_properties()

dbIngest.dbIngest.refresh_properties

(

self

)

Definition at line 127 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop(), and visxCtrl.xapp.VisX.loop().

rescan_files()

dbIngest.dbIngest.rescan_files

(

self

)

Definition at line 210 of file dbIngest.py.

setup()

dbIngest.dbIngest.setup

(

self

)

Definition at line 134 of file dbIngest.py.

Member Data Documentation

_connections [1/2]

list dbIngest.dbIngest._connections [psycopg.Connection]

staticprotected

Definition at line 106 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop(), and dbIngest.dbIngest.rescan_files().

_connections [2/2]

dbIngest.dbIngest._connections

protected

Definition at line 190 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop(), and dbIngest.dbIngest.rescan_files().

_should_connect [1/2]

bool dbIngest.dbIngest._should_connect = True

staticprotected

Definition at line 107 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop(), and dbIngest.dbIngest.rescan_files().

_should_connect [2/2]

dbIngest.dbIngest._should_connect

protected

Definition at line 191 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop(), and dbIngest.dbIngest.rescan_files().

config

dbIngestConfig dbIngest.dbIngest.config

static

Definition at line 98 of file dbIngest.py.

Referenced by visxCtrl.xapp.VisX.cooling_on_target(), dbIngest.dbIngest.launch_followers(), dbIngest.dbIngest.loop(), dbIngest.dbIngest.rescan_files(), adcCtrl.adcCtrl.setup(), corAlign.corAlign.setup(), and efcControl.efcControl.setup().

fs_observer [1/2]

BaseObserverSubclassCallable dbIngest.dbIngest.fs_observer

static

Definition at line 101 of file dbIngest.py.

fs_observer [2/2]

dbIngest.dbIngest.fs_observer

Definition at line 198 of file dbIngest.py.

fs_queue [1/2]

queue dbIngest.dbIngest.fs_queue .Queue

static

Definition at line 102 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop().

fs_queue [2/2]

dbIngest.dbIngest.fs_queue

Definition at line 196 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop().

last_update_ts_sec [1/2]

float dbIngest.dbIngest.last_update_ts_sec

static

Definition at line 103 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop(), and dbIngest.dbIngest.refresh_properties().

last_update_ts_sec [2/2]

dbIngest.dbIngest.last_update_ts_sec

Definition at line 135 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop(), and dbIngest.dbIngest.refresh_properties().

records_per_sec

dbIngest.dbIngest.records_per_sec

Definition at line 137 of file dbIngest.py.

records_since_startup [1/2]

float dbIngest.dbIngest.records_since_startup

static

Definition at line 105 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop(), and dbIngest.dbIngest.refresh_properties().

records_since_startup [2/2]

dbIngest.dbIngest.records_since_startup

Definition at line 136 of file dbIngest.py.

Referenced by dbIngest.dbIngest.loop(), and dbIngest.dbIngest.refresh_properties().

startup_ts_sec [1/2]

float dbIngest.dbIngest.startup_ts_sec

static

Definition at line 104 of file dbIngest.py.

Referenced by dbIngest.dbIngest.refresh_properties().

startup_ts_sec [2/2]

dbIngest.dbIngest.startup_ts_sec

Definition at line 188 of file dbIngest.py.

Referenced by dbIngest.dbIngest.refresh_properties().

telem_queue [1/2]

queue dbIngest.dbIngest.telem_queue .Queue

static

Definition at line 100 of file dbIngest.py.

Referenced by dbIngest.dbIngest.launch_followers(), and dbIngest.dbIngest.loop().

telem_queue [2/2]

dbIngest.dbIngest.telem_queue

Definition at line 183 of file dbIngest.py.

Referenced by dbIngest.dbIngest.launch_followers(), and dbIngest.dbIngest.loop().

telem_threads [1/2]

list dbIngest.dbIngest.telem_threads [tuple[str, threading.Thread]]

static

Definition at line 99 of file dbIngest.py.

Referenced by dbIngest.dbIngest.launch_followers().

telem_threads [2/2]

dbIngest.dbIngest.telem_threads

Definition at line 184 of file dbIngest.py.

Referenced by dbIngest.dbIngest.launch_followers().

user_log_queue [1/2]

queue dbIngest.dbIngest.user_log_queue .Queue

static

Definition at line 111 of file dbIngest.py.

Referenced by dbIngest.dbIngest.launch_followers(), and dbIngest.dbIngest.loop().

user_log_queue [2/2]

dbIngest.dbIngest.user_log_queue

Definition at line 180 of file dbIngest.py.

Referenced by dbIngest.dbIngest.launch_followers(), and dbIngest.dbIngest.loop().

user_log_threads [1/2]

list dbIngest.dbIngest.user_log_threads [tuple[str, threading.Thread]]

static

Definition at line 110 of file dbIngest.py.

Referenced by dbIngest.dbIngest.launch_followers().

user_log_threads [2/2]

dbIngest.dbIngest.user_log_threads

Definition at line 181 of file dbIngest.py.

Referenced by dbIngest.dbIngest.launch_followers().

---

The documentation for this class was generated from the following file:

• apps/dbIngest/dbIngest.py