Identifier Index

[ A B C D E F G H I J K L M N O P Q R S T U V W X Y Z _ ]

A

addcmp() (in Repairer)	admin() (in SubscriberSetup)	attach() (in SerialConsumer)
addeq() (in Repairer)	aggregate_stats() (in LogDBHandler)
admin() (in ProviderSetup)	attach() (in Consumer)

B

bulk_insert_events() (in pgq.producer)

C

cf (in DBScript)	clone() (in Config)	Consumer (in pgq.consumer)
change_snapshot() (in TableState)	close_database() (in DBScript)	consumer (in pgq)
change_state() (in TableState)	cmp_data() (in Repairer)	contains() (in Snapshot)
change_table_state() (in Replicator)	cmp_keys() (in Repairer)	CopyPipe (in skytools.sqltools)
check_consumer() (in Syncer)	cmp_value() (in Repairer)	CopyTable (in londiste.table_copy)
check_table() (in Syncer)	collect_fkeys() (in SubscriberSetup)	create() (in TableStruct)
check_table_columns() (in SubscriberSetup)	Comparator (in londiste.compare)	create() (in DBObject)
check_table_triggers() (in SubscriberSetup)	compare (in londiste)	createSocket() (in LogDBHandler)
check_tables() (in SubscriberSetup)	Config (in skytools.config)	cur_tick (in Replicator)
clean_completed_tick() (in SerialConsumer)	config (in skytools)

D

daemonize() (in skytools.scripting)	DBObject (in skytools.sqltools)	do_copy() (in CopyTable)
db_copy_from_dict() (in skytools.sqltools)	DBSchema (in skytools.sqltools)	do_maintenance() (in MaintenanceJob)
db_copy_from_list() (in skytools.sqltools)	DBScript (in skytools.scripting)	drop() (in TableStruct)
db_install() (in skytools.sqltools)	dbstruct (in skytools)	dst_reset() (in SerialConsumer)
db_urldecode() (in skytools.quoting)	DBTable (in skytools.sqltools)	dump_compare() (in Repairer)
db_urlencode() (in skytools.quoting)	DEF_CONN_AGE (in skytools.scripting)	dump_table() (in Repairer)
DBFunction (in skytools.sqltools)	detach() (in Consumer)
DBLanguage (in skytools.sqltools)	detach() (in SerialConsumer)

E

EasyRotatingFileHandler (in skytools.skylog)	EV_RETRY (in pgq)	exists() (in DBSchema)
emit() (in LogDBHandler)	EV_RETRY (in pgq.consumer)	exists() (in DBTable)
EV_DONE (in pgq)	EV_RETRY (in pgq.event)	exists_function() (in skytools.sqltools)
EV_DONE (in pgq.consumer)	Event (in pgq.event)	exists_language() (in skytools.sqltools)
EV_DONE (in pgq.event)	event (in pgq)	exists_schema() (in skytools.sqltools)
EV_FAILED (in pgq)	exec_provider() (in ProviderSetup)	exists_table() (in skytools.sqltools)
EV_FAILED (in pgq.consumer)	exists() (in DBFunction)	exists_type() (in skytools.sqltools)
EV_FAILED (in pgq.event)	exists() (in DBLanguage)

F

file_rc (in londiste.file_read)	FileWrite (in londiste.file_write)	flush_stats() (in LogDBHandler)
file_read (in londiste)	fill_mirror_queue() (in Replicator)	forget() (in TableState)
file_regex (in londiste.file_read)	flush() (in CopyPipe)	fq_name() (in skytools.sqltools)
file_write (in londiste)	flush_sql() (in FileWrite)	fq_name_parts() (in skytools.sqltools)
FileRead (in londiste.file_read)	flush_sql() (in Replicator)	full_copy() (in skytools.sqltools)

G

