Module provider 

Query-back from telemetry providers (PostHog, Datadog). OTLP has no pull in v1.

Structs

PullPage

One page of remote rows; cursor is opaque to Kaizen.

PullWindow

Trailing time window for a pull (coarse; provider maps to its API).

Traits

TelemetryQueryProvider

Abstraction for PostHog / Datadog query APIs. OTLP is export-only, not a query authority.

Functions

from_config

Build a TelemetryQueryProvider for the configured query authority, or None when pull is off. Resolves credentials from the matching [[telemetry.exporters]] row first, then env. This way kaizen telemetry configure --type=datadog is enough to drive pull — users do not have to also export DD_API_KEY in their shell.

import_pull_page_to_remote

Parse each page.items entry as an OutboundEvent; on success, upsert into remote_events. Malformed or non-event JSON rows are skipped. Returns the number of rows written.