import { EventHubStore } from '@pikku/core/channel';
import type { Kysely } from 'kysely';
import type { KyselyPikkuDB } from './kysely-tables.js';
export declare class KyselyEventHubStore extends EventHubStore {
    private db;
    private initialized;
    constructor(db: Kysely<KyselyPikkuDB>);
    init(): Promise<void>;
    getChannelIdsForTopic(topic: string): Promise<string[]>;
    subscribe(topic: string, channelId: string): Promise<boolean>;
    unsubscribe(topic: string, channelId: string): Promise<boolean>;
    close(): Promise<void>;
}