import * as Component from '../Component';
import * as EventBus from '../EventBus';
import { eventHandler } from '../EventBus';
import { EventHandling } from '../EventBus';
import { Event } from '../Event';
import * as MySQL from 'cqes-mysql';
import * as redis from 'redis';
export interface props extends Component.props {
    originContext?: string;
    host?: string;
    user?: string;
    password?: string;
    database?: string;
    MySQL?: {
        url: string;
    } & MySQL.props;
    Redis?: redis.ClientOpts;
}
export declare class Subscription implements EventBus.Subscription {
    abort: (err?: any) => Promise<void>;
    protected handler: eventHandler;
    protected queue: Array<Event>;
    protected draining: boolean;
    constructor(handler: eventHandler, abort: (err?: any) => Promise<void>);
    append(events: Array<Event>): void;
    drain(): void;
}
declare type Filter = {
    [name: string]: string;
};
declare type Begin = {
    [name: string]: number;
};
export declare class Transport extends Component.Component implements EventBus.Transport {
    protected mysql: MySQL.MySQL;
    protected redis: redis.RedisClient;
    protected originContext: string;
    constructor(props: props);
    start(): Promise<void>;
    save(events: Array<Event>): Promise<void>;
    readFrom(filter: Filter, begin: Begin, handler: eventHandler): Promise<void>;
    readAllFrom(position: number, handler: eventHandler): Promise<void>;
    readCategoryFrom(category: string, position: number, handler: eventHandler): Promise<void>;
    readStreamFrom(category: string, streamId: string, number: number, handler: eventHandler): Promise<void>;
    readStreamLast(category: string, id: string, count: number): Promise<Array<Event>>;
    subscribe(category: string, handler: eventHandler): Promise<Subscription>;
    psubscribe(id: string, category: string, handler: eventHandler<EventHandling>): Promise<Subscription>;
    protected getPSubscriptionPosition(subscriptionId: string): Promise<number>;
    protected getLastCategoryPosition(category: string): Promise<any>;
    protected upsertPSubscriptionPosition(subscriptionId: string, position: number): Promise<void>;
    stop(): Promise<void>;
}
export {};