/**
 * E2E Test Runner - EventHub Adapter
 *
 * Azure Event Hub operations
 */
import type { AdapterConfig, AdapterContext, AdapterStepResult, Logger } from '../types';
import { BaseAdapter } from './base.adapter';
export interface EventHubAssertion {
    path: string;
    equals?: unknown;
    contains?: string;
    matches?: string;
    exists?: boolean;
}
export declare class EventHubAdapter extends BaseAdapter {
    private producerClient;
    private consumerClient;
    private receivedEvents;
    constructor(config: AdapterConfig, logger: Logger);
    get name(): string;
    connect(): Promise<void>;
    disconnect(): Promise<void>;
    execute(action: string, params: Record<string, unknown>, ctx: AdapterContext): Promise<AdapterStepResult>;
    healthCheck(): Promise<boolean>;
    /**
     * Publish message(s) to EventHub
     */
    private publish;
    /**
     * Wait for a message matching filter
     */
    private waitFor;
    /**
     * Consume messages from EventHub
     */
    private consume;
    /**
     * Check if event matches filter
     */
    private matchesFilter;
    /**
     * Get nested value using dot notation
     */
    private getNestedValue;
    /**
     * Run assertions on event data
     */
    private runAssertions;
}
//# sourceMappingURL=eventhub.adapter.d.ts.map