Directories
¶
| Path | Synopsis |
|---|---|
|
Package ackwatermark turns out-of-order acknowledgements into a cursor that is safe to persist.
|
Package ackwatermark turns out-of-order acknowledgements into a cursor that is safe to persist. |
|
Package avrodecode decodes Avro binary records into map[string]any.
|
Package avrodecode decodes Avro binary records into map[string]any. |
|
Package pgxutil centralizes pgx connection configuration so that every Postgres connection (source metadata, sink pool, pgvector pool, state store) is built consistently and is safe to use behind a transaction/statement pooling proxy such as PgBouncer.
|
Package pgxutil centralizes pgx connection configuration so that every Postgres connection (source metadata, sink pool, pgvector pool, state store) is built consistently and is safe to use behind a transaction/statement pooling proxy such as PgBouncer. |
|
Package schemaregistry speaks the Confluent Schema Registry wire format and REST API.
|
Package schemaregistry speaks the Confluent Schema Registry wire format and REST API. |
|
Package sqlident validates and quotes SQL identifiers.
|
Package sqlident validates and quotes SQL identifiers. |
|
Package tracing carries trace context on a message rather than in a Go context.
|
Package tracing carries trace context on a message rather than in a Go context. |
Click to show internal directories.
Click to hide internal directories.