/** * Azure Data Factory Service * Provides authentication and API operations for ADF. */ import type { AdfConfig, AdfFactoryConfig, Pipeline, PipelineRun, CreateRunResponse, QueryPipelineRunsRequest, QueryPipelineRunsResponse, ActivityRun, QueryActivityRunsRequest, QueryActivityRunsResponse, Dataset, LinkedService, DataFlow, Trigger, QueryTriggerRunsRequest, QueryTriggerRunsResponse, IntegrationRuntime, IntegrationRuntimeStatus } from './types.js'; export declare class AdfService { private config; private msalClient; private accessToken; private tokenExpirationTime; constructor(config: AdfConfig); /** * Get an access token for Azure Management API */ private getAccessToken; /** * Get authorization headers */ private getAuthHeaders; /** * Get all configured factories */ getAllFactories(): AdfFactoryConfig[]; /** * Get active factories */ getActiveFactories(): AdfFactoryConfig[]; /** * Get factory by ID */ getFactoryById(factoryId: string): AdfFactoryConfig; /** * Get the default factory (first active factory) */ getDefaultFactory(): AdfFactoryConfig; /** * Get factory by ID or default */ resolveFactory(factoryId?: string): AdfFactoryConfig; /** * Get base URL for a factory */ private getBaseUrl; /** * Check if write operations are enabled */ isWriteEnabled(): boolean; /** * Check if trigger control is enabled */ isTriggerControlEnabled(): boolean; private get; private post; private handleError; /** * List all pipelines in a factory */ listPipelines(factoryId?: string): Promise; /** * Get a pipeline by name */ getPipeline(pipelineName: string, factoryId?: string): Promise; /** * Run a pipeline with optional parameters */ runPipeline(pipelineName: string, parameters?: Record, factoryId?: string, options?: { referencePipelineRunId?: string; isRecovery?: boolean; startFromFailure?: boolean; startActivityName?: string; }): Promise; /** * Get a pipeline run by ID */ getPipelineRun(runId: string, factoryId?: string): Promise; /** * Cancel a pipeline run */ cancelPipelineRun(runId: string, factoryId?: string): Promise; /** * Query pipeline runs with filters */ queryPipelineRuns(request: QueryPipelineRunsRequest, factoryId?: string): Promise; /** * Query activity runs for a pipeline run */ queryActivityRuns(runId: string, request: QueryActivityRunsRequest, factoryId?: string): Promise; /** * Get activity runs for a pipeline run (simplified) */ getActivityRuns(runId: string, factoryId?: string, filters?: { status?: string; activityName?: string; }): Promise; /** * List all datasets in a factory */ listDatasets(factoryId?: string): Promise; /** * Get a dataset by name */ getDataset(datasetName: string, factoryId?: string): Promise; /** * List all linked services in a factory (credentials sanitized) */ listLinkedServices(factoryId?: string): Promise; /** * Sanitize linked service to remove sensitive data */ private sanitizeLinkedService; /** * List all data flows in a factory */ listDataFlows(factoryId?: string): Promise; /** * Get a data flow by name */ getDataFlow(dataFlowName: string, factoryId?: string): Promise; /** * List all triggers in a factory */ listTriggers(factoryId?: string): Promise; /** * Get a trigger by name */ getTrigger(triggerName: string, factoryId?: string): Promise; /** * Start a trigger */ startTrigger(triggerName: string, factoryId?: string): Promise; /** * Stop a trigger */ stopTrigger(triggerName: string, factoryId?: string): Promise; /** * Query trigger runs */ queryTriggerRuns(request: QueryTriggerRunsRequest, factoryId?: string): Promise; /** * List all integration runtimes in a factory */ listIntegrationRuntimes(factoryId?: string): Promise; /** * Get integration runtime status */ getIntegrationRuntimeStatus(irName: string, factoryId?: string): Promise; /** * Start an integration runtime (managed IR only) */ startIntegrationRuntime(irName: string, factoryId?: string): Promise; /** * Stop an integration runtime (managed IR only) */ stopIntegrationRuntime(irName: string, factoryId?: string): Promise; } //# sourceMappingURL=AdfService.d.ts.map