Function Index

$#! · 0-9 · 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

C
	change_consumer_provider(3), pgq_node
	create_attrs(2), pgq_node
	create_node(7), pgq_node
D
	demote_root(3), pgq_node
	drop_node(2), pgq_node
G
	get_consumer_info(1), pgq_node
	get_consumer_state(2), pgq_node
	get_node_info(1), pgq_node
	get_queue_locations(1), pgq_node
	get_subscriber_info(1), pgq_node
	get_worker_state(1), pgq_node
I
	is_leaf_node(1), pgq_node
	is_root_node(1), pgq_node
M
	maint_watermark(1), pgq_node
P
	promote_branch(1), pgq_node
R
	register_consumer(4), pgq_node
	register_location(4), pgq_node
	register_subscriber(4), pgq_node
S
	set_consumer_completed(3), pgq_node
	set_consumer_error(3), pgq_node
	set_consumer_paused(3), pgq_node
	set_consumer_uptodate(3), pgq_node
	set_global_watermark(2), pgq_node
	set_partition_watermark(3), pgq_node
	set_subscriber_watermark(3), pgq_node
U
	unregister_consumer(2), pgq_node
	unregister_location(2), pgq_node
	unregister_subscriber(2), pgq_node

pgq_node.change_consumer_provider( in i_queue_name text,
in i_consumer_name text,
in i_new_provider text,
out ret_code int4,
out ret_note text ) as

Change provider for this consumer.

Set node attributes.

pgq_node.create_node( in i_queue_name text,
in i_node_type text,
in i_node_name text,
in i_worker_name text,
in i_provider_name text,
in i_global_watermark bigint,
in i_combined_queue text,
out ret_code int4,
out ret_note text ) returns record

Initialize node.

pgq_node.demote_root( in i_queue_name text,
in i_step int4,
in i_new_provider text,
out ret_code int4,
out ret_note text,
out last_tick int8 ) as

Multi-step root demotion to branch.

pgq_node.drop_node( in i_queue_name text,
in i_node_name text,
out ret_code int4,
out ret_note text ) returns record

Drop node.

pgq_node.get_consumer_info( in i_queue_name text,
out consumer_name text,
out provider_node text,
out last_tick_id int8,
out paused boolean,
out uptodate boolean,
out cur_error text ) returns setof record

Get consumer list that work on the local node.

pgq_node.get_consumer_state( in i_queue_name text,
in i_consumer_name text,
out ret_code int4,
out ret_note text,
out node_type text,
out node_name text,
out completed_tick bigint,
out provider_node text,
out provider_location text,
out paused boolean,
out uptodate boolean,
out cur_error text ) returns record

Get info for cascaded consumer that targets local node.

pgq_node.get_node_info( in i_queue_name text,
out ret_code int4,
out ret_note text,
out node_type text,
out node_name text,
out global_watermark bigint,
out local_watermark bigint,
out provider_node text,
out provider_location text,
out combined_queue text,
out combined_type text,
out worker_name text,
out worker_paused bool,
out worker_uptodate bool,
out worker_last_tick bigint,
out node_attrs text ) returns record

Get local node info for cascaded queue.

pgq_node.get_queue_locations( in i_queue_name text,
out node_name text,
out node_location text,
out dead boolean ) returns setof record

Get node list for the queue.

pgq_node.get_subscriber_info( in i_queue_name text,
out node_name text,
out worker_name text,
out node_watermark int8 ) returns setof record

Get subscriber list for the local node.

pgq_node.get_worker_state( in i_queue_name text,
out ret_code int4,
out ret_note text,
out node_type text,
out node_name text,
out completed_tick bigint,
out provider_node text,
out provider_location text,
out paused boolean,
out uptodate boolean,
out cur_error text,
out worker_name text,
out global_watermark bigint,
out local_watermark bigint,
out local_queue_top bigint,
out combined_queue text,
out combined_type text ) returns record

Get info for consumer that maintains local node.

pgq_node.is_leaf_node( i_queue_name text ) returns bool

Checs if node is leaf.

pgq_node.is_root_node( i_queue_name text ) returns bool

Checs if node is root.

pgq_node.maint_watermark( i_queue_name text ) returns int4

Move global watermark on root node.

pgq_node.promote_branch( in i_queue_name text,
out ret_code int4,
out ret_note text ) as

Promote branch node to root.

pgq_node.register_consumer( in i_queue_name text,
in i_consumer_name text,
in i_provider_node text,
in i_custom_tick_id int8,
out ret_code int4,
out ret_note text ) returns record

Subscribe plain cascaded consumer to a target node.

pgq_node.register_location( in i_queue_name text,
in i_node_name text,
in i_node_location text,
in i_dead boolean,
out ret_code int4,
out ret_note text ) returns record

Add new node location.

pgq_node.register_subscriber( in i_queue_name text,
in i_remote_node_name text,
in i_remote_worker_name text,
in i_custom_tick_id int8,
out ret_code int4,
out ret_note text,
out global_watermark bigint ) returns record

Subscribe remote node to local node at custom position.

pgq_node.set_consumer_completed( in i_queue_name text,
in i_consumer_name text,
in i_tick_id int8,
out ret_code int4,
out ret_note text ) as

Set last completed tick id for the cascaded consumer that it has committed to local node.

pgq_node.set_consumer_error( in i_queue_name text,
in i_consumer_name text,
in i_error_msg text,
out ret_code int4,
out ret_note text ) as

If batch processing fails, consumer can store it’s last error in db.

pgq_node.set_consumer_paused( in i_queue_name text,
in i_consumer_name text,
in i_paused boolean,
out ret_code int4,
out ret_note text ) as

Set consumer paused flag.

pgq_node.set_consumer_uptodate( in i_queue_name text,
in i_consumer_name text,
in i_uptodate boolean,
out ret_code int4,
out ret_note text ) returns record

Set consumer uptodate flag.....

pgq_node.set_global_watermark( in i_queue_name text,
in i_watermark bigint,
out ret_code int4,
out ret_note text ) returns record

Move global watermark on branch/leaf, publish on root.

pgq_node.set_partition_watermark( in i_combined_queue_name text,
in i_part_queue_name text,
in i_watermark bigint,
out ret_code int4,
out ret_note text ) returns record

Move merge-leaf position on combined-branch.

pgq_node.set_subscriber_watermark( in i_queue_name text,
in i_node_name text,
in i_watermark bigint,
out ret_code int4,
out ret_note text ) returns record

Notify provider about subscribers lowest watermark.

pgq_node.unregister_consumer( in i_queue_name text,
in i_consumer_name text,
out ret_code int4,
out ret_note text ) returns record

Unregister cascaded consumer from local node.

pgq_node.unregister_location( in i_queue_name text,
in i_node_name text,
out ret_code int4,
out ret_note text ) returns record

Drop unreferenced node.

pgq_node.unregister_subscriber( in i_queue_name text,
in i_remote_node_name text,
out ret_code int4,
out ret_note text ) returns record

Unsubscribe remote node from local node.