stream

type Engine struct {
	// contains filtered or unexported fields
}

type Options struct {
	// Source yields records and is required.
	Source source.Source
	// Cascade classifies records and is required.
	Cascade *classmesh.Cascade
	// Sink receives classified records and is required.
	Sink sink.Sink
	// Review receives unclassified records with a zero Classification.
	// A nil Review drops those records.
	Review sink.Sink
	// Logger defaults to slog.Default.
	Logger *slog.Logger
	// Workers controls concurrent classification. Zero or one uses the serial loop.
	// Larger values require concurrent-safe stages and preserve serial outcomes.
	Workers int
}

type Stats struct {
	// Processed counts records read from the source.
	Processed int
	// Classified counts records some stage decided.
	Classified int
	// Reviewed counts records no stage decided.
	Reviewed int
	// ByStage counts classifications per stage name.
	ByStage map[string]int
}