summaryrefslogtreecommitdiff
path: root/manager.go
diff options
context:
space:
mode:
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()
+}