export type MessageHandler<T = unknown> = (message: T) => void | Promise<void>;
export type EventHandler<TArgs extends unknown[] = unknown[]> = (...args: TArgs) => void | Promise<void>;
export type ProcessMethod<TArgs extends unknown[] = unknown[], TReturn = unknown> = (...args: TArgs) => TReturn;
export type AsyncProcessMethod<TArgs extends unknown[] = unknown[], TReturn = unknown> = (...args: TArgs) => Promise<TReturn>;
export type StreamingMethod<TYield = unknown, TReturn = unknown, TNext = unknown> = (...args: unknown[]) => AsyncGenerator<TYield, TReturn, TNext>;
export type WorkerMessageType = 'ready' | 'error' | 'pong' | 'shutdown' | 'ping' | 'call' | 'result' | 'stream-chunk' | 'stream-end';
export interface WorkerMessageBase {
    type: WorkerMessageType | string;
    id?: string;
}
export interface WorkerCallMessage extends WorkerMessageBase {
    type: 'call';
    method: string;
    args: unknown[];
}
export interface WorkerResultMessage extends WorkerMessageBase {
    type: 'result';
    result: unknown;
}
export interface WorkerErrorMessage extends WorkerMessageBase {
    type: 'error';
    error: {
        message: string;
        stack?: string;
        code?: string;
    };
}
export interface WorkerStreamChunkMessage extends WorkerMessageBase {
    type: 'stream-chunk';
    chunk: unknown;
}
export interface WorkerReadyMessage extends WorkerMessageBase {
    type: 'ready';
    processId: string;
    transportUrl?: string;
    serviceName?: string;
    serviceVersion?: string;
}
export type WorkerMessage = WorkerCallMessage | WorkerResultMessage | WorkerErrorMessage | WorkerStreamChunkMessage | WorkerReadyMessage | WorkerMessageBase;
export interface MethodDescriptor<TArgs extends unknown[] = unknown[], TReturn = unknown> {
    name: string;
    handler: ProcessMethod<TArgs, TReturn>;
    isAsync?: boolean;
    isStreaming?: boolean;
}
export type ServiceMethodMap = Map<string, ProcessMethod>;
export interface ProcessContext<TMeta extends Record<string, unknown> = Record<string, unknown>> {
    processId: string;
    serviceName: string;
    metadata?: TMeta;
}
export type WorkflowHandler<TInput = unknown, TOutput = unknown> = (input: TInput) => Promise<TOutput>;
export declare function isAsyncGenerator(value: unknown): value is AsyncGenerator<unknown, unknown, unknown>;
export declare function isPromise<T = unknown>(value: unknown): value is Promise<T>;
export declare function isWorkerCallMessage(message: WorkerMessage): message is WorkerCallMessage;
export declare function isWorkerResultMessage(message: WorkerMessage): message is WorkerResultMessage;
export declare function isWorkerErrorMessage(message: WorkerMessage): message is WorkerErrorMessage;
export declare function isWorkerReadyMessage(message: WorkerMessage): message is WorkerReadyMessage;
//# sourceMappingURL=common-types.d.ts.map