From 5147048d4a67c59f799203e1cc5f79b183208cab Mon Sep 17 00:00:00 2001 From: Silvan Jegen Date: Wed, 15 Feb 2017 12:55:58 +0100 Subject: Put the Manager in its own package --- manager/manager.go | 46 ++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 46 insertions(+) create mode 100644 manager/manager.go (limited to 'manager') diff --git a/manager/manager.go b/manager/manager.go new file mode 100644 index 0000000..5bbd49f --- /dev/null +++ b/manager/manager.go @@ -0,0 +1,46 @@ +package manager + +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 { + if w.Err != nil { + fmt.Printf("Got an error when getting Work input: %q\n", w.Err) + continue + } + 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 filtering Work: %q\n", err) + } + err = m.Output.Output(nw) + if err != nil { + fmt.Printf("Got an error when outputting Work: %q\n", err) + } + + wg.Done() + }(w) + } + + wg.Wait() +} -- cgit v1.2.1-18-gbd029