import { IBlockProcessor, IProcessedBlockRepository, IShipConsumer } from '../types/interfaces';
import { IBlockRequest, ShipBlockResponse } from '../types/ship';
export interface IConsumerSettings {
    delta_types: string[];
    end_block: number;
    fetch_deltas: boolean;
    fetch_traces: boolean;
    irreversible_only: boolean;
    max_messages_in_flight: number;
    min_block_confirmations: number;
}
interface IShipConsumerParams {
    consumerOptions?: Partial<IConsumerSettings>;
    repository: IProcessedBlockRepository;
    processor: IBlockProcessor;
    blockDelay: number;
}
export declare class ShipConsumer implements IShipConsumer {
    private readonly consumerOptions;
    private readonly repository;
    private readonly processor;
    private readonly blockDelay;
    private delayedBlocks;
    constructor(params: IShipConsumerParams);
    getRequestBlockConfig(): Promise<IBlockRequest>;
    getRequiredDeltas(): string[];
    consume(resp: ShipBlockResponse): Promise<void>;
    processBlock(resp: ShipBlockResponse): Promise<void>;
    private processDeltas;
    private processTraces;
}
export {};