chunk

package

v0.2.2-buildfails Latest Latest Go to latest Published: Feb 27, 2015 License: MIT Imports: 6 Imported by: 0

Details

package chunk implements streaming block splitters

This section is empty.

View Source

var DefaultBlockSize = 1024 * 256

View Source

var DefaultSplitter = &SizeSplitter{Size: DefaultBlockSize}

This section is empty.

type BlockSplitter interface {
	Split(r io.Reader) chan []byte
}

type MaybeRabin struct {
	MinBlockSize int
	MaxBlockSize int
	// contains filtered or unexported fields
}

func NewMaybeRabin(avgBlkSize int) *MaybeRabin

func (mr *MaybeRabin) Split(r io.Reader) chan []byte

type SizeSplitter struct {
	Size int
}

func (ss *SizeSplitter) Split(r io.Reader) chan []byte