Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/PostHog/duckgres
/ types & classes
Types & classes
803 in github.com/PostHog/duckgres
⨍
Functions
5,901
◇
Types & classes
803
↓ 12 callers
FuncType
StepExecutorFunc
func(context.Context, Step) error
tests/scenario/core/runner.go:31
↓ 12 callers
TypeAlias
describeColumnType
server/conn_describe_test.go:60
↓ 10 callers
Class
Warning
scripts/test_impact_plan.py:50
↓ 6 callers
TypeAlias
staticColumnType
staticColumnType is a minimal ColumnTyper reporting a fixed DuckDB type name, used to synthesize a RowDescription without executing a query.
server/conn.go:1855
↓ 5 callers
Class
ReportClient
scripts/client-compat/report_client.py:21
↓ 5 callers
Struct
handler
controlplane/provisioning/api.go:100
↓ 4 callers
Struct
env
controlplane/admin/live.go:197
↓ 2 callers
TypeAlias
FlightSessionState
FlightSessionState is the durable reconnect state for Flight-only sessions.
controlplane/configstore/models.go:393
↓ 2 callers
TypeAlias
LifecycleOperation
LifecycleOperation is the stable, low-cardinality label that identifies a public WorkerLifecycle method on lifecycle-transition metrics. New values mu
controlplane/worker_lifecycle_metrics.go:16
↓ 2 callers
Class
OrmTest
scripts/client-compat/clients/sqlalchemy/test_sqlalchemy.py:213
↓ 2 callers
Class
TestImpactPlan
scripts/test_impact_plan.py:57
↓ 2 callers
TypeAlias
contextKey
tests/scenario/core/runner_test.go:10
↓ 2 callers
TypeAlias
fakeResult
tests/perf/publisher/publisher_test.go:60
↓ 2 callers
FuncType
roundTripFunc
func(*http.Request) (*http.Response, error)
cmd/cache-proxy/proxy_test.go:26
↓ 2 callers
Class
sigaction
internal/crashhandler/handler.c:102
↓ 2 callers
TypeAlias
stubAddr
server/conn_passthrough_test.go:59
↓ 1 callers
TypeAlias
DurableSessionState
server/flightsqlingress/ingress.go:83
↓ 1 callers
Class
Results
scripts/client-compat/clients/sqlalchemy/test_sqlalchemy.py:46
↓ 1 callers
Class
Results
scripts/client-compat/clients/dbt/test_dbt.py:29
↓ 1 callers
Class
Results
scripts/client-compat/clients/pgadmin/test_pgadmin.py:64
↓ 1 callers
Class
Results
scripts/client-compat/clients/psycopg/test_psycopg.py:53
↓ 1 callers
Struct
Session
Session represents a single DuckDB session.
duckdbservice/service.go:105
↓ 1 callers
TypeAlias
TransitionOutcomeReason
TransitionOutcomeReason classifies why a lifecycle transition did or did not happen. The values are stable and meant for telemetry — PR 6 will hang pe
controlplane/configstore/lifecycle_types.go:130
↓ 1 callers
Interface
WorkerPool
WorkerPool abstracts the lifecycle and scheduling of Flight SQL workers. Two implementations exist: - FlightWorkerPool: spawns workers as local child
controlplane/worker_pool.go:53
↓ 1 callers
TypeAlias
assertErr
tests/perf/publisher/publisher_test.go:65
Class
controlplane/admin/ui/src/lib/api.ts:42
Struct
ACMEConfig
configloader/file_config.go:91
Struct
ACMEDNSManager
ACMEDNSManager manages TLS certificates via ACME DNS-01 challenges using Route53. Unlike HTTP-01 (which requires port 80 reachable from the internet),
server/tlscert/acme_dns.go:31
Struct
ACMEManager
ACMEManager wraps autocert.Manager to provide Let's Encrypt TLS certificates. It starts an HTTP listener on port 80 for HTTP-01 challenge validation.
server/tlscert/acme.go:18
Struct
APIError
tests/scenario/provision/errors.go:51
Struct
ActivationPayload
ActivationPayload carries the tenant-specific runtime that is delivered to a neutral shared warm worker over the control-plane RPC channel.
duckdbservice/activation.go:17
Struct
AdminAuditEntry
AdminAuditEntry is one append-only record of an admin-UI action. Every mutation (config-store write, user/secret change) and every impersonation state
controlplane/admin/audit.go:19
Class
ApiError
controlplane/admin/ui/src/lib/api.ts:42
FuncType
Appender
Appender is a hook that handles append for value types arrowmap doesn't know about (typically driver-specific types like duckdb.Interval). It reports
duckdbservice/arrowmap/arrowmap.go:372
Struct
ArtifactSink
tests/perf/core/sink.go:13
Struct
AssumedCredentials
AssumedCredentials holds the temporary credentials from STS AssumeRole.
controlplane/sts_broker.go:157
Interface
AuditEntry
controlplane/admin/ui/src/types/api.ts:451
Struct
AuditStore
AuditStore persists admin audit entries.
controlplane/admin/audit.go:43
Struct
BackendKey
BackendKey identifies a backend connection for PostgreSQL cancel requests. Pid is the backend process id surfaced to the client; SecretKey is the matc
server/wire/backend_key.go:16
Interface
BadgeProps
controlplane/admin/ui/src/components/ui/badge.tsx:23
Class
Base
scripts/client-compat/clients/sqlalchemy/test_sqlalchemy.py:209
Struct
BooleanPredicateTransform
BooleanPredicateTransform normalizes boolean literal comparisons in predicate-valued contexts so DuckLake doesn't see `= true/false` or `!= true/false
transpiler/transform/boolpredicates.go:11
Struct
BuildInfo
BuildInfo carries the version/commit/date triple that each binary receives via -ldflags -X main.* at link time. Each package main owns its own var ver
internal/cliboot/buildinfo.go:18
Interface
ButtonProps
controlplane/admin/ui/src/components/ui/button.tsx:29
Struct
CLIInputs
CLIInputs carries the post-flag.Parse() values from the binary's main plus a Set map indicating which flags the user actually provided. The caller is
configresolve/resolve.go:27
Interface
CPInstance
controlplane/admin/ui/src/types/api.ts:302
Struct
CPInstance
CPInstance is a live control-plane replica.
controlplane/admin/live.go:111
Struct
CPUserSecretManager
CPUserSecretManager implements server.UserSecretManager on top of the config store: it seals user CREATE PERSISTENT SECRET statements with AES-GCM and
controlplane/user_secrets.go:24
Struct
CRMetadataStore
CRMetadataStore is the metadata-store slice of one Duckling CR's status — the live (composition-assigned) backend, notably which cnpg shard a cnpg-sha
controlplane/provisioner/k8s_client.go:256
Struct
CacheProxy
CacheProxy is a forward HTTP proxy that caches responses on local NVMe. DuckDB httpfs sends each S3 request as a signed plain-HTTP request to the prox
cmd/cache-proxy/proxy.go:42
Struct
Catalog
tests/perf/core/types.go:12
Struct
CatalogPolicy
transpiler/backend/profile.go:25
Struct
ChildConfig
ChildConfig contains all configuration needed by a child worker process. It is passed from parent to child via the DUCKGRES_CHILD_CONFIG env var as JS
server/worker.go:35
Struct
ChildProcess
ChildProcess represents a spawned child worker process
server/parent.go:16
Struct
ChildTracker
ChildTracker manages spawned child worker processes
server/parent.go:28
Struct
Cipher
Cipher seals and opens user secret statements with AES-256-GCM. The (org, user, name) row key is bound in as additional authenticated data, so a ciphe
server/usersecrets/crypto.go:24
Struct
Classification
Classification is the result of pre-parse query classification.
transpiler/transpiler.go:44
Interface
ClassifiedError
tests/scenario/core/runner.go:26
Struct
Client
tests/scenario/provision/client.go:33
Interface
ClusterStatus
controlplane/admin/ui/src/types/api.ts:235
Struct
ClusterStatus
ClusterStatus aggregates cluster state for the dashboard.
controlplane/admin/api.go:53
Interface
ClusterSummary
controlplane/admin/ui/src/types/api.ts:244
Struct
CodedError
CodedError is a transform-detected error that carries an explicit PostgreSQL SQLSTATE. conn_errors.go reads the code via the SQLState() method when se
transpiler/transform/errors.go:6
Interface
ColumnTyper
ColumnTyper provides type name information for a database column. *sql.ColumnType satisfies this interface.
server/sqlcore/interfaces.go:19
Struct
CommandRequest
tests/scenario/dbt/steps.go:25
Struct
CommandResult
tests/scenario/dbt/steps.go:33
Interface
CommandRunner
tests/scenario/dbt/steps.go:21
Struct
CompareOptions
CompareOptions configures comparison behavior
tests/integration/compare.go:27
Struct
CompareResult
CompareResult holds the result of comparing two query results
tests/integration/compare.go:15
Struct
ComputeUsageDelta
ComputeUsageDelta is one accumulator's compute-usage for a single billing key + time-bucket, ready to be flushed into the durable buffer. Counts are w
controlplane/configstore/compute_usage.go:21
Struct
ComputeUsageRow
ComputeUsageRow is one aggregated row served by the billing pull API: the sum of every closed bucket for one key on one UTC day. CPU and MemGiB are th
controlplane/configstore/compute_usage.go:36
Struct
Config
Config controls transpilation behavior
transpiler/config.go:6
Struct
Config
tests/scenario/provision/client.go:27
Struct
Config
tests/perf/publisher/publisher.go:40
Struct
Config
server/server.go:173
Struct
Config
server/flightsqlingress/ingress.go:61
Struct
Config
Config configures DuckLake catalog attachment.
server/ducklake/config.go:13
Struct
ConfigStore
ConfigStore manages configuration stored in a PostgreSQL database.
controlplane/configstore/store.go:91
Interface
ConfigStoreInterface
ConfigStoreInterface abstracts the config store for the control plane. Defined here to avoid circular imports with the configstore package.
controlplane/control.go:221
TypeAlias
ConflictHandling
transpiler/backend/profile.go:12
Struct
ConnDetail
ConnDetail is a redacted snapshot of one live client connection, for the admin live-query detail view. Query is the ALREADY-redacted current/last quer
server/exports.go:109
Struct
ConnLiveSummary
ConnLiveSummary is the per-connection live state the admin Live list needs: the pg_stat_activity-style State and the current-query start. State is "ac
server/exports.go:167
Struct
ConnectionConfig
tests/scenario/sql/connection.go:9
Struct
ConnectionConfig
tests/perf/drivers/flight/driver.go:27
Struct
ConnectionDetails
tests/scenario/provision/client.go:66
TypeAlias
ConstraintHandling
transpiler/backend/profile.go:10
Struct
ControlPlane
ControlPlane manages the TCP listener and routes connections to Flight SQL workers. The control plane owns client connections end-to-end: TLS, authent
controlplane/control.go:180
Struct
ControlPlaneConfig
ControlPlaneConfig extends server.Config with control-plane-specific settings.
controlplane/control.go:35
Struct
ControlPlaneFlightSQLHandler
ControlPlaneFlightSQLHandler implements Flight SQL over control-plane sessions.
server/flightsqlingress/ingress.go:319
Struct
ControlPlaneInstance
ControlPlaneInstance is a runtime coordination record for one control-plane process. These rows live in the runtime schema, not the snapshot-backed co
controlplane/configstore/models.go:288
TypeAlias
ControlPlaneInstanceState
NOTE: the cluster-wide singleton config tables (global_config, ducklake_config, rate_limit_config, query_log_config) were removed — they were seeded a
controlplane/configstore/models.go:278
Struct
ControlPlaneJanitor
controlplane/janitor.go:27
Struct
ControlPlaneRuntimeTracker
controlplane/runtime_tracker.go:17
Struct
Controller
Controller polls the config store for actionable warehouses and reconciles their state against Duckling CRs in Kubernetes.
controlplane/provisioner/controller.go:64
Struct
Controller
Controller is a stub for non-Kubernetes builds.
controlplane/provisioner/controller_stub.go:14
Struct
CopyFromOptions
CopyFromOptions contains parsed options from a COPY FROM STDIN command
server/conn_copy.go:56
Interface
CopyFromStdinExecutor
CopyFromStdinExecutor is an optional capability implemented by executors that need the CSV bytes shipped to a different filesystem than the one the CO
server/sqlcore/interfaces.go:74
Struct
CopyToOptions
CopyToOptions contains parsed options from a COPY TO STDOUT command
server/conn_copy.go:124
Struct
CreateOptions
CreateOptions carries per-org knobs that shape the generated Duckling CR.
controlplane/provisioner/k8s_client.go:99
Interface
CreateUserBody
controlplane/admin/ui/src/types/api.ts:99
next →
1–100 of 803, ranked by callers