chunk

package

v0.4.0-rc1 Latest Latest Go to latest Published: Jan 28, 2016 License: MIT Imports: 8 Imported by: 0

Details

package chunk implements streaming block splitters

This section is empty.

View Source

var DefaultBlockSize int64 = 1024 * 256

View Source

var IpfsRabinPoly = chunker.Pol(17437180132763653)

func Chan(s Splitter) (<-chan []byte, <-chan error)

type Rabin struct {
	// contains filtered or unexported fields
}

func NewRabin(r io.Reader, avgBlkSize uint64) *Rabin

func NewRabinMinMax(r io.Reader, min, avg, max uint64) *Rabin

func (r *Rabin) NextBytes() ([]byte, error)

type Splitter interface {
	NextBytes() ([]byte, error)
}

func DefaultSplitter(r io.Reader) Splitter

func FromString(r io.Reader, chunker string) (Splitter, error)

func NewSizeSplitter(r io.Reader, size int64) Splitter

type SplitterGen func(r io.Reader) Splitter

func SizeSplitterGen(size int64) SplitterGen