summaryrefslogtreecommitdiff
path: root/output
diff options
context:
space:
mode:
Diffstat (limited to 'output')
-rw-r--r--output/http/http.go4
-rw-r--r--output/outputinterface.go2
-rw-r--r--output/stdout/stdout.go5
3 files changed, 7 insertions, 4 deletions
diff --git a/output/http/http.go b/output/http/http.go
index 3ea603c..158f091 100644
--- a/output/http/http.go
+++ b/output/http/http.go
@@ -22,9 +22,11 @@ func New(kv map[string]string) output.Output {
return &HttpOutput{url: url}
}
-func (h *HttpOutput) Output(w *work.Work) {
+func (h *HttpOutput) Output(w *work.Work) error {
_, err := http.Post(h.url, "application/json", bytes.NewReader(w.Data))
if err != nil {
w.Err = err
}
+
+ return err
}
diff --git a/output/outputinterface.go b/output/outputinterface.go
index 8f1137a..385fe4e 100644
--- a/output/outputinterface.go
+++ b/output/outputinterface.go
@@ -3,5 +3,5 @@ package output
import "github.com/Shugyousha/stasher/work"
type Output interface {
- Output(*work.Work)
+ Output(*work.Work) error
}
diff --git a/output/stdout/stdout.go b/output/stdout/stdout.go
index 9d66581..f3e4f57 100644
--- a/output/stdout/stdout.go
+++ b/output/stdout/stdout.go
@@ -19,6 +19,7 @@ func New(map[string]string) output.Output {
return &StdoutOutput{}
}
-func (o *StdoutOutput) Output(w *work.Work) {
- fmt.Printf("%s\n", w.Data)
+func (o *StdoutOutput) Output(w *work.Work) error {
+ _, err := fmt.Printf("%s\n", w.Data)
+ return err
}