gen_copy_tbl() (in Repairer)	get_subscriber_seq_list() (in SubscriberSetup)	getfile() (in Config)
get() (in Config)	get_subscriber_table_state() (in Syncer)	getfloat() (in Config)
get_batch_info() (in Consumer)	get_table_by_name() (in Replicator)	getint() (in Config)
get_column_list() (in TableStruct)	get_table_by_state() (in Replicator)	getlist() (in Config)
get_database() (in DBScript)	get_table_columns() (in skytools.sqltools)	got_missed_delete() (in Repairer)
get_list() (in FileRead)	get_table_oid() (in skytools.sqltools)	got_missed_insert() (in Repairer)
get_pgq_api_version() (in pgq.maint)	get_table_pkeys() (in skytools.sqltools)	got_missed_update() (in Repairer)
get_row() (in Repairer)	get_wildcard() (in Config)	gzip_append() (in skytools.gzlog)
get_sql() (in DBObject)	getboolean() (in Config)	gzlog (in skytools)

H

handle_data_event() (in FileWrite)	handle_seqs() (in Replicator)	hook_sighup() (in DBScript)
handle_data_event() (in Replicator)	handle_system_event() (in FileWrite)	hook_sigint() (in DBScript)
handle_events() (in Replicator)	handle_system_event() (in Replicator)

I

I_AUTOCOMMIT (in skytools)	init_optparse() (in Syncer)	installer (in londiste)
I_AUTOCOMMIT (in skytools.scripting)	init_optparse() (in CopyTable)	interesting() (in FileWrite)
I_DEFAULT (in skytools.scripting)	init_optparse() (in SerialConsumer)	interesting() (in Replicator)
I_READ_COMMITTED (in skytools)	init_optparse() (in DBScript)	interesting() (in TableState)
I_READ_COMMITTED (in skytools.scripting)	insert_event() (in pgq.producer)	is_batch_done() (in SerialConsumer)
I_SERIALIZABLE (in skytools)	install_provider() (in londiste.installer)	is_last_batch() (in RemoteConsumer)
I_SERIALIZABLE (in skytools.scripting)	install_subscriber() (in londiste.installer)	ival() (in pgq.status)

J

job_name (in DBScript)

L

last_successful_batch (in FileWrite)	launch_copy() (in Replicator)	log (in DBScript)
last_tick_event (in SmartTicker)	load_state() (in FileWrite)	LogDBHandler (in skytools.skylog)
last_tick_time (in SmartTicker)	load_table_state() (in Replicator)	londiste
launch_copy() (in FileRead)	loaded_state() (in TableState)

M

magic_insert() (in skytools.sqltools)	MaintenanceJob (in pgq.maint)	MAXMSG (in UdpLogServerHandler)
maint (in pgq)	makePickle() (in UdpLogServerHandler)
maint_thread (in SmartTicker)	makeSocket() (in LogDBHandler)

N

name (in DBObject)

P

parse_state() (in TableState)	process_rec() (in LogDBHandler)	provider_install() (in ProviderSetup)
pgq	process_remote_batch() (in Replicator)	provider_list_seqs() (in ProviderSetup)
PGQStatus (in pgq.status)	process_remote_batch() (in RemoteConsumer)	provider_notify_change() (in ProviderSetup)
pick_consumers() (in PGQStatus)	process_remote_batch() (in SerialConsumer)	provider_object_list (in londiste.installer)
playback (in londiste)	process_sync() (in Comparator)	provider_remove_seq() (in ProviderSetup)
prev_tick (in Replicator)	process_sync() (in Repairer)	provider_remove_table() (in ProviderSetup)
process_batch() (in FileWrite)	process_sync() (in Syncer)	provider_remove_tables() (in ProviderSetup)
process_batch() (in Consumer)	producer (in pgq)	provider_show_tables() (in ProviderSetup)
process_batch() (in RemoteConsumer)	provider_add_seq() (in ProviderSetup)	ProviderSetup (in londiste.setup)
process_batch() (in SerialConsumer)	provider_add_table() (in ProviderSetup)
process_event() (in Consumer)	provider_add_tables() (in ProviderSetup)

Q

