Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
P
Postgres FD Implementation
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Abuhujair Javed
Postgres FD Implementation
Commits
890194f1
Commit
890194f1
authored
Mar 12, 2014
by
Robert Haas
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Comment fixes related to logical decoding.
Andres Freund, per complaints by Peter Eisentraut.
parent
c5608ea2
Changes
2
Hide whitespace changes
Inline
Side-by-side
Showing
2 changed files
with
7 additions
and
4 deletions
+7
-4
contrib/test_decoding/test_decoding.c
contrib/test_decoding/test_decoding.c
+1
-1
src/backend/replication/logical/logical.c
src/backend/replication/logical/logical.c
+6
-3
No files found.
contrib/test_decoding/test_decoding.c
View file @
890194f1
...
...
@@ -33,6 +33,7 @@
PG_MODULE_MAGIC
;
/* These must be available to pg_dlsym() */
extern
void
_PG_init
(
void
);
extern
void
_PG_output_plugin_init
(
OutputPluginCallbacks
*
cb
);
...
...
@@ -43,7 +44,6 @@ typedef struct
bool
include_timestamp
;
}
TestDecodingData
;
/* These must be available to pg_dlsym() */
static
void
pg_decode_startup
(
LogicalDecodingContext
*
ctx
,
OutputPluginOptions
*
opt
,
bool
is_init
);
static
void
pg_decode_shutdown
(
LogicalDecodingContext
*
ctx
);
...
...
src/backend/replication/logical/logical.c
View file @
890194f1
...
...
@@ -12,14 +12,17 @@
* together provide logical decoding, primarily by providing so
* called LogicalDecodingContexts. The goal is to encapsulate most of the
* internal complexity for consumers of logical decoding, so they can
* create and consume a changestream with a low amount of code.
* create and consume a changestream with a low amount of code. Builtin
* consumers are the walsender and SQL SRF interface, but it's possible to
* add further ones without changing core code, e.g. to consume changes in
* a bgworker.
*
* The idea is that a consumer provides three callbacks, one to read WAL,
* one to prepare a data write, and a final one for actually writing since
* their implementation depends on the type of consumer. Check
* logicalfunc
.c for an example implementations
of a fairly simple consumer
* logicalfunc
s.c for an example implementation
of a fairly simple consumer
* and a implementation of a WAL reading callback that's suitable for
* simple
r
consumers.
* simple consumers.
*-------------------------------------------------------------------------
*/
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment