splitmerge

Documentation

Index

• func MergeWriter(sink io.WriteCloser, parts int, blockSize int) []io.WriteCloser
• func NewChannelReader(in <-chan []byte) io.ReadCloser
• func SplitReader(reader io.Reader, parts int, blockSize int) []io.Reader

Functions

func MergeWriter

func MergeWriter(sink io.WriteCloser, parts int, blockSize int) []io.WriteCloser

MergeWriter returns list of WriteCloser-s Then it reads data from each of n=`parts` WriteClosers in blocks of `blockSize` and writes data to `sink` writer. MergeWriter gets ownership over sink and will close it.

func NewChannelReader

func NewChannelReader(in <-chan []byte) io.ReadCloser

func SplitReader

func SplitReader(reader io.Reader, parts int, blockSize int) []io.Reader