import type { EnricherEngine, Manifest } from 'flair-sdk'; import type { Client } from './utils/get-client.js'; export type CliContext = { client: Client; cluster: Manifest['cluster']; }; export type OrchestrationJob = { id?: string; orchestrationState?: string; orchestrationError?: string; executionMode?: 'ON_DEMAND' | 'PROVISIONED'; scanDirection?: string; actualStartBlock?: number; actualEndBlock?: number; createdAt?: number; startedAt?: number; updatedAt?: number; logLevel?: string; blocksAttempts?: number; blocksScans?: number; blocksIngests?: number; blocksFailures?: number; transactionsScans?: number; transactionsIngests?: number; transactionsFailures?: number; logsScans?: number; logsIngests?: number; logsQueued?: number; logsFailures?: number; processorTransactionsVisits?: number; processorLogsTopicSkips?: number; processorLogsAddressSkips?: number; processorLogsIngestions?: number; processorHandlerSkips?: number; processorHandlerFailures?: number; processorHandlerRetries?: number; processorHandlerSuccesses?: number; userCodeMs?: number; handlingMs?: number; backfillBatchesReceived?: number; backfillBatchesProcessed?: number; backfillBatchesFailed?: number; evmBlocksReceived?: number; evmBlocksIngested?: number; evmEventsReceived?: number; evmEventsFiltered?: number; evmEventsIngested?: number; evmEventsIngestingFailed?: number; evmEventsIngestingMs?: number; evmEventsProcessorQueueWaitMs?: number; evmEventsProcessorPicked?: number; evmEventsProcessorIgnored?: number; evmEventsProcessorSkipped?: number; evmEventsProcessorHandlingMs?: number; evmEventsProcessorSucceded?: number; evmEventsProcessorFailed?: number; evmEventsProcessorUserCodeMs?: number; evmTransactionsReceived?: number; evmTransactionsIngested?: number; evmTransactionsIngestingFailed?: number; evmTransactionsIngestingMs?: number; evmTransactionsProcessorQueueWaitMs?: number; evmTransactionsProcessorPicked?: number; evmTransactionsProcessorSkipped?: number; evmTransactionsProcessorHandlingMs?: number; evmTransactionsProcessorSucceded?: number; evmTransactionsProcessorFailed?: number; evmTransactionsProcessorUserCodeMs?: number; enricherQueryDurationMs?: number; enricherQueryRows?: number; enricherQueryPages?: number; enricherVisits?: number; enricherAttempts?: number; enricherFailures?: number; enricherSuccesses?: number; webUrl?: string; request?: { engine?: EnricherEngine; cluster?: string; chainId?: number; chainIds?: number[]; maxBlocks?: number; minBlockTimestamp?: number; maxBlockTimestamp?: number; contractAddresses?: string[]; matchLogHashes?: string[]; executionMode?: string; }; }; export type QueueState = 'STABLE' | 'DEAD' | 'IDLE' | 'REBALANCING'; export declare enum QueueAlias { INGESTIONS = "ingestions", INGESTIONS_DLQ = "ingestions-dlq", BACKFILL_BATCHES = "backfill-batches", BACKFILL_BATCHES_DLQ = "backfill-batches-dlq", BACKFILL_INGESTIONS = "backfill-ingestions", BACKFILL_INGESTIONS_DLQ = "backfill-ingestions-dlq", ENRICHMENTS = "enrichments", ENRICHMENTS_DLQ = "enrichments-dlq", OPERATIONS = "operations", OPERATIONS_DLQ = "operations-dlq" } export type QueueMetadata = { id: string; name: string; description: string; alias: QueueAlias; consumerGroup: string | null; totalMessages?: number; messagesBehind?: number; state?: QueueState; members?: number; };