import { BackendIdMismatchError, ServerAheadError, UnknownError } from '@livestore/common';
import { Rpc, RpcGroup, Schema } from '@livestore/utils/effect';
declare const SyncWsRpc_base: RpcGroup.RpcGroup<Rpc.Rpc<"SyncWsRpc.Pull", Schema.Struct<{
    cursor: Schema.Option<Schema.Struct<{
        backendId: Schema.SchemaClass<string, string, never>;
        eventSequenceNumber: Schema.BrandSchema<number & import("effect/Brand").Brand<"GlobalEventSequenceNumber">, number, never>;
    }>>;
    storeId: typeof Schema.String;
    payload: Schema.optional<Schema.Schema<Schema.JsonValue, Schema.JsonValue, never>>;
    /** Whether to keep the pull stream alive and wait for more events */
    live: typeof Schema.Boolean;
}>, import("@effect/rpc/RpcSchema").Stream<Schema.Struct<{
    batch: Schema.Array$<Schema.Struct<{
        eventEncoded: Schema.Struct<{
            name: typeof Schema.String;
            args: typeof Schema.Any;
            seqNum: Schema.BrandSchema<number & import("effect/Brand").Brand<"GlobalEventSequenceNumber">, number, never>;
            parentSeqNum: Schema.BrandSchema<number & import("effect/Brand").Brand<"GlobalEventSequenceNumber">, number, never>;
            clientId: typeof Schema.String;
            sessionId: typeof Schema.String;
        }>;
        metadata: Schema.Option<Schema.Struct<{
            _tag: Schema.tag<"SyncMessage.SyncMetadata">;
        } & {
            createdAt: typeof Schema.String;
        }>>;
    }>>;
    pageInfo: Schema.Union<[Schema.TaggedStruct<"MoreUnknown", {}>, Schema.TaggedStruct<"MoreKnown", {
        remaining: typeof Schema.Number;
    }>, Schema.TaggedStruct<"NoMore", {}>]>;
    backendId: Schema.SchemaClass<string, string, never>;
}>, Schema.Union<[typeof UnknownError, typeof BackendIdMismatchError]>>, typeof Schema.Never, never> | Rpc.Rpc<"SyncWsRpc.Push", Schema.Struct<{
    batch: Schema.Array$<Schema.Struct<{
        name: typeof Schema.String;
        args: typeof Schema.Any;
        seqNum: Schema.BrandSchema<number & import("effect/Brand").Brand<"GlobalEventSequenceNumber">, number, never>;
        parentSeqNum: Schema.BrandSchema<number & import("effect/Brand").Brand<"GlobalEventSequenceNumber">, number, never>;
        clientId: typeof Schema.String;
        sessionId: typeof Schema.String;
    }>>;
    backendId: Schema.Option<Schema.SchemaClass<string, string, never>>;
    storeId: typeof Schema.String;
    payload: Schema.optional<Schema.Schema<Schema.JsonValue, Schema.JsonValue, never>>;
}>, Schema.Struct<{}>, Schema.Union<[typeof UnknownError, typeof ServerAheadError, typeof BackendIdMismatchError]>, never>>;
/**
 * WebSocket RPC Schema for LiveStore CF Sync Provider
 *
 * This defines the RPC endpoints available over WebSocket transport.
 * Unlike HTTP transport which uses request/response patterns for each operation,
 * WebSocket transport maintains a persistent connection and uses streaming responses.
 */
export declare class SyncWsRpc extends SyncWsRpc_base {
}
export {};
//# sourceMappingURL=ws-rpc-schema.d.ts.map