Commit 87341562 authored by Hector Sanjuan's avatar Hector Sanjuan

Extract: chunker: rename "chunk" to "chunker" as it is more consistent

License: MIT
Signed-off-by: default avatarHector Sanjuan <hector@protocol.ai>
parent f3c8524d
...@@ -23,7 +23,7 @@ import ( ...@@ -23,7 +23,7 @@ import (
uio "github.com/ipfs/go-ipfs/unixfs/io" uio "github.com/ipfs/go-ipfs/unixfs/io"
u "gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util" u "gx/ipfs/QmNiJuT8Ja3hMVpBHXv3Q6dwmperaQ6JjLtpMQgMCD7xvx/go-ipfs-util"
chunk "gx/ipfs/QmWo8jYc19ppG7YoTsrr2kEtLRbARTJho5oNXFTR6B7Peq/go-ipfs-chunker" chunker "gx/ipfs/QmWo8jYc19ppG7YoTsrr2kEtLRbARTJho5oNXFTR6B7Peq/go-ipfs-chunker"
cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid" cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid"
ipld "gx/ipfs/Qme5bWv7wtjUNGsK2BNGVUFPKiuxWrsqrtvYwCLRw8YFES/go-ipld-format" ipld "gx/ipfs/Qme5bWv7wtjUNGsK2BNGVUFPKiuxWrsqrtvYwCLRw8YFES/go-ipld-format"
blocks "gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format" blocks "gx/ipfs/Qmej7nf81hi2x2tvjRBF3mcp74sQyuDH4VMYDGd1YtXjb2/go-block-format"
...@@ -136,7 +136,7 @@ func runBatchFetchTest(t *testing.T, read io.Reader) { ...@@ -136,7 +136,7 @@ func runBatchFetchTest(t *testing.T, read io.Reader) {
dagservs = append(dagservs, NewDAGService(bsi)) dagservs = append(dagservs, NewDAGService(bsi))
} }
spl := chunk.NewSizeSplitter(read, 512) spl := chunker.NewSizeSplitter(read, 512)
root, err := imp.BuildDagFromReader(dagservs[0], spl) root, err := imp.BuildDagFromReader(dagservs[0], spl)
if err != nil { if err != nil {
...@@ -228,7 +228,7 @@ func TestFetchGraph(t *testing.T) { ...@@ -228,7 +228,7 @@ func TestFetchGraph(t *testing.T) {
} }
read := io.LimitReader(u.NewTimeSeededRand(), 1024*32) read := io.LimitReader(u.NewTimeSeededRand(), 1024*32)
root, err := imp.BuildDagFromReader(dservs[0], chunk.NewSizeSplitter(read, 512)) root, err := imp.BuildDagFromReader(dservs[0], chunker.NewSizeSplitter(read, 512))
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
...@@ -254,7 +254,7 @@ func TestEnumerateChildren(t *testing.T) { ...@@ -254,7 +254,7 @@ func TestEnumerateChildren(t *testing.T) {
ds := NewDAGService(bsi[0]) ds := NewDAGService(bsi[0])
read := io.LimitReader(u.NewTimeSeededRand(), 1024*1024) read := io.LimitReader(u.NewTimeSeededRand(), 1024*1024)
root, err := imp.BuildDagFromReader(ds, chunk.NewSizeSplitter(read, 512)) root, err := imp.BuildDagFromReader(ds, chunker.NewSizeSplitter(read, 512))
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment