import type { EdgeTransfer, EdgeTransferId, NodeAttempt, NodeAttemptId, NodeAttemptStatus, WorkflowArchiveStateRecord, WorkflowCheckpoint, WorkflowCheckpointId, WorkflowDefinitionSnapshot, WorkflowDefinitionSnapshotId, WorkflowDeleteTombstoneRecord, WorkflowDraftRecord, WorkflowDraftValidationState, WorkflowEventId, WorkflowEventRecord, WorkflowHumanActionId, WorkflowHumanActionKind, WorkflowHumanActionRecord, WorkflowIdentityRecord, WorkflowPublishedVersionRecord, WorkflowRun, WorkflowRunId, WorkflowRunStatus, WorkflowWakeup, WorkflowWakeupId, WorkflowWaitToken, WorkflowWaitTokenId, WorkflowWaitTokenStatus } from "../types/index.js"; export type WorkflowRunStore = { saveRun(run: WorkflowRun): void | Promise; getRun(id: WorkflowRunId): WorkflowRun | undefined | Promise; }; export type WorkflowDefinitionSnapshotStore = { saveDefinitionSnapshot(snapshot: WorkflowDefinitionSnapshot): void | Promise; getDefinitionSnapshot(id: WorkflowDefinitionSnapshotId): WorkflowDefinitionSnapshot | undefined | Promise; listDefinitionSnapshots(filter?: WorkflowDefinitionSnapshotListFilter): WorkflowDefinitionSnapshot[] | Promise; }; export type WorkflowIdentityStore = { saveWorkflowIdentity(record: WorkflowIdentityRecord): void | Promise; getWorkflowIdentity(workflowId: string): WorkflowIdentityRecord | undefined | Promise; listWorkflowIdentities(filter?: WorkflowIdentityListFilter): WorkflowIdentityRecord[] | Promise; }; export type WorkflowDraftStore = { saveWorkflowDraft(record: WorkflowDraftRecord): void | Promise; getWorkflowDraft(draftId: string): WorkflowDraftRecord | undefined | Promise; listWorkflowDrafts(filter?: WorkflowDraftListFilter): WorkflowDraftRecord[] | Promise; }; export type WorkflowArchiveStateStore = { saveWorkflowArchiveState(record: WorkflowArchiveStateRecord): void | Promise; getWorkflowArchiveState(workflowId: string): WorkflowArchiveStateRecord | undefined | Promise; listWorkflowArchiveStates(filter?: WorkflowArchiveStateListFilter): WorkflowArchiveStateRecord[] | Promise; }; export type WorkflowDeleteTombstoneStore = { saveWorkflowDeleteTombstone(record: WorkflowDeleteTombstoneRecord): void | Promise; getWorkflowDeleteTombstone(workflowId: string): WorkflowDeleteTombstoneRecord | undefined | Promise; listWorkflowDeleteTombstones(filter?: WorkflowDeleteTombstoneListFilter): WorkflowDeleteTombstoneRecord[] | Promise; }; export type WorkflowPublishedVersionStore = { savePublishedWorkflowVersion(record: WorkflowPublishedVersionRecord): void | Promise; getPublishedWorkflowVersion(workflowId: string, version: string): WorkflowPublishedVersionRecord | undefined | Promise; listPublishedWorkflowVersions(filter?: WorkflowPublishedVersionListFilter): WorkflowPublishedVersionRecord[] | Promise; }; export type WorkflowEventStore = { saveEvent(event: WorkflowEventRecord): void | Promise; getEvent(id: WorkflowEventId): WorkflowEventRecord | undefined | Promise; listEvents(filter?: WorkflowEventListFilter): WorkflowEventRecord[] | Promise; }; export type WorkflowWaitTokenStore = { saveWaitToken(token: WorkflowWaitToken): void | Promise; getWaitToken(id: WorkflowWaitTokenId): WorkflowWaitToken | undefined | Promise; listWaitTokens(filter?: WorkflowWaitTokenListFilter): WorkflowWaitToken[] | Promise; }; export type WorkflowNodeAttemptStore = { saveNodeAttempt(nodeAttempt: NodeAttempt): void | Promise; getNodeAttempt(id: NodeAttemptId): NodeAttempt | undefined | Promise; listNodeAttempts(filter?: WorkflowNodeAttemptListFilter): NodeAttempt[] | Promise; }; export type WorkflowEdgeTransferStore = { saveEdgeTransfer(transfer: EdgeTransfer): void | Promise; getEdgeTransfer(id: EdgeTransferId): EdgeTransfer | undefined | Promise; listEdgeTransfers(filter?: WorkflowEdgeTransferListFilter): EdgeTransfer[] | Promise; }; export type WorkflowCheckpointStore = { saveCheckpoint(checkpoint: WorkflowCheckpoint): void | Promise; getCheckpoint(id: WorkflowCheckpointId): WorkflowCheckpoint | undefined | Promise; listCheckpoints(filter?: WorkflowCheckpointListFilter): WorkflowCheckpoint[] | Promise; }; export type WorkflowWakeupStore = { saveWakeup(wakeup: WorkflowWakeup): void | Promise; getWakeup(id: WorkflowWakeupId): WorkflowWakeup | undefined | Promise; listWakeups(filter?: WorkflowWakeupListFilter): WorkflowWakeup[] | Promise; }; export type WorkflowHumanActionStore = { saveHumanAction(action: WorkflowHumanActionRecord): void | Promise; getHumanAction(id: WorkflowHumanActionId): WorkflowHumanActionRecord | undefined | Promise; listHumanActions(filter?: WorkflowHumanActionListFilter): WorkflowHumanActionRecord[] | Promise; }; export type WorkflowRunListFilter = { workflowId?: string; piboSessionId?: string; status?: WorkflowRunStatus; limit?: number; }; export type WorkflowDefinitionSnapshotListFilter = { workflowId?: string; workflowVersion?: string; hash?: string; limit?: number; }; export type WorkflowIdentityListFilter = { workflowId?: string; limit?: number; }; export type WorkflowDraftListFilter = { workflowId?: string; validationState?: WorkflowDraftValidationState; limit?: number; }; export type WorkflowArchiveStateListFilter = { archived?: boolean; limit?: number; }; export type WorkflowDeleteTombstoneListFilter = { limit?: number; }; export type WorkflowPublishedVersionListFilter = { workflowId?: string; limit?: number; }; export type WorkflowEventListFilter = { workflowRunId?: WorkflowRunId; type?: string; nodeId?: string; edgeId?: string; attemptId?: NodeAttemptId; limit?: number; }; export type WorkflowWaitTokenListFilter = { workflowRunId?: WorkflowRunId; status?: WorkflowWaitTokenStatus; humanNodeId?: string; limit?: number; }; export type WorkflowNodeAttemptListFilter = { workflowRunId?: WorkflowRunId; nodeId?: string; kind?: NodeAttempt["kind"]; status?: NodeAttemptStatus; limit?: number; }; export type WorkflowEdgeTransferListFilter = { workflowRunId?: WorkflowRunId; edgeId?: string; targetNodeId?: string; status?: EdgeTransfer["status"]; limit?: number; }; export type WorkflowCheckpointListFilter = { workflowRunId?: WorkflowRunId; namespace?: string; limit?: number; }; export type WorkflowWakeupListFilter = { workflowRunId?: WorkflowRunId; nodeAttemptId?: NodeAttemptId; kind?: WorkflowWakeup["kind"]; correlationId?: string; limit?: number; }; export type WorkflowHumanActionListFilter = { workflowRunId?: WorkflowRunId; waitTokenId?: WorkflowWaitTokenId; kind?: WorkflowHumanActionKind; limit?: number; }; //# sourceMappingURL=contracts.d.ts.map