summaryrefslogtreecommitdiff
path: root/manager.go
diff options
context:
space:
mode:
authorSilvan Jegen <s.jegen@gmail.com>2017-01-18 18:22:16 +0100
committerSilvan Jegen <s.jegen@gmail.com>2017-01-18 18:22:16 +0100
commit76e2175159ac2ff4b26d2606f4d8f1d7a896c5cc (patch)
tree3864cce33beb8bd851374df2d735831c8cfe3a23 /manager.go
parentc003fdf2182432a25892467bf1a456049f4b1c1d (diff)
Rename file
Diffstat (limited to 'manager.go')
-rw-r--r--manager.go39
1 files changed, 39 insertions, 0 deletions
diff --git a/manager.go b/manager.go
new file mode 100644
index 0000000..3fd2234
--- /dev/null
+++ b/manager.go
@@ -0,0 +1,39 @@
+package main
+
+import (
+ "fmt"
+ "sync"
+
+ "github.com/Shugyousha/stasher/filter"
+ "github.com/Shugyousha/stasher/input"
+ "github.com/Shugyousha/stasher/output"
+ "github.com/Shugyousha/stasher/work"
+)
+
+type Manager struct {
+ Input input.Input
+ Filter filter.Filter
+ Output output.Output
+}
+
+func (m *Manager) Run() {
+ var wg sync.WaitGroup
+
+ ic := m.Input.Start()
+ for w := range ic {
+ wg.Add(1)
+
+ go func(w *work.Work) {
+ nw := m.Filter.Filter(w)
+ err := nw.Error()
+ if err != nil {
+ fmt.Printf("Got an error when processing Work: %q\n", err)
+ }
+ m.Output.Output(nw)
+
+ wg.Done()
+ }(w)
+ }
+
+ wg.Wait()
+}