pipleline

Documentation

Index

• func ArraySource(a ...int) <-chan int
• func InMemSort(in <-chan int) <-chan int
• func Init()
• func Merge(in1, in2 <-chan int) <-chan int
• func MergeN(inputs ...<-chan int) <-chan int
• func NetworkSink(addr string, in <-chan int)
• func NetworkSource(addr string) <-chan int
• func RandomSource(count int) <-chan int
• func ReaderSource(reader io.Reader, chunkSize int) <-chan int
• func WriterSink(writer io.Writer, in <-chan int)

Functions

func ArraySource

func ArraySource(a ...int) <-chan int

func InMemSort

func InMemSort(in <-chan int) <-chan int

in 是节点的一个输入 return 的 channel 是一个输出 return 是相对于使用者的来说 使用的人只能用它去收东西 对于 InMemSort 只能发东西 in <-chan int::只进不出的 channel 返回的是 <-chan int：只出不进的 channel

func Init

func Init()

func Merge

func Merge(in1, in2 <-chan int) <-chan int

func MergeN

func MergeN(inputs ...<-chan int) <-chan int

N 个节点反复两两归并 注意：这里只有两路

func NetworkSink

func NetworkSink(addr string, in <-chan int)

func NetworkSource

func NetworkSource(addr string) <-chan int

func RandomSource

func RandomSource(count int) <-chan int

func ReaderSource

func ReaderSource(reader io.Reader, chunkSize int) <-chan int

func WriterSink

func WriterSink(writer io.Writer, in <-chan int)