import pino from 'pino'; import { ApiConfig, ExecutionError, ExecutionEvent, ExecutionOutput, JsonValue, Mock, Result } from '../types'; import { ExecutorServiceClient } from '../types-js/api/v1/service_grpc_pb'; /** * Each execute service will create one and only one connection */ export declare class ExecutorService { private client; private url; private apiKey; private insecure; private authority?; private connectionTimeoutMs?; private connectionPromise; private logger; private status; constructor({ url, apiKey, insecure, authority, connectionTimeoutMs, logger }: { url: string; apiKey: string; insecure: boolean; authority?: string; connectionTimeoutMs: number; logger?: pino.Logger; }); reset(): void; close(): void; execute({ apiId, inputs, mocks, apiConfig, retries }: { apiId: string; inputs: object; mocks: Mock[]; apiConfig: ApiConfig; retries: number; }): Promise; private executeOnce; private shouldRetry; private shouldReset; private newStream; private connect; } export declare class ExecutorStream { private apiKey; private stream; private pending; private funcs; private executionEvents; private streamError; constructor({ client, apiKey, requestTimeoutMs }: { client: ExecutorServiceClient; apiKey: string; requestTimeoutMs?: number; }); execute({ apiId, inputs, mocks, apiConfig }: { apiId: string; inputs: object; mocks: Mock[]; apiConfig: ApiConfig; }): Promise; private registerFunc; private request; private send; private handleExecuteFunctions; } export declare class IExecutionResult implements Result { private events; private output; private errors; constructor({ events }: { events: ExecutionEvent[]; }); getEvents(): ExecutionEvent[]; getOutput(): ExecutionOutput; getErrors(): ExecutionError[]; getResult(): JsonValue; getBlockResult(blockName: string): JsonValue; } //# sourceMappingURL=executor.d.ts.map