import type { Either } from '@lokalise/node-core';
import { type AsyncPublisher, type BarrierResult, type MessageInvalidFormatError, type MessageValidationError, type QueuePublisherOptions, type ResolvedMessage } from '@message-queue-toolkit/core';
import type { PubSubMessage } from '../types/MessageTypes.ts';
import type { PubSubCreationConfig, PubSubDependencies, PubSubQueueLocatorType } from './AbstractPubSubService.ts';
import { AbstractPubSubService } from './AbstractPubSubService.ts';
export type PubSubMessageOptions = {
    orderingKey?: string;
    attributes?: Record<string, string>;
};
export declare abstract class AbstractPubSubPublisher<MessagePayloadType extends object> extends AbstractPubSubService<MessagePayloadType> implements AsyncPublisher<MessagePayloadType, PubSubMessageOptions> {
    private readonly messageSchemaContainer;
    private readonly isDeduplicationEnabled;
    private initPromise?;
    constructor(dependencies: PubSubDependencies, options: QueuePublisherOptions<PubSubCreationConfig, PubSubQueueLocatorType, MessagePayloadType>);
    publish(message: MessagePayloadType, options?: PubSubMessageOptions): Promise<void>;
    private sendMessage;
    protected resolveNextFunction(): () => void;
    protected resolveMessage(_message: PubSubMessage): Either<MessageInvalidFormatError | MessageValidationError, ResolvedMessage>;
    protected processPrehandlers(): Promise<unknown>;
    protected preHandlerBarrier<BarrierOutput>(): Promise<BarrierResult<BarrierOutput>>;
    processMessage(): Promise<Either<'retryLater', 'success'>>;
    protected isDeduplicationEnabledForMessage(message: MessagePayloadType): boolean;
    protected resolveSchema(message: MessagePayloadType): Either<Error, import("zod/v4").ZodSchema<MessagePayloadType>>;
}