Home Explore Help
Sign In
BlitzNG
/
database.mod
mirror of https://github.com/bmx-ng/database.mod.git
2
0
Fork 0
Files Issues 0 Wiki
Branch: task/add-postgresql
Branches Tags
database.mod
/
postgresql.mod
/
include
/
replication
/
origin.h

origin.h 2.4 KB
Permalink History Raw

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273 
  1. /*-------------------------------------------------------------------------
    2. 

  2.  * origin.h
    3. 

  3.  *	   Exports from replication/logical/origin.c
    4. 

  4.  *
    5. 

  5.  * Copyright (c) 2013-2022, PostgreSQL Global Development Group
    6. 

  6.  *
    7. 

  7.  * src/include/replication/origin.h
    8. 

  8.  *-------------------------------------------------------------------------
    9. 

  9.  */
    10. 

  10. #ifndef PG_ORIGIN_H
    11. 

  11. #define PG_ORIGIN_H
    12. 

  12. 

  13. #include "access/xlog.h"
    14. 

  14. #include "access/xlogdefs.h"
    15. 

  15. #include "access/xlogreader.h"
    16. 

  16. #include "catalog/pg_replication_origin.h"
    17. 

  17. 

  18. typedef struct xl_replorigin_set
    19. 

  19. {
    20. 

  20. 	XLogRecPtr	remote_lsn;
    21. 

  21. 	RepOriginId node_id;
    22. 

  22. 	bool		force;
    23. 

  23. } xl_replorigin_set;
    24. 

  24. 

  25. typedef struct xl_replorigin_drop
    26. 

  26. {
    27. 

  27. 	RepOriginId node_id;
    28. 

  28. } xl_replorigin_drop;
    29. 

  29. 

  30. #define XLOG_REPLORIGIN_SET		0x00
    31. 

  31. #define XLOG_REPLORIGIN_DROP		0x10
    32. 

  32. 

  33. #define InvalidRepOriginId 0
    34. 

  34. #define DoNotReplicateId PG_UINT16_MAX
    35. 

  35. 

  36. extern PGDLLIMPORT RepOriginId replorigin_session_origin;
    37. 

  37. extern PGDLLIMPORT XLogRecPtr replorigin_session_origin_lsn;
    38. 

  38. extern PGDLLIMPORT TimestampTz replorigin_session_origin_timestamp;
    39. 

  39. 

  40. /* API for querying & manipulating replication origins */
    41. 

  41. extern RepOriginId replorigin_by_name(const char *name, bool missing_ok);
    42. 

  42. extern RepOriginId replorigin_create(const char *name);
    43. 

  43. extern void replorigin_drop_by_name(const char *name, bool missing_ok, bool nowait);
    44. 

  44. extern bool replorigin_by_oid(RepOriginId roident, bool missing_ok,
    45. 

  45. 							  char **roname);
    46. 

  46. 

  47. /* API for querying & manipulating replication progress tracking */
    48. 

  48. extern void replorigin_advance(RepOriginId node,
    49. 

  49. 							   XLogRecPtr remote_commit,
    50. 

  50. 							   XLogRecPtr local_commit,
    51. 

  51. 							   bool go_backward, bool wal_log);
    52. 

  52. extern XLogRecPtr replorigin_get_progress(RepOriginId node, bool flush);
    53. 

  53. 

  54. extern void replorigin_session_advance(XLogRecPtr remote_commit,
    55. 

  55. 									   XLogRecPtr local_commit);
    56. 

  56. extern void replorigin_session_setup(RepOriginId node);
    57. 

  57. extern void replorigin_session_reset(void);
    58. 

  58. extern XLogRecPtr replorigin_session_get_progress(bool flush);
    59. 

  59. 

  60. /* Checkpoint/Startup integration */
    61. 

  61. extern void CheckPointReplicationOrigin(void);
    62. 

  62. extern void StartupReplicationOrigin(void);
    63. 

  63. 

  64. /* WAL logging */
    65. 

  65. extern void replorigin_redo(XLogReaderState *record);
    66. 

  66. extern void replorigin_desc(StringInfo buf, XLogReaderState *record);
    67. 

  67. extern const char *replorigin_identify(uint8 info);
    68. 

  68. 

  69. /* shared memory allocation */
    70. 

  70. extern Size ReplicationOriginShmemSize(void);
    71. 

  71. extern void ReplicationOriginShmemInit(void);
    72. 

  72. 

  73. #endif							/* PG_ORIGIN_H */
    74.