carbites

Nov 2, 2021

Changes in this version

+ type BlockReader interface

+ Get func(cid.Cid) (blocks.Block, error)

+ type SimpleSplitter struct

+ func NewSimpleSplitter(in io.Reader, targetSize int) (*SimpleSplitter, error)

+ func (spltr *SimpleSplitter) Next() (io.Reader, error)

+ type Splitter interface

+ Next func() (io.Reader, error)

+ type TreewalkSplitter struct

+ func NewTreewalkSplitter(r io.Reader, targetSize int) (*TreewalkSplitter, error)

+ func NewTreewalkSplitterFromBlockReader(root cid.Cid, br BlockReader, targetSize int) (*TreewalkSplitter, error)

+ func NewTreewalkSplitterFromPath(path string, targetSize int) (*TreewalkSplitter, error)

+ func (spltr *TreewalkSplitter) Next() (io.Reader, error)

Jul 4, 2021

Changes in this version

+ func JoinTreewalk(in []io.Reader) (io.Reader, error)

+ func NewCarMerger(in []io.Reader) (io.Reader, error)

Jul 4, 2021

Changes in this version

+ func SplitTreewalkFromBlockReader(ctx context.Context, root cid.Cid, br CarBlockReader, targetSize int, ...) error

+ func SplitTreewalkFromPath(ctx context.Context, path string, targetSize int, out chan io.Reader) error

type Strategy

+ const Treewalk

Jul 4, 2021

Changes in this version

+ func Join(ctx context.Context, in []io.Reader, s Strategy) (io.Reader, error)

+ func JoinSimple(in []io.Reader) (io.Reader, error)

Jul 3, 2021

Changes in this version

+ func SplitSimple(ctx context.Context, in io.Reader, targetSize int, out chan io.Reader) error

+ func SplitTreewalk(ctx context.Context, r io.Reader, targetSize int, out chan io.Reader) error

+ func SplitTreewalkWithBlockReader(ctx context.Context, root cid.Cid, br CarBlockReader, targetSize int, ...) error

+ type CarBlockReader interface

+ Get func(cid.Cid) (blocks.Block, error)

Jul 3, 2021

Changes in this version

+ func Split(ctx context.Context, r *car.CarReader, targetSize int, s Strategy, ...) error

+ type Strategy int

+ const Simple

+ const TreeWalk