Prometheus Entity Management API
    Preparing search index...

    adapters/surreal-live.ts

    SurrealDB LIVE SELECT realtime adapter.

    SurrealDB live stream → per-channel state machine → RealtimeAdapter contract one ChannelConfig = one LIVE SELECT = one independent reconnect/replay state

    Implements the RealtimeAdapter contract (NOT SyncAdapter) per the corrected spec at openspec/specs/entity-surreal-live-adapter/spec.md. The consumer owns the SurrealDB client; the adapter only orchestrates live queries.

    interface SurrealLike {
        kill(uuid: string): Promise<void>;
        live<T = unknown>(
            table: string,
            callback: (action: SurrealLiveAction<T>) => void,
            diff?: boolean,
        ): Promise<string>;
        query<T = unknown>(
            sql: string,
            vars?: Record<string, unknown>,
        ): Promise<T[]>;
    }
    Index
    • Parameters

      • uuid: string

      Returns Promise<void>

    • Type Parameters

      • T = unknown

      Parameters

      Returns Promise<string>

    • Type Parameters

      • T = unknown

      Parameters

      • sql: string
      • Optionalvars: Record<string, unknown>

      Returns Promise<T[]>