import type { Id } from "./_generated/dataModel.js";
type PreparedTelegramAttachment = {
    kind: "photo" | "video" | "audio" | "voice" | "document";
    status: "ready";
    storageId: Id<"_storage">;
    telegramFileId: string;
    fileName?: string;
    mimeType?: string;
    sizeBytes?: number;
    expiresAt: number;
    downloadUrl?: string;
};
export declare const enqueueMessage: import("convex/server").RegisteredMutation<"public", {
    providerConfig?: {
        appName: string;
        kind: "fly" | "runpod" | "ecs";
        organizationSlug: string;
        image: string;
        region: string;
        volumeName: string;
        volumePath: string;
        volumeSizeGb: number;
    } | undefined;
    nowMs?: number | undefined;
    maxAttempts?: number | undefined;
    priority?: number | undefined;
    scheduledFor?: number | undefined;
    agentKey: string;
    conversationId: string;
    payload: {
        metadata?: Record<string, string> | undefined;
        attachments?: {
            sizeBytes?: number | undefined;
            fileName?: string | undefined;
            mimeType?: string | undefined;
            downloadUrl?: string | undefined;
            status: "expired" | "ready";
            storageId: import("convex/values").GenericId<"_storage">;
            kind: "photo" | "video" | "audio" | "voice" | "document";
            telegramFileId: string;
            expiresAt: number;
        }[] | undefined;
        externalMessageId?: string | undefined;
        rawUpdateJson?: string | undefined;
        provider: string;
        providerUserId: string;
        messageText: string;
    };
}, Promise<import("convex/values").GenericId<"messageQueue">>>;
export declare const appendConversationMessages: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    workspaceId?: string | undefined;
    conversationId: string;
    messages: {
        at?: number | undefined;
        content: string;
        role: "system" | "user" | "assistant" | "tool";
    }[];
}, Promise<{
    updated: boolean;
    messageCount: number;
}>>;
export declare const upsertAgentProfile: import("convex/server").RegisteredMutation<"public", {
    botIdentity?: string | undefined;
    bridgeConfig?: {
        baseUrl?: string | undefined;
        serviceId?: string | undefined;
        appKey?: string | undefined;
        serviceKeySecretRef?: string | undefined;
        appBaseUrlMapJsonSecretRef?: string | undefined;
        enabled: boolean;
    } | undefined;
    agentKey: string;
    enabled: boolean;
    secretsRef: string[];
    version: string;
}, Promise<import("convex/values").GenericId<"agentProfiles">>>;
export declare const importPlaintextSecret: import("convex/server").RegisteredMutation<"public", {
    metadata?: Record<string, string> | undefined;
    secretRef: string;
    plaintextValue: string;
}, Promise<{
    secretId: import("convex/values").GenericId<"secrets">;
    secretRef: string;
    version: number;
}>>;
export declare const getSecretsStatus: import("convex/server").RegisteredQuery<"public", {
    secretRefs: string[];
}, Promise<{
    secretRef: string;
    hasActive: boolean;
    version: number | null;
}[]>>;
export declare const getActiveSecretPlaintext: import("convex/server").RegisteredQuery<"internal", {
    secretRef: string;
}, Promise<string | null>>;
export declare const getWorkerSpawnOpenClawEnv: import("convex/server").RegisteredQuery<"internal", {}, Promise<{
    OPENCLAW_SERVICE_ID?: string;
    OPENCLAW_SERVICE_KEY?: string;
    OPENCLAW_LINKING_SHARED_SECRET?: string;
}>>;
export declare const getActiveConversationsForScheduler: import("convex/server").RegisteredQuery<"internal", {
    nowMs?: number | undefined;
    limit?: number | undefined;
}, Promise<{
    conversationId: string;
    agentKey: string;
}[]>>;
export declare const getProviderRuntimeConfig: import("convex/server").RegisteredQuery<"internal", {}, Promise<{
    appName: string;
    kind: "fly" | "runpod" | "ecs";
    organizationSlug: string;
    image: string;
    region: string;
    volumeName: string;
    volumePath: string;
    volumeSizeGb: number;
} | null>>;
export declare const upsertProviderRuntimeConfig: import("convex/server").RegisteredMutation<"internal", {
    nowMs?: number | undefined;
    providerConfig: {
        appName: string;
        kind: "fly" | "runpod" | "ecs";
        organizationSlug: string;
        image: string;
        region: string;
        volumeName: string;
        volumePath: string;
        volumeSizeGb: number;
    };
}, Promise<null>>;
export declare const providerRuntimeConfig: import("convex/server").RegisteredQuery<"public", {}, Promise<{
    appName: string;
    kind: "fly" | "runpod" | "ecs";
    organizationSlug: string;
    image: string;
    region: string;
    volumeName: string;
    volumePath: string;
    volumeSizeGb: number;
} | null>>;
export declare const setProviderRuntimeConfig: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    providerConfig: {
        appName: string;
        kind: "fly" | "runpod" | "ecs";
        organizationSlug: string;
        image: string;
        region: string;
        volumeName: string;
        volumePath: string;
        volumeSizeGb: number;
    };
}, Promise<null>>;
export declare const getMessageRuntimeConfig: import("convex/server").RegisteredQuery<"internal", {}, Promise<{
    systemPrompt?: string | undefined;
    telegramAttachmentRetentionMs?: number | undefined;
} | null>>;
export declare const getTelegramIngressRuntimeConfig: import("convex/server").RegisteredQuery<"internal", {
    agentKey: string;
}, Promise<{
    botToken: string | null;
    attachmentRetentionMs: number;
}>>;
export declare const prepareTelegramAttachmentsForEnqueue: import("convex/server").RegisteredAction<"public", {
    agentKey: string;
    attachments: {
        sizeBytes?: number | undefined;
        fileName?: string | undefined;
        mimeType?: string | undefined;
        kind: "photo" | "video" | "audio" | "voice" | "document";
        telegramFileId: string;
    }[];
}, Promise<PreparedTelegramAttachment[]>>;
export declare const upsertMessageRuntimeConfig: import("convex/server").RegisteredMutation<"internal", {
    nowMs?: number | undefined;
    messageConfig: {
        systemPrompt?: string | undefined;
        telegramAttachmentRetentionMs?: number | undefined;
    };
}, Promise<null>>;
export declare const messageRuntimeConfig: import("convex/server").RegisteredQuery<"public", {}, Promise<{
    systemPrompt?: string | undefined;
    telegramAttachmentRetentionMs?: number | undefined;
} | null>>;
export declare const setMessageRuntimeConfig: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    messageConfig: {
        systemPrompt?: string | undefined;
        telegramAttachmentRetentionMs?: number | undefined;
    };
}, Promise<null>>;
export declare const deployGlobalSkill: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    actor?: string | undefined;
    description?: string | undefined;
    displayName?: string | undefined;
    entryPoint?: string | undefined;
    moduleFormat?: "esm" | "cjs" | undefined;
    releaseChannel?: "stable" | "canary" | undefined;
    version: string;
    slug: string;
    files: {
        content: string;
        sha256: string;
        path: string;
    }[];
}, Promise<{
    skillId: import("convex/values").GenericId<"globalSkills">;
    versionId: import("convex/values").GenericId<"globalSkillVersions">;
    releaseId: import("convex/values").GenericId<"globalSkillReleases">;
    slug: string;
    version: string;
    sha256: string;
    releaseChannel: "stable" | "canary";
}>>;
export declare const listGlobalSkills: import("convex/server").RegisteredQuery<"public", {
    status?: "active" | "disabled" | undefined;
    limit?: number | undefined;
    releaseChannel?: "stable" | "canary" | undefined;
}, Promise<{
    skillId: any;
    slug: string;
    displayName: string;
    description?: string;
    status: "active" | "disabled";
    updatedAt: number;
    activeRelease: {
        releaseId: any;
        versionId: any;
        version: string;
        sha256: string;
        moduleFormat: "esm" | "cjs";
        entryPoint: string;
        releaseChannel: "stable" | "canary";
        activatedAt: number;
    } | null;
}[]>>;
export declare const getWorkerGlobalSkillsManifest: import("convex/server").RegisteredQuery<"public", {
    workspaceId?: string | undefined;
    workerId?: string | undefined;
    releaseChannel?: "stable" | "canary" | undefined;
}, Promise<{
    layoutVersion: "openclaw-workspace-skill-v1";
    manifestVersion: string;
    generatedAt: number;
    releaseChannel: "stable" | "canary";
    workspaceId: string;
    skills: {
        slug: string;
        version: string;
        moduleFormat: "esm" | "cjs";
        entryPoint: string;
        sha256: string;
        skillDirName: string;
        files: Array<{
            path: string;
            content: string;
            sha256: string;
        }>;
    }[];
}>>;
export declare const setGlobalSkillStatus: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    actor?: string | undefined;
    status: "active" | "disabled";
    slug: string;
}, Promise<{
    updated: boolean;
    slug: string;
    status: "active" | "disabled";
}>>;
export declare const deleteGlobalSkill: import("convex/server").RegisteredMutation<"public", {
    slug: string;
}, Promise<{
    deleted: boolean;
    slug: string;
    deletedVersions: number;
    deletedReleases: number;
}>>;
export declare const generateMediaUploadUrl: import("convex/server").RegisteredMutation<"public", {}, Promise<{
    uploadUrl: string;
}>>;
export declare const getStorageFileUrl: import("convex/server").RegisteredQuery<"public", {
    storageId: import("convex/values").GenericId<"_storage">;
}, Promise<string | null>>;
export declare const attachMessageMetadata: import("convex/server").RegisteredMutation<"public", {
    metadata: Record<string, string>;
    messageId: import("convex/values").GenericId<"messageQueue">;
}, Promise<boolean>>;
export declare const claimNextJob: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    conversationId?: string | undefined;
    workerId: string;
}, Promise<{
    messageId: import("convex/values").GenericId<"messageQueue">;
    conversationId: string;
    agentKey: string;
    leaseId: string;
    leaseExpiresAt: number;
    payload: {
        metadata?: Record<string, string> | undefined;
        attachments?: {
            sizeBytes?: number | undefined;
            fileName?: string | undefined;
            mimeType?: string | undefined;
            downloadUrl?: string | undefined;
            status: "expired" | "ready";
            storageId: import("convex/values").GenericId<"_storage">;
            kind: "photo" | "video" | "audio" | "voice" | "document";
            telegramFileId: string;
            expiresAt: number;
        }[] | undefined;
        externalMessageId?: string | undefined;
        rawUpdateJson?: string | undefined;
        provider: string;
        providerUserId: string;
        messageText: string;
    };
} | null>>;
export declare const heartbeatJob: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    messageId: import("convex/values").GenericId<"messageQueue">;
    workerId: string;
    leaseId: string;
}, Promise<boolean>>;
export declare const completeJob: import("convex/server").RegisteredMutation<"public", {
    providerConfig?: {
        appName: string;
        kind: "fly" | "runpod" | "ecs";
        organizationSlug: string;
        image: string;
        region: string;
        volumeName: string;
        volumePath: string;
        volumeSizeGb: number;
    } | undefined;
    nowMs?: number | undefined;
    messageId: import("convex/values").GenericId<"messageQueue">;
    workerId: string;
    leaseId: string;
}, Promise<boolean>>;
export declare const failJob: import("convex/server").RegisteredMutation<"public", {
    providerConfig?: {
        appName: string;
        kind: "fly" | "runpod" | "ecs";
        organizationSlug: string;
        image: string;
        region: string;
        volumeName: string;
        volumePath: string;
        volumeSizeGb: number;
    } | undefined;
    nowMs?: number | undefined;
    messageId: import("convex/values").GenericId<"messageQueue">;
    workerId: string;
    leaseId: string;
    errorMessage: string;
}, Promise<{
    requeued: boolean;
    deadLettered: boolean;
    nextScheduledFor: number | null;
}>>;
export declare const releaseExpiredLeases: import("convex/server").RegisteredMutation<"internal", {
    nowMs?: number | undefined;
    limit?: number | undefined;
}, Promise<{
    requeued: number;
    unlocked: number;
}>>;
export declare const releaseStuckJobs: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    limit?: number | undefined;
}, Promise<{
    requeued: number;
    unlocked: number;
}>>;
export declare const getHydrationBundleForClaimedJob: import("convex/server").RegisteredQuery<"public", {
    workspaceId: string;
    messageId: import("convex/values").GenericId<"messageQueue">;
}, Promise<{
    messageId: import("convex/values").GenericId<"messageQueue">;
    conversationId: string;
    agentKey: string;
    payload: {
        provider: string;
        providerUserId: string;
        messageText: string;
        externalMessageId?: string;
        rawUpdateJson?: string;
        metadata?: Record<string, string>;
        attachments?: Array<{
            kind: "photo" | "video" | "audio" | "voice" | "document";
            status: "ready" | "expired";
            storageId: Id<"_storage">;
            telegramFileId: string;
            fileName?: string;
            mimeType?: string;
            sizeBytes?: number;
            expiresAt: number;
            downloadUrl?: string;
        }>;
    };
    conversationState: {
        contextHistory: {
            content: string;
            role: "system" | "user" | "assistant" | "tool";
            at: number;
        }[];
        pendingToolCalls: {
            status: "pending" | "failed" | "running" | "done";
            toolName: string;
            callId: string;
        }[];
    };
    telegramBotToken: string | null;
    bridgeRuntimeConfig: {
        baseUrl: string | null;
        appBaseUrlMapJson: string | null;
        serviceId: string | null;
        appKey: string | null;
        serviceKey: string | null;
        serviceKeySecretRef: string | null;
        botIdentity: string | null;
    } | null;
} | null>>;
export declare const getQueueStats: import("convex/server").RegisteredQuery<"public", {
    nowMs?: number | undefined;
}, Promise<{
    queuedReady: number;
    processing: number;
    deadLetter: number;
}>>;
export declare const hasQueuedJobsForConversation: import("convex/server").RegisteredQuery<"public", {
    conversationId: string;
}, Promise<boolean>>;
export declare const listQueueItemsForConversation: import("convex/server").RegisteredQuery<"public", {
    limit?: number | undefined;
    conversationId: string;
}, Promise<{
    _id: import("convex/values").GenericId<"messageQueue">;
    _creationTime: number;
    conversationId: string;
    agentKey: string;
    status: "failed" | "done" | "queued" | "processing" | "dead_letter";
    priority: number;
    scheduledFor: number;
    attempts: number;
    maxAttempts: number;
    lastError: string | null;
    payload: {
        metadata?: Record<string, string> | undefined;
        attachments?: {
            sizeBytes?: number | undefined;
            fileName?: string | undefined;
            mimeType?: string | undefined;
            downloadUrl?: string | undefined;
            status: "expired" | "ready";
            storageId: import("convex/values").GenericId<"_storage">;
            kind: "photo" | "video" | "audio" | "voice" | "document";
            telegramFileId: string;
            expiresAt: number;
        }[] | undefined;
        externalMessageId?: string | undefined;
        rawUpdateJson?: string | undefined;
        provider: string;
        providerUserId: string;
        messageText: string;
    };
}[]>>;
export declare const listQueueItemsForUserAgent: import("convex/server").RegisteredQuery<"public", {
    limit?: number | undefined;
    statuses?: ("failed" | "done" | "queued" | "processing" | "dead_letter")[] | undefined;
    agentKey: string;
    consumerUserId: string;
}, Promise<{
    _id: import("convex/values").GenericId<"messageQueue">;
    _creationTime: number;
    conversationId: string;
    agentKey: string;
    status: "failed" | "done" | "queued" | "processing" | "dead_letter";
    priority: number;
    scheduledFor: number;
    attempts: number;
    maxAttempts: number;
    lastError: string | null;
    payload: {
        metadata?: Record<string, string> | undefined;
        attachments?: {
            sizeBytes?: number | undefined;
            fileName?: string | undefined;
            mimeType?: string | undefined;
            downloadUrl?: string | undefined;
            status: "expired" | "ready";
            storageId: import("convex/values").GenericId<"_storage">;
            kind: "photo" | "video" | "audio" | "voice" | "document";
            telegramFileId: string;
            expiresAt: number;
        }[] | undefined;
        externalMessageId?: string | undefined;
        rawUpdateJson?: string | undefined;
        provider: string;
        providerUserId: string;
        messageText: string;
    };
}[]>>;
export declare const getConversationViewForUserAgent: import("convex/server").RegisteredQuery<"public", {
    limit?: number | undefined;
    agentKey: string;
    consumerUserId: string;
}, Promise<{
    conversationId: string;
    contextHistory: {
        content: string;
        role: "system" | "user" | "assistant" | "tool";
        at: number;
    }[];
    pendingToolCalls: {
        status: "pending" | "failed" | "running" | "done";
        toolName: string;
        callId: string;
    }[];
    queueItems: {
        _id: import("convex/values").GenericId<"messageQueue">;
        _creationTime: number;
        conversationId: string;
        agentKey: string;
        status: "failed" | "done" | "queued" | "processing" | "dead_letter";
        priority: number;
        scheduledFor: number;
        attempts: number;
        maxAttempts: number;
        lastError: string | null;
        payload: {
            metadata?: Record<string, string> | undefined;
            attachments?: {
                sizeBytes?: number | undefined;
                fileName?: string | undefined;
                mimeType?: string | undefined;
                downloadUrl?: string | undefined;
                status: "expired" | "ready";
                storageId: import("convex/values").GenericId<"_storage">;
                kind: "photo" | "video" | "audio" | "voice" | "document";
                telegramFileId: string;
                expiresAt: number;
            }[] | undefined;
            externalMessageId?: string | undefined;
            rawUpdateJson?: string | undefined;
            provider: string;
            providerUserId: string;
            messageText: string;
        };
    }[];
    hasQueuedJobs: boolean;
    latestMessageId: import("convex/values").GenericId<"messageQueue">;
    lastUserMessageAt: number | null;
    lastAssistantMessageAt: number | null;
}>>;
export declare const sendMessageToUserAgent: import("convex/server").RegisteredMutation<"public", {
    providerConfig?: {
        appName: string;
        kind: "fly" | "runpod" | "ecs";
        organizationSlug: string;
        image: string;
        region: string;
        volumeName: string;
        volumePath: string;
        volumeSizeGb: number;
    } | undefined;
    metadata?: Record<string, string> | undefined;
    nowMs?: number | undefined;
    agentKey: string;
    consumerUserId: string;
    content: string;
}, Promise<import("convex/values").GenericId<"messageQueue">>>;
export declare const sendMessageTemplateToUserAgent: import("convex/server").RegisteredMutation<"public", {
    providerConfig?: {
        appName: string;
        kind: "fly" | "runpod" | "ecs";
        organizationSlug: string;
        image: string;
        region: string;
        volumeName: string;
        volumePath: string;
        volumeSizeGb: number;
    } | undefined;
    metadata?: Record<string, string> | undefined;
    nowMs?: number | undefined;
    agentKey: string;
    consumerUserId: string;
    templateId: import("convex/values").GenericId<"messageTemplates">;
}, Promise<{
    messageId: import("convex/values").GenericId<"messageQueue">;
    usageCount: number;
}>>;
export declare const listSnapshotsForConversation: import("convex/server").RegisteredQuery<"public", {
    nowMs?: number | undefined;
    limit?: number | undefined;
    conversationId: string;
}, Promise<{
    snapshotId: import("convex/values").GenericId<"dataSnapshots">;
    createdAt: number;
    sizeBytes: number | null;
    sha256: string | null;
    downloadUrl: string | null;
    status: "expired" | "failed" | "ready" | "uploading";
    conversationId: string;
}[]>>;
export declare const listSnapshotsForUserAgent: import("convex/server").RegisteredQuery<"public", {
    nowMs?: number | undefined;
    limit?: number | undefined;
    agentKey: string;
    consumerUserId: string;
}, Promise<{
    snapshotId: Id<"dataSnapshots">;
    createdAt: number;
    sizeBytes: number | null;
    sha256: string | null;
    downloadUrl: string | null;
    status: "expired" | "failed" | "ready" | "uploading";
    conversationId: string;
}[]>>;
export declare const getLatestSnapshotForUserAgent: import("convex/server").RegisteredQuery<"public", {
    nowMs?: number | undefined;
    agentKey: string;
    consumerUserId: string;
}, Promise<{
    snapshotId: Id<"dataSnapshots">;
    createdAt: number;
    sizeBytes: number | null;
    sha256: string | null;
    downloadUrl: string | null;
    status: "expired" | "failed" | "ready" | "uploading";
    conversationId: string;
}>>;
export declare const getReadyConversationCountForScheduler: import("convex/server").RegisteredQuery<"internal", {
    nowMs?: number | undefined;
    limit?: number | undefined;
}, Promise<number>>;
export declare const getActiveConversationCountForScheduler: import("convex/server").RegisteredQuery<"internal", {
    nowMs?: number | undefined;
    limit?: number | undefined;
}, Promise<number>>;
export declare const getActiveConversationIdsForScheduler: import("convex/server").RegisteredQuery<"internal", {
    nowMs?: number | undefined;
    limit?: number | undefined;
}, Promise<string[]>>;
export declare const listJobsByStatus: import("convex/server").RegisteredQuery<"public", {
    limit?: number | undefined;
    status: "failed" | "done" | "queued" | "processing" | "dead_letter";
}, Promise<{
    _id: import("convex/values").GenericId<"messageQueue">;
    _creationTime: number;
    conversationId: string;
    agentKey: string;
    status: "failed" | "done" | "queued" | "processing" | "dead_letter";
    priority: number;
    scheduledFor: number;
    attempts: number;
    maxAttempts: number;
    lastError: string | undefined;
}[]>>;
export declare const upsertWorkerState: import("convex/server").RegisteredMutation<"internal", {
    nowMs?: number | undefined;
    appName?: string | undefined;
    volumeId?: string | undefined;
    region?: string | undefined;
    machineId?: string | undefined;
    scheduledShutdownAt?: number | undefined;
    stoppedAt?: number | undefined;
    assignment?: {
        agentKey: string;
        conversationId: string;
        leaseId: string;
        assignedAt: number;
    } | null | undefined;
    clearLastSnapshotId?: boolean | undefined;
    clearMachineRef?: boolean | undefined;
    clearVolumeId?: boolean | undefined;
    status: "active" | "draining" | "stopping" | "stopped";
    workerId: string;
    provider: string;
    load: number;
}, Promise<null>>;
export declare const getWorkerControlState: import("convex/server").RegisteredQuery<"public", {
    workerId: string;
}, Promise<{
    shouldStop: boolean;
}>>;
export declare const prepareDataSnapshotUpload: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    agentKey: string;
    conversationId: string;
    workspaceId: string;
    workerId: string;
    reason: "manual" | "drain" | "signal";
}, Promise<{
    snapshotId: import("convex/values").GenericId<"dataSnapshots">;
    uploadUrl: string;
    expiresAt: number;
}>>;
export declare const finalizeDataSnapshotUpload: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    workerId: string;
    storageId: import("convex/values").GenericId<"_storage">;
    snapshotId: import("convex/values").GenericId<"dataSnapshots">;
    sha256: string;
    sizeBytes: number;
}, Promise<boolean>>;
export declare const failDataSnapshotUpload: import("convex/server").RegisteredMutation<"public", {
    nowMs?: number | undefined;
    error: string;
    workerId: string;
    snapshotId: import("convex/values").GenericId<"dataSnapshots">;
}, Promise<boolean>>;
export declare const getLatestDataSnapshotForRestore: import("convex/server").RegisteredQuery<"public", {
    nowMs?: number | undefined;
    agentKey: string;
    conversationId: string;
    workspaceId: string;
}, Promise<{
    snapshotId: import("convex/values").GenericId<"dataSnapshots">;
    downloadUrl: string;
    sha256: string | null;
    sizeBytes: number | null;
    createdAt: number;
} | null>>;
export declare const listWorkersForScheduler: import("convex/server").RegisteredQuery<"internal", {}, Promise<{
    workerId: string;
    status: "active" | "draining" | "stopping" | "stopped";
    load: number;
    heartbeatAt: number;
    lastClaimAt: number | null;
    scheduledShutdownAt: number | null;
    stoppedAt: number | null;
    lastSnapshotId: import("convex/values").GenericId<"dataSnapshots"> | null;
    assignment: {
        agentKey: string;
        conversationId: string;
        leaseId: string;
        assignedAt: number;
    } | null;
    machineId: string | null;
    appName: string | null;
    region: string | null;
    volumeId: string | null;
}[]>>;
export declare const expireOldDataSnapshots: import("convex/server").RegisteredMutation<"internal", {
    nowMs?: number | undefined;
    limit?: number | undefined;
}, Promise<number>>;
export declare const expireOldTelegramAttachments: import("convex/server").RegisteredMutation<"internal", {
    nowMs?: number | undefined;
    limit?: number | undefined;
}, Promise<number>>;
export declare const getWorkerStats: import("convex/server").RegisteredQuery<"public", {}, Promise<{
    activeCount: number;
    idleCount: number;
    workers: {
        workerId: string;
        status: "active" | "draining" | "stopping" | "stopped";
        load: number;
        heartbeatAt: number;
        machineId: string | null;
        appName: string | null;
    }[];
}>>;
export {};
//# sourceMappingURL=queue.d.ts.map