Directories
¶
| Path | Synopsis |
|---|---|
|
Package filterexpr renders the shared spec.Filter AST into an expr-lang expression.
|
Package filterexpr renders the shared spec.Filter AST into an expr-lang expression. |
|
Direct-to-Arrow Kafka consumption (#733): the decoder writes each record's fields straight into a transport.RowEncoder built from the target table's canonical schema, so no per-record rowchange.Change is materialized and the source puller never re-encodes one.
|
Direct-to-Arrow Kafka consumption (#733): the decoder writes each record's fields straight into a transport.RowEncoder built from the target table's canonical schema, so no per-record rowchange.Change is materialized and the source puller never re-encodes one. |
|
decoder
Columnar decoding: the direct-to-Arrow sibling of Decoder (#733).
|
Columnar decoding: the direct-to-Arrow sibling of Decoder (#733). |
|
Package source.mysql implements the MySQL replication source on top of go-mysql/canal: a single binlog reader that decodes row events into rowchange.Change, positions them at their transaction GTID, and exposes the synced and master positions for the DBLog watermark logic.
|
Package source.mysql implements the MySQL replication source on top of go-mysql/canal: a single binlog reader that decodes row events into rowchange.Change, positions them at their transaction GTID, and exposes the synced and master positions for the DBLog watermark logic. |
|
charsetgen
command
Command charsetgen turns the .tsv tables in this directory into charset_tables.go, the single-byte decoding tables for the 7 character sets that have no decoder in golang.org/x/text (see issue #113).
|
Command charsetgen turns the .tsv tables in this directory into charset_tables.go, the single-byte decoding tables for the 7 character sets that have no decoder in golang.org/x/text (see issue #113). |
|
Package source.postgres implements the PostgreSQL replication source: a single logical-decoding reader (pgoutput) that decodes row changes into rowchange.Change, positions them at their commit LSN, and exposes the synced and confirmed positions for the DBLog watermark logic.
|
Package source.postgres implements the PostgreSQL replication source: a single logical-decoding reader (pgoutput) that decodes row changes into rowchange.Change, positions them at their commit LSN, and exposes the synced and confirmed positions for the DBLog watermark logic. |
Click to show internal directories.
Click to hide internal directories.