PostgreSQL Source Code
git master
|
Go to the source code of this file.
Data Structures | |
struct | LogicalRepTupleData |
struct | LogicalRepRelation |
struct | LogicalRepTyp |
struct | LogicalRepBeginData |
struct | LogicalRepCommitData |
Macros | |
#define | LOGICALREP_PROTO_MIN_VERSION_NUM 1 |
#define | LOGICALREP_PROTO_VERSION_NUM 1 |
Typedefs | |
typedef struct LogicalRepTupleData | LogicalRepTupleData |
typedef uint32 | LogicalRepRelId |
typedef struct LogicalRepRelation | LogicalRepRelation |
typedef struct LogicalRepTyp | LogicalRepTyp |
typedef struct LogicalRepBeginData | LogicalRepBeginData |
typedef struct LogicalRepCommitData | LogicalRepCommitData |
#define LOGICALREP_PROTO_MIN_VERSION_NUM 1 |
Definition at line 27 of file logicalproto.h.
Referenced by pgoutput_startup().
#define LOGICALREP_PROTO_VERSION_NUM 1 |
Definition at line 28 of file logicalproto.h.
Referenced by ApplyWorkerMain(), and pgoutput_startup().
typedef struct LogicalRepBeginData LogicalRepBeginData |
typedef struct LogicalRepCommitData LogicalRepCommitData |
typedef struct LogicalRepRelation LogicalRepRelation |
typedef uint32 LogicalRepRelId |
Definition at line 39 of file logicalproto.h.
typedef struct LogicalRepTupleData LogicalRepTupleData |
typedef struct LogicalRepTyp LogicalRepTyp |
void logicalrep_read_begin | ( | StringInfo | in, |
LogicalRepBeginData * | begin_data | ||
) |
Definition at line 60 of file proto.c.
References LogicalRepBeginData::committime, elog, ERROR, LogicalRepBeginData::final_lsn, InvalidXLogRecPtr, pq_getmsgint(), pq_getmsgint64(), and LogicalRepBeginData::xid.
Referenced by apply_handle_begin().
void logicalrep_read_commit | ( | StringInfo | in, |
LogicalRepCommitData * | commit_data | ||
) |
Definition at line 95 of file proto.c.
References LogicalRepCommitData::commit_lsn, LogicalRepCommitData::committime, elog, LogicalRepCommitData::end_lsn, ERROR, pq_getmsgbyte(), and pq_getmsgint64().
Referenced by apply_handle_commit().
LogicalRepRelId logicalrep_read_delete | ( | StringInfo | in, |
LogicalRepTupleData * | oldtup | ||
) |
Definition at line 280 of file proto.c.
References generate_unaccent_rules::action, elog, ERROR, logicalrep_read_tuple(), pq_getmsgbyte(), and pq_getmsgint().
Referenced by apply_handle_delete().
LogicalRepRelId logicalrep_read_insert | ( | StringInfo | in, |
LogicalRepTupleData * | newtup | ||
) |
Definition at line 163 of file proto.c.
References generate_unaccent_rules::action, elog, ERROR, logicalrep_read_tuple(), pq_getmsgbyte(), and pq_getmsgint().
Referenced by apply_handle_insert().
char* logicalrep_read_origin | ( | StringInfo | in, |
XLogRecPtr * | origin_lsn | ||
) |
Definition at line 129 of file proto.c.
References pq_getmsgint64(), pq_getmsgstring(), and pstrdup().
LogicalRepRelation* logicalrep_read_rel | ( | StringInfo | in | ) |
Definition at line 379 of file proto.c.
References logicalrep_read_attrs(), logicalrep_read_namespace(), LogicalRepRelation::nspname, palloc(), pq_getmsgbyte(), pq_getmsgint(), pq_getmsgstring(), pstrdup(), LogicalRepRelation::relname, LogicalRepRelation::remoteid, and LogicalRepRelation::replident.
Referenced by apply_handle_relation().
List* logicalrep_read_truncate | ( | StringInfo | in, |
bool * | cascade, | ||
bool * | restart_seqs | ||
) |
Definition at line 329 of file proto.c.
References i, lappend_oid(), NIL, pq_getmsgint(), TRUNCATE_CASCADE, and TRUNCATE_RESTART_SEQS.
Referenced by apply_handle_truncate().
void logicalrep_read_typ | ( | StringInfo | out, |
LogicalRepTyp * | ltyp | ||
) |
Definition at line 431 of file proto.c.
References logicalrep_read_namespace(), LogicalRepTyp::nspname, pq_getmsgint(), pq_getmsgstring(), pstrdup(), LogicalRepTyp::remoteid, and LogicalRepTyp::typname.
Referenced by apply_handle_type().
LogicalRepRelId logicalrep_read_update | ( | StringInfo | in, |
bool * | has_oldtuple, | ||
LogicalRepTupleData * | oldtup, | ||
LogicalRepTupleData * | newtup | ||
) |
Definition at line 214 of file proto.c.
References generate_unaccent_rules::action, elog, ERROR, logicalrep_read_tuple(), pq_getmsgbyte(), and pq_getmsgint().
Referenced by apply_handle_update().
void logicalrep_write_begin | ( | StringInfo | out, |
ReorderBufferTXN * | txn | ||
) |
Definition at line 46 of file proto.c.
References ReorderBufferTXN::commit_time, ReorderBufferTXN::final_lsn, pq_sendbyte(), pq_sendint32(), pq_sendint64(), and ReorderBufferTXN::xid.
Referenced by pgoutput_begin_txn().
void logicalrep_write_commit | ( | StringInfo | out, |
ReorderBufferTXN * | txn, | ||
XLogRecPtr | commit_lsn | ||
) |
Definition at line 75 of file proto.c.
References ReorderBufferTXN::commit_time, ReorderBufferTXN::end_lsn, pq_sendbyte(), and pq_sendint64().
Referenced by pgoutput_commit_txn().
void logicalrep_write_delete | ( | StringInfo | out, |
Relation | rel, | ||
HeapTuple | oldtuple | ||
) |
Definition at line 255 of file proto.c.
References Assert, logicalrep_write_tuple(), pq_sendbyte(), pq_sendint32(), RelationData::rd_rel, and RelationGetRelid.
Referenced by pgoutput_change().
void logicalrep_write_insert | ( | StringInfo | out, |
Relation | rel, | ||
HeapTuple | newtuple | ||
) |
Definition at line 142 of file proto.c.
References Assert, logicalrep_write_tuple(), pq_sendbyte(), pq_sendint32(), RelationData::rd_rel, and RelationGetRelid.
Referenced by pgoutput_change().
void logicalrep_write_origin | ( | StringInfo | out, |
const char * | origin, | ||
XLogRecPtr | origin_lsn | ||
) |
Definition at line 113 of file proto.c.
References pq_sendbyte(), pq_sendint64(), and pq_sendstring().
Referenced by pgoutput_begin_txn().
void logicalrep_write_rel | ( | StringInfo | out, |
Relation | rel | ||
) |
Definition at line 354 of file proto.c.
References logicalrep_write_attrs(), logicalrep_write_namespace(), pq_sendbyte(), pq_sendint32(), pq_sendstring(), RelationData::rd_rel, RelationGetNamespace, RelationGetRelationName, RelationGetRelid, and relname.
Referenced by maybe_send_schema().
void logicalrep_write_truncate | ( | StringInfo | out, |
int | nrelids, | ||
Oid | relids[], | ||
bool | cascade, | ||
bool | restart_seqs | ||
) |
Definition at line 302 of file proto.c.
References i, pq_sendbyte(), pq_sendint32(), pq_sendint8(), TRUNCATE_CASCADE, and TRUNCATE_RESTART_SEQS.
Referenced by pgoutput_truncate().
void logicalrep_write_typ | ( | StringInfo | out, |
Oid | typoid | ||
) |
Definition at line 404 of file proto.c.
References elog, ERROR, getBaseType(), GETSTRUCT, HeapTupleIsValid, logicalrep_write_namespace(), NameStr, ObjectIdGetDatum, pq_sendbyte(), pq_sendint32(), pq_sendstring(), ReleaseSysCache(), SearchSysCache1(), and TYPEOID.
Referenced by maybe_send_schema().
void logicalrep_write_update | ( | StringInfo | out, |
Relation | rel, | ||
HeapTuple | oldtuple, | ||
HeapTuple | newtuple | ||
) |
Definition at line 185 of file proto.c.
References Assert, logicalrep_write_tuple(), pq_sendbyte(), pq_sendint32(), RelationData::rd_rel, and RelationGetRelid.
Referenced by pgoutput_change().