summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorSilvan Jegen <s.jegen@gmail.com>2017-02-14 14:31:58 +0100
committerSilvan Jegen <s.jegen@gmail.com>2017-02-14 14:31:58 +0100
commit543eea285200c8955f42c5eb202a222105259587 (patch)
treeb6c6a16166a16eef2e9fc74fd28240eb66368a50
parent30716efc96229240cdc1af40ce52d61b0658277b (diff)
Implement simple http Output
-rw-r--r--output/http/http.go14
1 files changed, 10 insertions, 4 deletions
diff --git a/output/http/http.go b/output/http/http.go
index 9caa1b9..3ea603c 100644
--- a/output/http/http.go
+++ b/output/http/http.go
@@ -1,7 +1,8 @@
package http
import (
- "fmt"
+ "bytes"
+ "net/http"
"github.com/Shugyousha/stasher/output"
"github.com/Shugyousha/stasher/registry"
@@ -13,12 +14,17 @@ func init() {
}
type HttpOutput struct {
+ url string
}
-func New(map[string]string) output.Output {
- return &HttpOutput{}
+func New(kv map[string]string) output.Output {
+ url := kv["url"]
+ return &HttpOutput{url: url}
}
func (h *HttpOutput) Output(w *work.Work) {
- fmt.Printf("%s\n", w.Data)
+ _, err := http.Post(h.url, "application/json", bytes.NewReader(w.Data))
+ if err != nil {
+ w.Err = err
+ }
}