-
Notifications
You must be signed in to change notification settings - Fork 712
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Probes POST to apps #342
Probes POST to apps #342
Conversation
router := mux.NewRouter() | ||
post := router.Methods("POST").Subrouter() | ||
post.HandleFunc("/", handleReport(c)) |
This comment was marked as abuse.
This comment was marked as abuse.
Sorry, something went wrong.
This comment was marked as abuse.
This comment was marked as abuse.
Sorry, something went wrong.
For the OSS to work, doesn't the probe need to use the resolver to publish to multiple apps? |
@@ -25,10 +25,11 @@ var version = "dev" // set at build time | |||
|
|||
func main() { | |||
var ( | |||
publish = flag.String("publish", fmt.Sprintf("http://localhost:%d", xfer.AppPort), "URL to publish reports") |
This comment was marked as abuse.
This comment was marked as abuse.
Sorry, something went wrong.
This comment was marked as abuse.
This comment was marked as abuse.
Sorry, something went wrong.
75f6fc5
to
9099b2a
Compare
- App takes POST report on /api/report - Probe publishes to configured target(s) - Name resolution happens on probe-side - There's no longer an xfer.ProbePort - xfer.Collector responsibility is reduced - Fixes to remaining experimental components. - rm experimental/bridge: it's not being used, and by changing the app/probe comm model, it would require a complete refactor anyway. We can easily rebuild it when we need to. It will even be much simpler. - rm experimental/graphviz: it's broken for some time anyway, and we don't really need to play around with it as a rendering option anymore. - rm experimental/oneshot: we never use this anymore.
b657ec1
to
7d51f17
Compare
@tomwilkie @paulbellamy @2opremio Ready for review! |
p.closer.Close() | ||
// AuthorizationHeader returns a value suitable for an HTTP Authorization | ||
// header, based on the passed token string. | ||
func AuthorizationHeader(token string) string { |
This comment was marked as abuse.
This comment was marked as abuse.
Sorry, something went wrong.
This comment was marked as abuse.
This comment was marked as abuse.
Sorry, something went wrong.
Overall, LGTM |
dec70e8
to
a8d3fdf
Compare
a8d3fdf
to
edf0ceb
Compare
Change the flow of the streams.