livekit

type ReportStats struct {
	RetainedEvents uint64
	RetainedBytes  uint64
	DroppedEvents  uint64
	CaptureError   error
}

type Runtime[UserData any] struct {
	// contains filtered or unexported fields
}

type StartOptions[UserData any] struct {
	Job            *agents.JobContext[UserData]
	ConnectOptions agents.ConnectOptions

	RoomInput  *roomio.RoomInputOptions
	RoomOutput *roomio.RoomOutputOptions
	RoomIO     *roomio.RoomIO

	// Recording inherits livekit.Job.enable_recording when zero-valued. A
	// concrete sparse update explicitly selects its granular policy.
	Recording       agents.Override[voice.RecordingOptionsUpdate]
	Recorder        *recorderio.RecorderIO
	RecorderOptions recorderio.RecorderOptions

	EventCapacity   int
	MaxReportEvents int
	MaxReportBytes  int
	CloseTimeout    time.Duration
	FinalizeTimeout time.Duration

	Logger     *slog.Logger
	HTTPClient *http.Client
	Metadata   map[string]any
	UploadGate *telemetry.UploadGate
	// ObservabilityURL overrides Cloud endpoint discovery. It must be an
	// origin URL; LIVEKIT_OBSERVABILITY_URL is used when this field is empty.
	ObservabilityURL      string
	RecordingEndpoint     string
	LogEndpoint           string
	DisableCloudTelemetry bool

	// OnReport runs after the immutable report is assembled and before local
	// persistence or Cloud upload. It must honor ctx.
	OnReport func(context.Context, *voice.SessionReport) error
	// OnError receives asynchronous RoomIO and report-capture errors. Panics are
	// isolated. The Runtime also exposes the first capture error in ReportStats.
	OnError func(error)
}