MCPcopy Create free account

hub / github.com/PostHog/duckgres / types & classes

Types & classes803 in github.com/PostHog/duckgres

↓ 12 callersFuncTypeStepExecutorFunc
func(context.Context, Step) error
tests/scenario/core/runner.go:31
↓ 12 callersTypeAliasdescribeColumnType
server/conn_describe_test.go:60
↓ 10 callersClassWarning
scripts/test_impact_plan.py:50
↓ 6 callersTypeAliasstaticColumnType
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 callersClassReportClient
scripts/client-compat/report_client.py:21
↓ 5 callersStructhandler
controlplane/provisioning/api.go:100
↓ 4 callersStructenv
controlplane/admin/live.go:197
↓ 2 callersTypeAliasFlightSessionState
FlightSessionState is the durable reconnect state for Flight-only sessions.
controlplane/configstore/models.go:393
↓ 2 callersTypeAliasLifecycleOperation
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 callersClassOrmTest
scripts/client-compat/clients/sqlalchemy/test_sqlalchemy.py:213
↓ 2 callersClassTestImpactPlan
scripts/test_impact_plan.py:57
↓ 2 callersTypeAliascontextKey
tests/scenario/core/runner_test.go:10
↓ 2 callersTypeAliasfakeResult
tests/perf/publisher/publisher_test.go:60
↓ 2 callersFuncTyperoundTripFunc
func(*http.Request) (*http.Response, error)
cmd/cache-proxy/proxy_test.go:26
↓ 2 callersClasssigaction
internal/crashhandler/handler.c:102
↓ 2 callersTypeAliasstubAddr
server/conn_passthrough_test.go:59
↓ 1 callersTypeAliasDurableSessionState
server/flightsqlingress/ingress.go:83
↓ 1 callersClassResults
scripts/client-compat/clients/sqlalchemy/test_sqlalchemy.py:46
↓ 1 callersClassResults
scripts/client-compat/clients/dbt/test_dbt.py:29
↓ 1 callersClassResults
scripts/client-compat/clients/pgadmin/test_pgadmin.py:64
↓ 1 callersClassResults
scripts/client-compat/clients/psycopg/test_psycopg.py:53
↓ 1 callersStructSession
Session represents a single DuckDB session.
duckdbservice/service.go:105
↓ 1 callersTypeAliasTransitionOutcomeReason
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 callersInterfaceWorkerPool
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 callersTypeAliasassertErr
tests/perf/publisher/publisher_test.go:65
Class
controlplane/admin/ui/src/lib/api.ts:42
StructACMEConfig
configloader/file_config.go:91
StructACMEDNSManager
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
StructACMEManager
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
StructAPIError
tests/scenario/provision/errors.go:51
StructActivationPayload
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
StructAdminAuditEntry
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
ClassApiError
controlplane/admin/ui/src/lib/api.ts:42
FuncTypeAppender
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
StructArtifactSink
tests/perf/core/sink.go:13
StructAssumedCredentials
AssumedCredentials holds the temporary credentials from STS AssumeRole.
controlplane/sts_broker.go:157
InterfaceAuditEntry
controlplane/admin/ui/src/types/api.ts:451
StructAuditStore
AuditStore persists admin audit entries.
controlplane/admin/audit.go:43
StructBackendKey
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
InterfaceBadgeProps
controlplane/admin/ui/src/components/ui/badge.tsx:23
ClassBase
scripts/client-compat/clients/sqlalchemy/test_sqlalchemy.py:209
StructBooleanPredicateTransform
BooleanPredicateTransform normalizes boolean literal comparisons in predicate-valued contexts so DuckLake doesn't see `= true/false` or `!= true/false
transpiler/transform/boolpredicates.go:11
StructBuildInfo
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
InterfaceButtonProps
controlplane/admin/ui/src/components/ui/button.tsx:29
StructCLIInputs
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
InterfaceCPInstance
controlplane/admin/ui/src/types/api.ts:302
StructCPInstance
CPInstance is a live control-plane replica.
controlplane/admin/live.go:111
StructCPUserSecretManager
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
StructCRMetadataStore
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
StructCacheProxy
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
StructCatalog
tests/perf/core/types.go:12
StructCatalogPolicy
transpiler/backend/profile.go:25
StructChildConfig
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
StructChildProcess
ChildProcess represents a spawned child worker process
server/parent.go:16
StructChildTracker
ChildTracker manages spawned child worker processes
server/parent.go:28
StructCipher
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
StructClassification
Classification is the result of pre-parse query classification.
transpiler/transpiler.go:44
InterfaceClassifiedError
tests/scenario/core/runner.go:26
StructClient
tests/scenario/provision/client.go:33
InterfaceClusterStatus
controlplane/admin/ui/src/types/api.ts:235
StructClusterStatus
ClusterStatus aggregates cluster state for the dashboard.
controlplane/admin/api.go:53
InterfaceClusterSummary
controlplane/admin/ui/src/types/api.ts:244
StructCodedError
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
InterfaceColumnTyper
ColumnTyper provides type name information for a database column. *sql.ColumnType satisfies this interface.
server/sqlcore/interfaces.go:19
StructCommandRequest
tests/scenario/dbt/steps.go:25
StructCommandResult
tests/scenario/dbt/steps.go:33
InterfaceCommandRunner
tests/scenario/dbt/steps.go:21
StructCompareOptions
CompareOptions configures comparison behavior
tests/integration/compare.go:27
StructCompareResult
CompareResult holds the result of comparing two query results
tests/integration/compare.go:15
StructComputeUsageDelta
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
StructComputeUsageRow
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
StructConfig
Config controls transpilation behavior
transpiler/config.go:6
StructConfig
tests/scenario/provision/client.go:27
StructConfig
tests/perf/publisher/publisher.go:40
StructConfig
server/server.go:173
StructConfig
server/flightsqlingress/ingress.go:61
StructConfig
Config configures DuckLake catalog attachment.
server/ducklake/config.go:13
StructConfigStore
ConfigStore manages configuration stored in a PostgreSQL database.
controlplane/configstore/store.go:91
InterfaceConfigStoreInterface
ConfigStoreInterface abstracts the config store for the control plane. Defined here to avoid circular imports with the configstore package.
controlplane/control.go:221
TypeAliasConflictHandling
transpiler/backend/profile.go:12
StructConnDetail
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
StructConnLiveSummary
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
StructConnectionConfig
tests/scenario/sql/connection.go:9
StructConnectionConfig
tests/perf/drivers/flight/driver.go:27
StructConnectionDetails
tests/scenario/provision/client.go:66
TypeAliasConstraintHandling
transpiler/backend/profile.go:10
StructControlPlane
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
StructControlPlaneConfig
ControlPlaneConfig extends server.Config with control-plane-specific settings.
controlplane/control.go:35
StructControlPlaneFlightSQLHandler
ControlPlaneFlightSQLHandler implements Flight SQL over control-plane sessions.
server/flightsqlingress/ingress.go:319
StructControlPlaneInstance
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
TypeAliasControlPlaneInstanceState
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
StructControlPlaneJanitor
controlplane/janitor.go:27
StructControlPlaneRuntimeTracker
controlplane/runtime_tracker.go:17
StructController
Controller polls the config store for actionable warehouses and reconciles their state against Duckling CRs in Kubernetes.
controlplane/provisioner/controller.go:64
StructController
Controller is a stub for non-Kubernetes builds.
controlplane/provisioner/controller_stub.go:14
StructCopyFromOptions
CopyFromOptions contains parsed options from a COPY FROM STDIN command
server/conn_copy.go:56
InterfaceCopyFromStdinExecutor
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
StructCopyToOptions
CopyToOptions contains parsed options from a COPY TO STDOUT command
server/conn_copy.go:124
StructCreateOptions
CreateOptions carries per-org knobs that shape the generated Duckling CR.
controlplane/provisioner/k8s_client.go:99
InterfaceCreateUserBody
controlplane/admin/ui/src/types/api.ts:99
next →1–100 of 803, ranked by callers