import { E as MeshServiceType } from './types-C9VYURdP.js';

type MeshStreamKind = 'log' | 'event' | 'lifecycle' | 'metric';
type MeshLogStreamName = 'stdout' | 'stderr' | 'system';
interface MeshStreamEnvelope<TPayload = unknown> {
    readonly id: string;
    readonly app: string;
    readonly kind: MeshStreamKind;
    readonly type: string;
    readonly payload: TPayload;
    readonly emittedAt: string;
    readonly source?: string;
    readonly instanceId?: string;
    readonly service?: string;
}
interface MeshLogStreamPayload {
    readonly stream: MeshLogStreamName;
    readonly chunk: string;
    readonly sequence: number;
    readonly truncated: boolean;
    readonly serviceType?: MeshServiceType;
}
interface MeshLifecycleStreamPayload {
    readonly status: string;
    readonly message?: string;
    readonly metadata?: Record<string, unknown>;
}
type MeshStreamHandler<TPayload = unknown> = (event: MeshStreamEnvelope<TPayload>) => void | Promise<void>;
interface MeshStreamPublisher {
    publish<TPayload>(event: Omit<MeshStreamEnvelope<TPayload>, 'id' | 'emittedAt' | 'app'> & {
        readonly app?: string;
    }): Promise<MeshStreamEnvelope<TPayload>>;
    publishLog(input: MeshLogPublishInput): Promise<MeshStreamEnvelope<MeshLogStreamPayload> | null>;
}
interface MeshStreamSubscriber {
    subscribe(types: readonly string[], handler: MeshStreamHandler): Promise<() => Promise<void> | void>;
}
interface MeshLogPublishInput {
    readonly instanceId: string;
    readonly service: string;
    readonly serviceType?: MeshServiceType;
    readonly stream: MeshLogStreamName;
    readonly chunk: Buffer | string;
    readonly source?: string;
}
interface MeshStreamSubscribeOptions {
    readonly kinds?: readonly MeshStreamKind[];
    readonly types?: readonly string[];
    readonly services?: readonly string[];
    readonly instances?: readonly string[];
}

export type { MeshLifecycleStreamPayload as M, MeshLogPublishInput as a, MeshLogStreamName as b, MeshLogStreamPayload as c, MeshStreamEnvelope as d, MeshStreamHandler as e, MeshStreamKind as f, MeshStreamPublisher as g, MeshStreamSubscribeOptions as h, MeshStreamSubscriber as i };