quiet_count (in SmartTicker)	quote_bytea_raw() (in skytools.quoting)	quote_literal() (in skytools.quoting)
quote_bytea_copy() (in skytools.quoting)	quote_copy() (in skytools.quoting)	quote_statement() (in skytools.quoting)
quote_bytea_literal() (in skytools.quoting)	quote_json() (in skytools.quoting)	quoting (in skytools)

R

real_copy() (in CopyTable)	reload() (in DBScript)	Replicator (in londiste.playback)
refresh_queues() (in SmartTicker)	RemoteConsumer (in pgq.consumer)	reset() (in DBScript)
register_consumer() (in Consumer)	remove_table() (in Replicator)	rewind() (in SerialConsumer)
reload() (in MaintenanceJob)	render_state() (in TableState)	run() (in DBScript)
reload() (in SmartTicker)	repair (in londiste)	run_once() (in DBScript)
reload() (in Config)	Repairer (in londiste.repair)	run_single_process() (in skytools.scripting)

S

save_state() (in FileWrite)	sql (in DBObject)	subscriber_missing_tables() (in SubscriberSetup)
save_table_state() (in Replicator)	sql_command (in Replicator)	subscriber_object_list (in londiste.installer)
scripting (in skytools)	sql_file (in DBObject)	subscriber_register() (in SubscriberSetup)
sections() (in Config)	sqltools (in skytools)	subscriber_remove_one_table() (in SubscriberSetup)
send_signal() (in DBScript)	start() (in DBScript)	subscriber_remove_seq() (in SubscriberSetup)
send_stats() (in DBScript)	startup() (in SerialConsumer)	subscriber_remove_tables() (in SubscriberSetup)
send_to_logdb() (in LogDBHandler)	startup() (in MaintenanceJob)	subscriber_resync_tables() (in SubscriberSetup)
SerialConsumer (in pgq.consumer)	startup() (in SmartTicker)	subscriber_show_tables() (in SubscriberSetup)
service_name (in DBScript)	startup() (in DBScript)	subscriber_unregister() (in SubscriberSetup)
set_batch_done() (in SerialConsumer)	stat_add() (in DBScript)	SubscriberSetup (in londiste.setup)
set_last_batch() (in RemoteConsumer)	stat_end() (in Consumer)	SYNC_EXIT (in londiste.playback)
set_single_loop() (in DBScript)	stat_increase() (in DBScript)	sync_from_copy_thread() (in Replicator)
setup (in londiste)	stat_put() (in DBScript)	sync_from_main_thread() (in Replicator)
show_consumer() (in PGQStatus)	stat_start() (in Consumer)	SYNC_LOOP (in londiste.playback)
show_fix() (in Repairer)	status (in pgq)	SYNC_OK (in londiste.playback)
show_queue() (in PGQStatus)	stop() (in DBScript)	sync_tables() (in FileWrite)
show_status() (in PGQStatus)	subscriber_add_one_table() (in SubscriberSetup)	sync_tables() (in Replicator)
skylog (in skytools)	subscriber_add_seq() (in SubscriberSetup)	Syncer (in londiste.syncer)
skytools	subscriber_add_tables() (in SubscriberSetup)	syncer (in londiste)
SmartTicker (in pgq.ticker)	subscriber_install() (in SubscriberSetup)
Snapshot (in skytools.sqltools)	subscriber_list_seqs() (in SubscriberSetup)

T

