KPipe API — fluent top-level KPipe entry point for the common consumer path