chunk

Documentation

Overview

package chunk implements streaming block splitters

Index

• Variables
• type BlockSplitter
• type MaybeRabin
  • func NewMaybeRabin(avgBlkSize int) *MaybeRabin
  • func (mr *MaybeRabin) Split(r io.Reader) chan []byte
• type SizeSplitter
  • func (ss *SizeSplitter) Split(r io.Reader) chan []byte

Variables

var DefaultBlockSize = 1024 * 256

var DefaultSplitter = &SizeSplitter{Size: DefaultBlockSize}

Types

type BlockSplitter

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

type MaybeRabin

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

func NewMaybeRabin

func NewMaybeRabin(avgBlkSize int) *MaybeRabin

func (*MaybeRabin) Split

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

type SizeSplitter

type SizeSplitter struct {
	Size int
}

func (*SizeSplitter) Split

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