import type { DatabaseSchema } from "./schema.js";
import { type KeyPropertyName, type Sync, type SyncChangeDelete, type SyncChangeUpsert } from "./sync.js";
export type WorkflowSyncTriggerResult = {
    status: "queued";
};
export type WorkflowSyncApplyResult = {
    upserted: number;
    deleted: number;
    skipped: number;
};
export type WorkflowSyncClient = {
    /**
     * Queue a run of the sync's own handler with its persisted state. Resolves
     * when the run is queued, not when the sync cycle finishes.
     */
    trigger(syncDefinition: Sync): Promise<WorkflowSyncTriggerResult>;
    /**
     * Write event-driven changes through the sync without running its handler.
     * Pass `state` to replace the sync's persisted state (for example, its
     * cursor); omit it to leave the state unchanged.
     */
    apply<S extends DatabaseSchema, PrimaryKey extends KeyPropertyName<S>, State>(syncDefinition: Sync<S, PrimaryKey, State>, args: {
        changes: Array<Pick<SyncChangeUpsert<S, PrimaryKey>, "type" | "key" | "properties" | "upstreamUpdatedAt"> | SyncChangeDelete>;
        state?: State;
    }): Promise<WorkflowSyncApplyResult>;
};
export declare function createWorkflowSyncClient(): WorkflowSyncClient;
//# sourceMappingURL=workflow-sync.d.ts.map