fork of https://github.com/sourcegraph/zoekt
0

Configure Feed

Select the types of activity you want to include in your feed.

shards: unexport NewDirectoryWatcher

Does not need to be exported.

+7 -7
+3 -3
shards/shards.go
··· 30 30 31 31 "golang.org/x/sync/semaphore" 32 32 33 + "github.com/prometheus/client_golang/prometheus" 34 + "github.com/prometheus/client_golang/prometheus/promauto" 33 35 "github.com/sourcegraph/zoekt" 34 36 "github.com/sourcegraph/zoekt/query" 35 37 "github.com/sourcegraph/zoekt/stream" 36 38 "github.com/sourcegraph/zoekt/trace" 37 - "github.com/prometheus/client_golang/prometheus" 38 - "github.com/prometheus/client_golang/prometheus/promauto" 39 39 ) 40 40 41 41 var ( ··· 202 202 tl := &loader{ 203 203 ss: ss, 204 204 } 205 - dw, err := NewDirectoryWatcher(dir, tl) 205 + dw, err := newDirectoryWatcher(dir, tl) // blocks until all shards are loaded 206 206 if err != nil { 207 207 return nil, err 208 208 }
+1 -1
shards/watcher.go
··· 54 54 }) 55 55 } 56 56 57 - func NewDirectoryWatcher(dir string, loader shardLoader) (*DirectoryWatcher, error) { 57 + func newDirectoryWatcher(dir string, loader shardLoader) (*DirectoryWatcher, error) { 58 58 sw := &DirectoryWatcher{ 59 59 dir: dir, 60 60 timestamps: map[string]time.Time{},
+3 -3
shards/watcher_test.go
··· 63 63 t.Fatalf("WriteFile: %v", err) 64 64 } 65 65 66 - dw, err := NewDirectoryWatcher(dir, logger) 66 + dw, err := newDirectoryWatcher(dir, logger) 67 67 if err != nil { 68 68 t.Fatalf("NewDirectoryWatcher: %v", err) 69 69 } ··· 115 115 loads: make(chan string, 10), 116 116 drops: make(chan string, 10), 117 117 } 118 - dw, err := NewDirectoryWatcher(dir, logger) 118 + dw, err := newDirectoryWatcher(dir, logger) 119 119 if err != nil { 120 120 t.Fatal(err) 121 121 } ··· 193 193 } 194 194 } 195 195 196 - dw, err := NewDirectoryWatcher(dir, logger) 196 + dw, err := newDirectoryWatcher(dir, logger) 197 197 if err != nil { 198 198 t.Fatalf("NewDirectoryWatcher: %v", err) 199 199 }