go-streams NewPipelineStats() 示范

以下是使用 `stats.NewPipelineStats()` 函数创建 `stats.PipelineStatistics` 结构体的示例代码：

pipelineStats := stats.NewPipelineStats()

source := NewSourceComponent(pipelineStats)
processor := NewProcessorComponent(pipelineStats)
sink := NewSinkComponent(pipelineStats)

go source.Run()
go processor.Run()
go sink.Run()

for {
    select {
    case <-time.After(time.Second):
        pipelineStats.PrintStats()
    }
}

该代码创建了一个 Pipeline，并使用 `stats.NewPipelineStats()` 函数创建了一个 `stats.PipelineStatistics` 结构体。然后，通过将 `pipelineStats` 参数传递给每个组件的构造函数，用于在组件内部收集性能统计信息。最后，通过 `PrintStats()` 方法输出性能统计信息。

需要注意的是，在输出性能统计信息之前，需要先确保各个组件已经开始运行。在上述代码中，我们通过 `go source.Run()`、`go processor.Run()` 和 `go sink.Run()` 分别启动了每个组件的运行。同时，我们通过 `time.After()` 定时器定期输出性能统计信息，以便及时了解 Pipeline 的性能情况。