From 07e3d60146de6c5906382e378cdcb3d6a6989cd0 Mon Sep 17 00:00:00 2001 From: Silvan Jegen Date: Tue, 14 Feb 2017 14:37:12 +0100 Subject: Change Output interface to return an error --- output/http/http.go | 4 +++- output/outputinterface.go | 2 +- output/stdout/stdout.go | 5 +++-- 3 files changed, 7 insertions(+), 4 deletions(-) (limited to 'output') 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 } -- cgit v1.2.1-18-gbd029