FindEnvs by name

Author: Duologic

pkg/tanka/find.go

@@ -12,6 +12,7 @@ import (
 // FindOpts are optional arguments for FindEnvs
 type FindOpts struct {
 	Selector labels.Selector
+	Name     string
 }
 
 // FindEnvs returns metadata of all environments recursively found in 'path'.
@@ -20,7 +21,7 @@ type FindOpts struct {
 // are not checked.
 func FindEnvs(path string, opts FindOpts) ([]*v1alpha1.Environment, error) {
 	// find all environments at dir
-	envs, err := find(path)
+	envs, err := find(path, opts.Name)
 	if err != nil {
 		return nil, err
 	}
@@ -42,9 +43,9 @@ func FindEnvs(path string, opts FindOpts) ([]*v1alpha1.Environment, error) {
 }
 
 // find implements the actual functionality described at 'FindEnvs'
-func find(path string) ([]*v1alpha1.Environment, error) {
+func find(path, name string) ([]*v1alpha1.Environment, error) {
 	// try if this has envs
-	list, err := List(path, Opts{})
+	list, err := List(path, Opts{Name: name})
 	if len(list) != 0 && err == nil {
 		// it has. don't search deeper
 		return list, nil
@@ -77,7 +78,7 @@ func find(path string) ([]*v1alpha1.Environment, error) {
 		}
 
 		routines++
-		go findShim(filepath.Join(path, fi.Name()), ch)
+		go findShim(filepath.Join(path, fi.Name()), name, ch)
 	}
 
 	// collect parallel results
@@ -105,7 +106,7 @@ type findOut struct {
 	err  error
 }
 
-func findShim(dir string, ch chan findOut) {
-	envs, err := find(dir)
+func findShim(path, name string, ch chan findOut) {
+	envs, err := find(path, name)
 	ch <- findOut{envs: envs, err: err}
 }

pkg/tanka/parallel.go

@@ -21,12 +21,13 @@ func parallelLoadEnvironments(paths []string, opts parallelOpts) ([]*v1alpha1.En
 	jobsCh := make(chan parallelJob)
 	list := make(map[string]string)
 	for _, path := range paths {
-		envs, err := FindEnvs(path, FindOpts{opts.Selector})
+		envs, err := FindEnvs(path, FindOpts{Selector: opts.Selector, Name: opts.Name})
 		if err != nil {
 			return nil, err
 		}
 		for _, env := range envs {
 			list[env.Metadata.Name] = path
+			fmt.Println(env.Metadata.Name)
 		}
 	}
 	outCh := make(chan parallelOut, len(list))