sinksql

package

v1.25.0 Latest Latest Go to latest Published: Oct 8, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func ExtractSinkService(pkg *pbsubstreams.Package) (*pbsql.Service, error)

This section is empty.

Path	Synopsis
bytes
db_changes
bundler
bundler/writer
db
sinker
state
db_proto
proto
sql
sql/click_house
sql/postgres
sql/postgres/pgcopy Package pgcopy writes the PostgreSQL binary COPY format ("PGCOPY").	Package pgcopy writes the PostgreSQL binary COPY format ("PGCOPY").
sql/schema
sql/spool Package spool holds a from-proto sink's rows on local disk, pre-encoded into whatever the target database can take unchanged, and applies whole segments from a separate goroutine.	Package spool holds a from-proto sink's rows on local disk, pre-encoded into whatever the target database can take unchanged, and applies whole segments from a separate goroutine.
stats
proto
services
tests
relations