Directories ¶
Path | Synopsis |
---|---|
Defines a changelog Entry, which is a sum type of Schema or Modification.
|
Defines a changelog Entry, which is a sum type of Schema or Modification. |
Implements decoding of Postgres types into Golang, using mappings that are generated from pgtype.
|
Implements decoding of Postgres types into Golang, using mappings that are generated from pgtype. |
Create, manage and work import jobs.
|
Create, manage and work import jobs. |
sinks
|
|
bigquery
Implements a sink to Google BigQuery, creating a dataset containing raw tables and de-duplicated views.
|
Implements a sink to Google BigQuery, creating a dataset containing raw tables and de-duplicated views. |
file
Implements a file sink, intended for testing.
|
Implements a file sink, intended for testing. |
generic
Suite of components that can be composed to make sinks.
|
Suite of components that can be composed to make sinks. |
Capture changes from a Postgres database by creating and managing a publication, then streaming changes over a logical replication socket.
|
Capture changes from a Postgres database by creating and managing a publication, then streaming changes over a logical replication socket. |
Click to show internal directories.
Click to hide internal directories.