Skywalker is a package to allow one to concurrently go through a filesystem with ease.
- Concurrency
- BlackList filtering
- WhiteList filtering
- Filter by Directory
- Filter by Extension
- Glob Filtering (provided by gobwas/glob)
For matching to work properly across platforms. Please use
/. In gobwas/glob the\is an escape character (so you can escape*,?, etc...) making it difficult to know if you want to escape a character or go into directory.
package main import ( "fmt" "sort" "strings" "sync" "github.com/dixonwille/skywalker" ) type ExampleWorker struct { *sync.Mutex found []string } func (ew *ExampleWorker) Work(path string) { //This is where the necessary work should be done. //This will get concurrently so make sure it is thread safe if you need info across threads. ew.Lock() defer ew.Unlock() ew.found = append(ew.found, path) } func main() { //Following two functions are only to create and destroy data for the example defer teardownData() standupData() ew := new(ExampleWorker) ew.Mutex = new(sync.Mutex) //root is the root directory of the data that was stood up above sw := skywalker.New(root, ew) sw.DirListType = skywalker.LTBlacklist sw.DirList = []string{"sub"} sw.ExtListType = skywalker.LTWhitelist sw.ExtList = []string{".pdf"} err := sw.Walk() if err != nil { fmt.Println(err) return } sort.Sort(sort.StringSlice(ew.found)) for _, f := range ew.found { fmt.Println(strings.Replace(f, sw.Root, "", 1)) } }