Skip to content

Commit

Permalink
fix build
Browse files Browse the repository at this point in the history
  • Loading branch information
ostinru committed Nov 22, 2021
1 parent 3c2eed8 commit a70ffcc
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion internal/splitmerge/splitreader.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ func SplitReader(reader io.Reader, parts int, blockSize int) []io.Reader {
channels := make([]chan []byte, 0)

for i := 0; i < parts; i++ {
channels = append(channels, make(chan []byte, 0))
channels = append(channels, make(chan []byte))
result = append(result, NewChannelReader(channels[i]))
}

Expand Down
2 changes: 1 addition & 1 deletion internal/stream_fetch_helper.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"path"
"time"

"github.com/wal-g/wal-g/pkg/storages/splitmerge"
"github.com/wal-g/wal-g/internal/splitmerge"

"github.com/wal-g/tracelog"
"github.com/wal-g/wal-g/internal/compression"
Expand Down
2 changes: 1 addition & 1 deletion internal/stream_push_helper.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import (

"golang.org/x/sync/errgroup"

"github.com/wal-g/wal-g/pkg/storages/splitmerge"
"github.com/wal-g/wal-g/internal/splitmerge"

"github.com/wal-g/tracelog"
"github.com/wal-g/wal-g/utility"
Expand Down

0 comments on commit a70ffcc

Please sign in to comment.