importer

Documentation

Index

• Variables
• func NewDagFromFile(fpath string) (*dag.Node, error)
• func NewDagFromReader(r io.Reader) (*dag.Node, error)
• func NewDagFromReaderWithSplitter(r io.Reader, spl BlockSplitter) (*dag.Node, error)
• 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 BlockSizeLimit = int64(1048576) // 1 MB

BlockSizeLimit specifies the maximum size an imported block can have.

var ErrSizeLimitExceeded = fmt.Errorf("object size limit exceeded")

ErrSizeLimitExceeded signals that a block is larger than BlockSizeLimit.

Functions

func NewDagFromFile

func NewDagFromFile(fpath string) (*dag.Node, error)

NewDagFromFile constructs a Merkle DAG from the file at given path.

func NewDagFromReader

func NewDagFromReader(r io.Reader) (*dag.Node, error)

NewDagFromReader constructs a Merkle DAG from the given io.Reader. size required for block construction.

func NewDagFromReaderWithSplitter

func NewDagFromReaderWithSplitter(r io.Reader, spl BlockSplitter) (*dag.Node, error)

Types

type BlockSplitter

type BlockSplitter interface {
	Split(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