import type { PushPayload } from '@n8n/api-types';
import { Logger } from '@n8n/backend-common';
import { ProjectRelationRepository } from '@n8n/db';
import { InstanceSettings } from 'n8n-core';
import { Push } from '../../push';
import type { PubSubCommandMap } from '../../scaling/pubsub/pubsub.event-map';
import { Publisher } from '../../scaling/pubsub/publisher.service';
import { AgentExecutionThreadRepository } from './repositories/agent-execution-thread.repository';
type AgentExecutionUpdate = PushPayload<'agentExecutionUpdated'>;
export declare class AgentExecutionUpdateBroadcaster {
    private readonly logger;
    private readonly projectRelationRepository;
    private readonly push;
    private readonly publisher;
    private readonly instanceSettings;
    private readonly threadRepository;
    constructor(logger: Logger, projectRelationRepository: ProjectRelationRepository, push: Push, publisher: Publisher, instanceSettings: InstanceSettings, threadRepository: AgentExecutionThreadRepository);
    notify(data: AgentExecutionUpdate): void;
    private broadcast;
    notifyBackgroundJobsUpdated(agentId: string, threadId: string): void;
    private broadcastBackgroundJobsUpdated;
    handleBackgroundJobsRelay({ data, userIds, }: PubSubCommandMap['relay-agent-background-tasks-update']): void;
    handleRelay({ data, userIds }: PubSubCommandMap['relay-agent-execution-update']): void;
}
export {};