MCPcopy Create free account
hub / github.com/PostHog/duckgres / OrgRouterInterface

Interface OrgRouterInterface

controlplane/control.go:254–262  ·  view source on GitHub ↗

OrgRouterInterface abstracts the org router for the control plane.

Source from the content-addressed store, hash-verified

252
253 // computeMeter accumulates per-org compute-usage and flushes it to the
254 // durable buffer (remote/k8s backend with billing config only; nil
255 // otherwise — every call site is nil-safe). The leader-only drain loop that
256 // ships buffered usage to PostHog is wired separately in SetupMultiTenant.
257 computeMeter *computeMeter
258 metadataPostgresURL func(context.Context, string) (string, error)
259 metadataPostgresConnect func(context.Context, string) (metadataPostgresConn, error)
260 metadataSessions *metadataProxySessionRegistry
261 proxyCancels sync.Map
262}
263
264// ConfigStoreInterface abstracts the config store for the control plane.
265// Defined here to avoid circular imports with the configstore package.

Callers 13

ImpersonateMethod · 0.65
StackForOrgMethod · 0.65
CreateSessionMethod · 0.65
ReconnectSessionMethod · 0.65
handleConnectionMethod · 0.65
handleConnectionMethod · 0.65
RunControlPlaneFunction · 0.65
drainAfterUpgradeMethod · 0.65
ReleaseIdleHotWorkersMethod · 0.65
ReleaseIdleHotWorkersMethod · 0.65

Implementers 4

mockOrgRoutercontrolplane/org_router_test_helpers_t
reconnectTestOrgRoutercontrolplane/flight_ingress_test.go
recordingOrgRoutercontrolplane/flight_ingress_test.go
orgRouterAdaptercontrolplane/multitenant.go

Calls

no outgoing calls

Tested by

no test coverage detected