import { BackendIdMismatchError, ServerAheadError, UnknownError } from '@livestore/common'; import { Rpc, RpcGroup, Schema } from '@livestore/utils/effect'; declare const SyncDoRpc_base: RpcGroup.RpcGroup>; /** Omitting the cursor will start from the beginning */ cursor: Schema.Option; eventSequenceNumber: Schema.BrandSchema, number, never>; }>>; /** Whether to keep the pull stream alive and wait for more events */ rpcContext: Schema.optional; }>>; }>, import("@effect/rpc/RpcSchema").Stream, number, never>; parentSeqNum: Schema.BrandSchema, number, never>; clientId: typeof Schema.String; sessionId: typeof Schema.String; }>; metadata: Schema.Option; } & { createdAt: typeof Schema.String; }>>; }>>; pageInfo: Schema.Union<[Schema.TaggedStruct<"MoreUnknown", {}>, Schema.TaggedStruct<"MoreKnown", { remaining: typeof Schema.Number; }>, Schema.TaggedStruct<"NoMore", {}>]>; backendId: Schema.SchemaClass; rpcRequestId: typeof Schema.String; }>, Schema.Union<[typeof UnknownError, typeof BackendIdMismatchError]>>, typeof Schema.Never, never> | Rpc.Rpc<"SyncDoRpc.Push", Schema.Struct<{ /** * While the storeId is already implied by the Durable Object, we still need the explicit storeId * since a DO doesn't know its own id.name value. 🫠 * https://community.cloudflare.com/t/how-can-i-get-the-name-of-a-durable-object-from-itself/505961/8 */ storeId: typeof Schema.String; /** Needed for various reasons (e.g. auth) */ payload: Schema.optional>; batch: Schema.Array$, number, never>; parentSeqNum: Schema.BrandSchema, number, never>; clientId: typeof Schema.String; sessionId: typeof Schema.String; }>>; backendId: Schema.Option>; }>, Schema.Struct<{}>, Schema.Union<[typeof UnknownError, typeof ServerAheadError, typeof BackendIdMismatchError]>, never> | Rpc.Rpc<"SyncDoRpc.Ping", Schema.Struct<{ /** * While the storeId is already implied by the Durable Object, we still need the explicit storeId * since a DO doesn't know its own id.name value. 🫠 * https://community.cloudflare.com/t/how-can-i-get-the-name-of-a-durable-object-from-itself/505961/8 */ storeId: typeof Schema.String; /** Needed for various reasons (e.g. auth) */ payload: Schema.optional>; }>, typeof Schema.Void, typeof Schema.Never, never>>; export declare class SyncDoRpc extends SyncDoRpc_base { } export {}; //# sourceMappingURL=do-rpc-schema.d.ts.map