From 819b6da7620b52774dead3d96e6407f9d29bbeb0 Mon Sep 17 00:00:00 2001 From: Alexander Neumann Date: Sat, 2 May 2015 15:31:31 +0200 Subject: [PATCH] restorer: unexport archive pipe --- archiver.go | 6 +++--- archiver_int_test.go | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/archiver.go b/archiver.go index 8632b82fd..c3517c0b1 100644 --- a/archiver.go +++ b/archiver.go @@ -459,7 +459,7 @@ func (arch *Archiver) dirWorker(wg *sync.WaitGroup, p *Progress, done <-chan str } } -type ArchivePipe struct { +type archivePipe struct { Old <-chan WalkTreeJob New <-chan pipe.Job } @@ -499,7 +499,7 @@ type archiveJob struct { new pipe.Job } -func (a *ArchivePipe) compare(done <-chan struct{}, out chan<- pipe.Job) { +func (a *archivePipe) compare(done <-chan struct{}, out chan<- pipe.Job) { defer func() { close(out) debug.Log("ArchivePipe.compare", "done") @@ -638,7 +638,7 @@ func (arch *Archiver) Snapshot(p *Progress, paths []string, pid backend.ID) (*Sn return nil, nil, err } - jobs := ArchivePipe{} + jobs := archivePipe{} // use parent snapshot (if some was given) if pid != nil { diff --git a/archiver_int_test.go b/archiver_int_test.go index 948d44ba6..d26a9ce53 100644 --- a/archiver_int_test.go +++ b/archiver_int_test.go @@ -115,7 +115,7 @@ func TestArchivePipe(t *testing.T) { go testTreeWalker(done, treeCh) go testPipeWalker(done, pipeCh) - p := ArchivePipe{Old: treeCh, New: pipeCh} + p := archivePipe{Old: treeCh, New: pipeCh} ch := make(chan pipe.Job)