events

type Envelope struct {
	Seq   uint64 `json:"seq"`
	Event Event  `json:"event"`
}

type Event struct {
	// Ts is the event time in Unix microseconds. It must be wall-clock
	// (time.Now()) captured at emit/observe, never a monotonic or other
	// source-derived clock (e.g. a kmsg envelope timestamp), which skews
	// on VM suspend. HTTP-published events are stamped by the API handler;
	// in-process producers must set it themselves.
	Ts        int64                       `json:"ts"`
	Type      string                      `json:"type"`
	Category  oapi.TelemetryEventCategory `json:"category"`
	Source    oapi.BrowserEventSource     `json:"source"`
	Data      json.RawMessage             `json:"data,omitempty"`
	Truncated bool                        `json:"truncated,omitempty"`
}

type EventStream struct {
	// contains filtered or unexported fields
}

type EventStreamConfig struct {
	// RingCapacity is the number of envelopes the ring buffer holds.
	RingCapacity int
	// RingMaxBytes bounds the memory those envelopes may occupy. Zero uses
	// DefaultRingMaxBytes. Capacity alone does not bound memory: a slot holds
	// anything from a small control event to a base64 screenshot.
	RingMaxBytes uint64
}

type OTLPConfig struct {
	// Endpoint is the host[:port] of the OTLP/HTTP target: a collector in
	// development, or a forwarding relay in production.
	Endpoint string
	// URLPath overrides the request path. Empty uses the exporter default of
	// /v1/logs.
	URLPath string
	// Insecure sends over plaintext HTTP. Development only.
	Insecure bool
	// Headers are attached to every export request.
	Headers map[string]string
	// AuthTokenFunc, when set, is called on every export request to resolve the
	// bearer credential, set as "Authorization: Bearer <token>". It is read per
	// request (not captured once) so a credential that changes after start, e.g.
	// the instance JWT refreshed from an applied fork-identity payload, takes
	// effect without restarting the process. An empty return sends no header.
	AuthTokenFunc func() string

	// ServiceName, InstanceName, and Metro populate the OTLP Resource.
	ServiceName  string
	InstanceName string
	Metro        string
	// InstanceNameFunc and MetroFunc, when set, resolve the resource identity at
	// exporter-build time and take precedence over the static InstanceName/Metro.
	// Like AuthTokenFunc, this lets a forked VM stamp the fresh identity from its
	// applied fork-identity payload instead of stale boot env. Since export is
	// started per session after identity applies, build time sees the applied
	// values.
	InstanceNameFunc func() string
	MetroFunc        func() string

	// Batch tuning. Zero values fall back to the SDK defaults.
	MaxQueueSize   int
	ExportInterval time.Duration
	ExportTimeout  time.Duration

	// Metrics accumulates export counters. When nil a throwaway is used so the
	// sink still runs; callers that scrape metrics pass a shared instance.
	Metrics *OTLPMetrics
}

type OTLPExportController struct {
	// contains filtered or unexported fields
}

type OTLPMetrics struct {
	// contains filtered or unexported fields
}

type OTLPStorageWriter struct {
	// contains filtered or unexported fields
}

type ReadResult struct {
	Envelope *Envelope
	Dropped  uint64
}

type Reader struct {
	// contains filtered or unexported fields
}

type S2Config struct {
	// BatcherLinger is how long the batcher waits before flushing (default: 100ms).
	BatcherLinger time.Duration
	// BatcherMaxRecords is the max records per batch (default: 50).
	BatcherMaxRecords int
}

type S2StorageWriter struct {
	// contains filtered or unexported fields
}

type Storage interface {
	Append(ctx context.Context, env Envelope) error
	Close(ctx context.Context) error
}

type StorageWriter struct {
	// contains filtered or unexported fields
}