summaryrefslogtreecommitdiff
path: root/types.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 /types.go
parentc003fdf2182432a25892467bf1a456049f4b1c1d (diff)
Rename file
Diffstat (limited to 'types.go')
-rw-r--r--types.go48
1 files changed, 0 insertions, 48 deletions
diff --git a/types.go b/types.go
deleted file mode 100644
index abd2658..0000000
--- a/types.go
+++ /dev/null
@@ -1,48 +0,0 @@
-package main
-
-import (
- "fmt"
- "sync"
-
- "github.com/Shugyousha/stasher/work"
-)
-
-type Input interface {
- Start() chan *work.Work
-}
-
-type Filter interface {
- Filter(*work.Work) *work.Work
-}
-
-type Output interface {
- Output(*work.Work)
-}
-
-type Manager struct {
- Input Input
- Filter Filter
- 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()
-}