import { BlueNode } from '@blue-labs/language'; import { CompositeTimelineChannel } from '../../model/index.js'; import { ChannelEvaluationContext, ChannelMatch, ChannelProcessor } from '../types.js'; /** * Compose a checkpoint key that namespaces a child channel under its composite. */ export declare function compositeCheckpointKey(compositeKey: string, childKey: string): string; export declare class CompositeTimelineChannelProcessor implements ChannelProcessor { readonly kind: "channel"; readonly blueIds: readonly ["HsNatiPt2YvmkWQoqtfrFCbdp75ZUBLBUkWeq84WTfnr"]; readonly schema: import('zod').ZodObject; name: import('zod').ZodOptional; order: import('zod').ZodOptional; }, { description: import('zod').ZodOptional; event: import('zod').ZodOptional>; name: import('zod').ZodOptional; }>, { channels: import('zod').ZodOptional>; description: import('zod').ZodOptional; name: import('zod').ZodOptional; }>, import("zod").objectUtil.extendShape; name: import('zod').ZodOptional; order: import('zod').ZodOptional; }, { description: import('zod').ZodOptional; event: import('zod').ZodOptional>; name: import('zod').ZodOptional; }>, { description: import('zod').ZodOptional; name: import('zod').ZodOptional; order: import('zod').ZodOptional; }>, { path: import('zod').ZodOptional; definition: import('zod').ZodOptional>; }>>, "strip", import('zod').ZodTypeAny, { event?: BlueNode | undefined; name?: string | undefined; path?: string | undefined; description?: string | undefined; order?: number | undefined; definition?: BlueNode | undefined; channels?: string[] | undefined; }, { event?: BlueNode | undefined; name?: string | undefined; path?: string | undefined; description?: string | undefined; order?: number | undefined; definition?: BlueNode | undefined; channels?: string[] | undefined; }>; /** * Fallback match hook that delegates to {@link evaluate} for consistent behavior. */ matches(contract: CompositeTimelineChannel, context: ChannelEvaluationContext): boolean | Promise; /** * Resolve child channels and return a delivery per matching child, enriching * each delivered event with the source channel key. */ evaluate(contract: CompositeTimelineChannel, context: ChannelEvaluationContext): Promise; /** * Determine recency by checking whether any child delivery should process. */ isNewerEvent(contract: CompositeTimelineChannel, context: ChannelEvaluationContext, lastEvent: BlueNode): Promise; /** * Attach the source child channel key to event metadata for handler logic. */ private enrichEvent; /** * Apply child-level recency rules using the composite-scoped checkpoint entry. */ private shouldProcessChild; /** * Resolve the checkpoint marker for the current scope, if present. */ private resolveCheckpoint; } //# sourceMappingURL=composite-timeline-channel-processor.d.ts.map