diff --git a/cmd/mtredisalize/changetracker.go b/cmd/mtredisalize/changetracker.go index adf5c2c..3b0af4d 100644 --- a/cmd/mtredisalize/changetracker.go +++ b/cmd/mtredisalize/changetracker.go @@ -3,8 +3,11 @@ package main import ( "encoding/json" "log" + "net/http" "sync" + "bytes" + "bitbucket.org/s_l_teichmann/mtredisalize/common" ) @@ -54,8 +57,11 @@ func (ct *ChangeTracker) FlushChanges(url string) (err error) { log.Printf("WARN: encode changes to JSON failed: %s", err) return } - // TODO: implement http POST - _ = encoded + var buf bytes.Buffer + buf.Write(encoded) + if _, err = http.Post(url, "application/json", &buf); err != nil { + log.Printf("WARN: posting changes to %s failed: %s", url, err) + } }() return }