T_ALL (in londiste.table_copy)	T_TABLE (in skytools)	TABLE_MISSING (in londiste.file_read)
T_ALL (in skytools)	T_TABLE (in skytools.dbstruct)	TABLE_MISSING (in londiste.file_write)
T_ALL (in skytools.dbstruct)	T_TRIGGER (in londiste.table_copy)	TABLE_MISSING (in londiste.playback)
T_CONSTRAINT (in londiste.table_copy)	T_TRIGGER (in skytools)	TABLE_MISSING (in londiste.table_copy)
T_CONSTRAINT (in skytools)	T_TRIGGER (in skytools.dbstruct)	TABLE_OK (in londiste)
T_CONSTRAINT (in skytools.dbstruct)	TABLE_CATCHING_UP (in londiste)	TABLE_OK (in londiste.file_read)
T_GRANT (in londiste.table_copy)	TABLE_CATCHING_UP (in londiste.file_read)	TABLE_OK (in londiste.file_write)
T_GRANT (in skytools)	TABLE_CATCHING_UP (in londiste.file_write)	TABLE_OK (in londiste.playback)
T_GRANT (in skytools.dbstruct)	TABLE_CATCHING_UP (in londiste.playback)	TABLE_OK (in londiste.table_copy)
T_INDEX (in londiste.table_copy)	TABLE_CATCHING_UP (in londiste.table_copy)	TABLE_WANNA_SYNC (in londiste)
T_INDEX (in skytools)	table_copy (in londiste)	TABLE_WANNA_SYNC (in londiste.file_read)
T_INDEX (in skytools.dbstruct)	TABLE_DO_SYNC (in londiste)	TABLE_WANNA_SYNC (in londiste.file_write)
T_OWNER (in londiste.table_copy)	TABLE_DO_SYNC (in londiste.file_read)	TABLE_WANNA_SYNC (in londiste.playback)
T_OWNER (in skytools)	TABLE_DO_SYNC (in londiste.file_write)	TABLE_WANNA_SYNC (in londiste.table_copy)
T_OWNER (in skytools.dbstruct)	TABLE_DO_SYNC (in londiste.playback)	TableState (in londiste.playback)
T_PKEY (in londiste.table_copy)	TABLE_DO_SYNC (in londiste.table_copy)	TableStruct (in skytools.dbstruct)
T_PKEY (in skytools)	TABLE_IN_COPY (in londiste)	tag_done() (in Event)
T_PKEY (in skytools.dbstruct)	TABLE_IN_COPY (in londiste.file_read)	tag_failed() (in Event)
T_RULE (in londiste.table_copy)	TABLE_IN_COPY (in londiste.file_write)	tag_retry() (in Event)
T_RULE (in skytools)	TABLE_IN_COPY (in londiste.playback)	tick_count (in SmartTicker)
T_RULE (in skytools.dbstruct)	TABLE_IN_COPY (in londiste.table_copy)	ticker (in pgq)
T_TABLE (in londiste.table_copy)	TABLE_MISSING (in londiste)

U

UdpLogServerHandler (in skytools.skylog)	unescape_copy() (in skytools.quoting)
unescape() (in skytools.quoting)	unregister_consumer() (in Consumer)

V

version_ge() (in pgq.maint)

W

work() (in FileRead)	work() (in MaintenanceJob)	write() (in CopyPipe)
work() (in Syncer)	work() (in SmartTicker)
work() (in Consumer)	work() (in DBScript)

_

__getattr__() (in Event)	__init__() (in SmartTicker)	_esc_rc (in skytools.quoting)
__init__() (in FileRead)	__init__() (in Config)	_esc_re (in skytools.quoting)
__init__() (in Replicator)	__init__() (in TableStruct)	_fldmap (in pgq.event)
__init__() (in TableState)	__init__() (in DBScript)	_fldmap (in pgq.producer)
__init__() (in Syncer)	__init__() (in EasyRotatingFileHandler)	_jsmap (in skytools.quoting)
__init__() (in CopyTable)	__init__() (in LogDBHandler)	_jsre (in skytools.quoting)
__init__() (in Consumer)	__init__() (in CopyPipe)	_level_map (in LogDBHandler)
__init__() (in RemoteConsumer)	__init__() (in DBFunction)	_level_map (in UdpLogServerHandler)
__init__() (in SerialConsumer)	__init__() (in DBLanguage)	_log_config_done (in skytools.scripting)
__init__() (in Event)	__init__() (in DBObject)	_log_init_done (in skytools.scripting)
__init__() (in MaintenanceJob)	__init__() (in Snapshot)	_log_template (in UdpLogServerHandler)
__init__() (in PGQStatus)	_esc_map (in skytools.quoting)