| /dports/databases/pglogical/pglogical-REL2_4_0/ |
| H A D | pglogical_rpc.h | 19 List *replication_sets);
21 RangeVar *rv, List *replication_sets);
27 char **replication_sets);
|
| H A D | pglogical_functions.c | 408 List *replication_sets; in pglogical_create_subscription() local
507 sub.replication_sets = replication_sets; in pglogical_create_subscription()
752 sub->replication_sets = lappend(sub->replication_sets, repset_name); in pglogical_alter_subscription_add_replication_set()
789 sub->replication_sets = foreach_delete_current(sub->replication_sets, in pglogical_alter_subscription_remove_replication_set()
792 sub->replication_sets = list_delete_cell(sub->replication_sets, in pglogical_alter_subscription_remove_replication_set()
1142 if (sub->replication_sets) in pglogical_show_subscription_status()
1756 List *replication_sets; in pglogical_replicate_ddl_command() local
1938 List *replication_sets; in pglogical_show_repset_table_info() local
1962 replication_sets, in pglogical_show_repset_table_info()
2060 List *replication_sets; in pglogical_table_data_filtered() local
[all …]
|
| H A D | pglogical_rpc.c | 37 pg_logical_get_remote_repset_tables(PGconn *conn, List *replication_sets) in pg_logical_get_remote_repset_tables() argument
48 foreach (lc, replication_sets) in pg_logical_get_remote_repset_tables()
113 List *replication_sets) in pg_logical_get_remote_repset_table() argument
129 foreach (lc, replication_sets) in pg_logical_get_remote_repset_table()
296 …(PGconn *conn, Oid *nodeid, char **node_name, char **sysid, char **dbname, char **replication_sets) in pglogical_remote_node_info() argument
317 if (replication_sets) in pglogical_remote_node_info()
318 *replication_sets = pstrdup(PQgetvalue(res, 0, 4)); in pglogical_remote_node_info()
|
| H A D | pglogical_queue.c | 73 queue_message(List *replication_sets, Oid roleoid, char message_type, in queue_message() argument
101 if (replication_sets) in queue_message()
103 PointerGetDatum(strlist_to_textarray(replication_sets)); in queue_message()
153 res->replication_sets = textarray_to_list(DatumGetArrayTypeP(d)); in queued_message_from_tuple()
155 res->replication_sets = NULL; in queued_message_from_tuple()
|
| H A D | pglogical_queue.h | 26 List *replication_sets; member
32 extern void queue_message(List *replication_sets, Oid roleoid,
|
| H A D | pglogical_repset.c | 288 List *replication_sets = NIL; in get_node_replication_sets() local
306 replication_sets = lappend(replication_sets, repset); in get_node_replication_sets()
312 return replication_sets; in get_node_replication_sets()
322 List *replication_sets = NIL; in get_replication_sets() local
364 replication_sets = lappend(replication_sets, in get_replication_sets()
372 return replication_sets; in get_replication_sets()
526 List *replication_sets = NIL; in get_table_replication_sets() local
561 replication_sets = lappend(replication_sets, repset); in get_table_replication_sets()
567 return replication_sets; in get_table_replication_sets()
633 replication_sets = lappend(replication_sets, repset); in get_seq_replication_sets()
[all …]
|
| H A D | pglogical_create_subscriber.c | 66 char *replication_sets; member
111 char *replication_sets,
179 char *replication_sets = NULL; in main() local
331 if (!replication_sets || !strlen(replication_sets)) in main()
566 prov_connstr, replication_sets, apply_delay, in main()
909 ri->replication_sets = pstrdup(PQgetvalue(res, 0, 4)); in get_remote_info()
1090 char *provider_dsn, char *replication_sets, in pglogical_subscribe() argument
1114 printfPQExpBuffer(&repsets, "{%s}", replication_sets); in pglogical_subscribe()
1155 validate_replication_set_input(char *replication_sets) in validate_replication_set_input() argument
1162 if (!replication_sets) in validate_replication_set_input()
[all …]
|
| H A D | pglogical--1.0.1--1.1.0.sql | 10 CREATE OR REPLACE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DE…
69 …replication_sets text[], synchronize_structure boolean, synchronize_data boolean, forward_origins …
71 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
|
| H A D | pglogical--2.4.0.sql | 58 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
80 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
208 replication_sets text[], field
213 CREATE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DEFAULT '{ddl…
219 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--2.2.1.sql | 57 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
78 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
206 replication_sets text[], field
211 CREATE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DEFAULT '{ddl…
217 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--2.3.1.sql | 58 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
80 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
208 replication_sets text[], field
213 CREATE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DEFAULT '{ddl…
219 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--2.3.2.sql | 58 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
80 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
208 replication_sets text[], field
213 CREATE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DEFAULT '{ddl…
219 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--2.2.0.sql | 57 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
78 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
206 replication_sets text[], field
211 CREATE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DEFAULT '{ddl…
217 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--2.2.2.sql | 57 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
78 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
206 replication_sets text[], field
211 CREATE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DEFAULT '{ddl…
217 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--2.3.3.sql | 58 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
80 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
208 replication_sets text[], field
213 CREATE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DEFAULT '{ddl…
219 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--2.3.4.sql | 58 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
80 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
208 replication_sets text[], field
213 CREATE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DEFAULT '{ddl…
219 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--1.0.0.sql | 54 replication_sets text[] = '{default,default_insert_only}', synchronize_structure boolean = true,
72 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
155 replication_sets text[], field
185 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--2.3.0.sql | 58 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure text = 'n…
80 OUT provider_dsn text, OUT slot_name text, OUT replication_sets text[],
216 replication_sets text[], field
221 CREATE FUNCTION pglogical.replicate_ddl_command(command text, replication_sets text[] DEFAULT '{ddl…
227 …fo(OUT node_id oid, OUT node_name text, OUT sysid text, OUT dbname text, OUT replication_sets text)
|
| H A D | pglogical--2.2.2--2.3.0.sql | 4 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure text = 'n…
10 replication_sets text[], synchronize_structure boolean,
|
| H A D | pglogical--2.3.0--2.3.1.sql | 2 replication_sets text[], synchronize_structure text, synchronize_data boolean,
6 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
|
| H A D | pglogical--1.2.2--2.0.0.sql | 34 replication_sets text[], synchronize_structure boolean,
37 …replication_sets text[] = '{default,default_insert_only,ddl_sql}', synchronize_structure boolean =…
|
| /dports/databases/pglogical/pglogical-REL2_4_0/expected/ |
| H A D | interfaces.out | 33 SELECT subscription_name, status, provider_node, replication_sets, forward_origins FROM pglogical.s…
34 …subscription_name | status | provider_node | replication_sets | forward_…
74 SELECT subscription_name, status, provider_node, replication_sets, forward_origins FROM pglogical.s…
75 …subscription_name | status | provider_node | replication_sets | forward_…
|
| H A D | parallel.out | 14 replication_sets := '{parallel,default}',
23 replication_sets := '{parallel}',
50 …sn | slot_name | replication_sets | …
|
| /dports/databases/pglogical/pglogical-REL2_4_0/sql/ |
| H A D | interfaces.sql | 24 SELECT subscription_name, status, provider_node, replication_sets, forward_origins FROM pglogical.s…
44 SELECT subscription_name, status, provider_node, replication_sets, forward_origins FROM pglogical.s…
|
| H A D | parallel.sql | 13 replication_sets := '{parallel,default}',
22 replication_sets := '{parallel}',
|