MCPcopy
hub / github.com/PeerDB-io/peerdb / Query

Method Query

flow/internal/postgres.go:272–272  ·  view source on GitHub ↗
(ctx context.Context, sql string, args ...any)

Source from the content-addressed store, hash-verified

270// support both catalog pool and pgx.Tx
271type CatalogQuerier interface {
272 Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
273}
274
275func LoadTableSchemasFromCatalog(

Callers 15

registerSendersFromPoolMethod · 0.65
RecordMetricsAggregatesMethod · 0.65
getFlowsForMetricsMethod · 0.65
RecordSlotSizesMethod · 0.65
GetAllMirrorsMethod · 0.65
GetBackedUpFlowsMethod · 0.65
GetCompletedTablesFromQrepRunsMethod · 0.65
getTableNameSchemaMappingMethod · 0.65
getPostgresPeerConfigsMethod · 0.65
GetDestinationTableSchemaFunction · 0.65
GetCustomDataTypesFunction · 0.65
QueryFunction · 0.65

Implementers 5

mockConnflow/pkg/clickhouse/validation_test.go
CatalogPoolflow/shared/postgres.go
CatalogTxflow/shared/postgres.go
WorkflowRunflow/e2e/test_utils.go
PostgresSourceflow/e2e/pg.go

Calls

no outgoing calls

Tested by 15

TestAwsRDSIAMAuthConnectForPostgresFunction · 0.52
TestAwsRDSIAMAuthConnectForPostgresViaProxyFunction · 0.52
TestRemoveTablesFromPublicationFunction · 0.52
compareQueryMethod · 0.52
checkSyncedAtMethod · 0.52
TestQRepPauseMethod · 0.52
TestXminPauseMethod · 0.52
Test_Guardrails_WithinRowLimitMethod · 0.52
Test_Guardrails_ConnectionUsableAfterLimitExceededMethod · 0.52
queryWithOptionsMethod · 0.52
Test_Guardrails_ResumeAfterRowLimitMethod · 0.52
Test_Guardrails_ResumeAfterByteLimitMethod · 0.52