/**
 * Activity schema lookup and handler instantiation.
 *
 * Every stream message targets an activity node in the compiled DAG.
 * This module resolves the activity's schema (from the store) and
 * creates the correct handler subclass (Trigger, Worker, Hook, …).
 */
import { StoreService } from '../store';
import { ILogger } from '../logger';
import { AppVID } from '../../types/app';
import { ActivityType } from '../../types/activity';
import { JobState, JobData } from '../../types/job';
import { ProviderClient, ProviderTransaction } from '../../types/provider';
interface SchemaContext {
    appId: string;
    store: StoreService<ProviderClient, ProviderTransaction>;
    logger: ILogger;
    getVID(vid?: AppVID): Promise<AppVID>;
}
export declare function initActivity(instance: SchemaContext, topic: string, data?: JobData, context?: JobState): Promise<any>;
export declare function getSchema(instance: SchemaContext, topic: string): Promise<[activityId: string, schema: ActivityType]>;
export declare function isPrivate(topic: string): boolean;
export {};