<row>
<entry>
<indexterm>
- <primary>create_physical_replication_slot</primary>
+ <primary>pg_create_physical_replication_slot</primary>
</indexterm>
- <literal><function>create_physical_replication_slot(<parameter>slotname</parameter> <type>text</type>, <parameter>plugin</parameter> <type>text</type>)</function></literal>
+ <literal><function>pg_create_physical_replication_slot(<parameter>slotname</parameter> <type>text</type>, <parameter>plugin</parameter> <type>text</type>)</function></literal>
</entry>
<entry>
(<parameter>slotname</parameter> <type>text</type>, <parameter>xlog_position</parameter> <type>text</type>)
<row>
<entry>
<indexterm>
- <primary>drop_replication_slot</primary>
+ <primary>pg_drop_replication_slot</primary>
</indexterm>
- <literal><function>drop_replication_slot(<parameter>slotname</parameter> <type>text</type>)</function></literal>
+ <literal><function>pg_drop_replication_slot(<parameter>slotname</parameter> <type>text</type>)</function></literal>
</entry>
<entry>
(<parameter>slotname</parameter> <type>text</type>)
<para>
You can create a replication slot like this:
<programlisting>
-postgres=# SELECT * FROM create_physical_replication_slot('node_a_slot');
+postgres=# SELECT * FROM pg_create_physical_replication_slot('node_a_slot');
slotname | xlog_position
-------------+---------------
node_a_slot |
#include "utils/builtins.h"
#include "replication/slot.h"
-Datum create_physical_replication_slot(PG_FUNCTION_ARGS);
-Datum drop_replication_slot(PG_FUNCTION_ARGS);
+Datum pg_create_physical_replication_slot(PG_FUNCTION_ARGS);
+Datum pg_drop_replication_slot(PG_FUNCTION_ARGS);
static void
check_permissions(void)
* replication slot.
*/
Datum
-create_physical_replication_slot(PG_FUNCTION_ARGS)
+pg_create_physical_replication_slot(PG_FUNCTION_ARGS)
{
Name name = PG_GETARG_NAME(0);
Datum values[2];
* SQL function for dropping a replication slot.
*/
Datum
-drop_replication_slot(PG_FUNCTION_ARGS)
+pg_drop_replication_slot(PG_FUNCTION_ARGS)
{
Name name = PG_GETARG_NAME(0);
DESCR("SP-GiST support for quad tree over range");
/* replication slots */
-DATA(insert OID = 3780 ( create_physical_replication_slot PGNSP PGUID 12 1 0 0 0 f f f f f f v 1 0 2249 "19" "{19,25,25}" "{i,o,o}" "{slotname,slotname,xlog_position}" _null_ create_physical_replication_slot _null_ _null_ _null_ ));
+DATA(insert OID = 3780 ( pg_create_physical_replication_slot PGNSP PGUID 12 1 0 0 0 f f f f f f v 1 0 2249 "19" "{19,25,25}" "{i,o,o}" "{slotname,slotname,xlog_position}" _null_ create_physical_replication_slot _null_ _null_ _null_ ));
DESCR("create a physical replication slot");
-DATA(insert OID = 3781 ( drop_replication_slot PGNSP PGUID 12 1 0 0 0 f f f f f f v 1 0 23 "19" _null_ _null_ _null_ _null_ drop_replication_slot _null_ _null_ _null_ ));
+DATA(insert OID = 3781 ( pg_drop_replication_slot PGNSP PGUID 12 1 0 0 0 f f f f f f v 1 0 23 "19" _null_ _null_ _null_ _null_ drop_replication_slot _null_ _null_ _null_ ));
DESCR("drop a replication slot");
DATA(insert OID = 3475 ( pg_get_replication_slots PGNSP PGUID 12 1 10 0 0 f f f f f t s 0 0 2249 "" "{25,25,26,16,28,25}" "{o,o,o,o,o,o}" "{slot_name,slot_type,datoid,active,xmin,restart_lsn}" _null_ pg_get_replication_slots _null_ _null_ _null_ ));
DESCR("information about replication slots currently in use");