diff --git a/coordinated_server.go b/coordinated_server.go new file mode 100644 index 0000000..67f9f7b --- /dev/null +++ b/coordinated_server.go @@ -0,0 +1,16 @@ +package realis + +import ( + "fmt" + "log" + "net/http" +) + +func handler(w http.ResponseWriter, r *http.Request) { + fmt.Fprintf(w, `{"roll_forward":true}`) +} + +func Run_server() { + http.HandleFunc("/aurora-update", handler) + log.Fatal(http.ListenAndServe(":8080", nil)) +} diff --git a/jobUpdate.go b/jobUpdate.go index c941cd5..c93a788 100644 --- a/jobUpdate.go +++ b/jobUpdate.go @@ -17,7 +17,7 @@ package realis import ( "time" - "git.apache.org/thrift.git/lib/go/thrift" + "github.com/apache/thrift/lib/go/thrift" "github.com/paypal/gorealis/v2/gen-go/apache/aurora" ) diff --git a/realis.go b/realis.go index 74c79c9..7602fde 100644 --- a/realis.go +++ b/realis.go @@ -31,7 +31,7 @@ import ( "sync" "time" - "git.apache.org/thrift.git/lib/go/thrift" + "github.com/apache/thrift/lib/go/thrift" "github.com/paypal/gorealis/v2/gen-go/apache/aurora" "github.com/paypal/gorealis/v2/response" "github.com/pkg/errors" diff --git a/retry.go b/retry.go index cb5b5a4..1b20dae 100644 --- a/retry.go +++ b/retry.go @@ -23,7 +23,7 @@ import ( "strings" "time" - "git.apache.org/thrift.git/lib/go/thrift" + "github.com/apache/thrift/lib/go/thrift" "github.com/paypal/gorealis/v2/gen-go/apache/aurora" "github.com/paypal/gorealis/v2/response" "github.com/pkg/errors" diff --git a/task.go b/task.go index 196d9a7..c067371 100644 --- a/task.go +++ b/task.go @@ -18,7 +18,7 @@ import ( "encoding/json" "strconv" - "git.apache.org/thrift.git/lib/go/thrift" + "github.com/apache/thrift/lib/go/thrift" "github.com/paypal/gorealis/v2/gen-go/apache/aurora" ) diff --git a/thermos_test.go b/thermos_test.go index 142bcda..6dce78f 100644 --- a/thermos_test.go +++ b/thermos_test.go @@ -4,7 +4,7 @@ import ( "encoding/json" "testing" - "git.apache.org/thrift.git/lib/go/thrift" + "github.com/apache/thrift/lib/go/thrift" "github.com/stretchr/testify/assert" )