@relayplane/telemetry

Telemetry queue and worker for workflow observability.

Features

• Local Queue: In-memory queue for workflow results
• Background Worker: Batches and flushes telemetry to cloud
• Non-Blocking: Telemetry failures never crash workflows
• Configurable: Batch size, flush interval, retry logic

Usage

import { relay } from '@relayplane/sdk';

relay.startTelemetry({
  apiKey: 'rp_...',
  endpoint: 'https://api.relayplane.com/v1/telemetry/logs',
  batchSize: 10,
  flushInterval: 5000,
  enabled: true
});

Architecture

• src/queue.ts - Telemetry queue implementation
• src/worker.ts - Background worker with batching and retry
• src/types.ts - Telemetry data types

Documentation

See /docs/Telemetry Schema Specification.md for schema details.