merge: gRPC server + hub + 跨实例 pub/sub [tsk_mF5RWPEwngai]
This commit is contained in:
@@ -43,6 +43,8 @@ func main() {
|
|||||||
// configured so the public API can run on its own. See internal/admin.
|
// configured so the public API can run on its own. See internal/admin.
|
||||||
startAdminIfConfigured()
|
startAdminIfConfigured()
|
||||||
|
|
||||||
|
// ─── HTTP server ──────────────────────────────────────────────────────────
|
||||||
|
|
||||||
r := chi.NewRouter()
|
r := chi.NewRouter()
|
||||||
r.Use(middleware.Logger)
|
r.Use(middleware.Logger)
|
||||||
r.Use(middleware.Recoverer)
|
r.Use(middleware.Recoverer)
|
||||||
@@ -81,6 +83,7 @@ func main() {
|
|||||||
log.Printf("probe ingest route registered (%d probe(s))", len(secretMap))
|
log.Printf("probe ingest route registered (%d probe(s))", len(secretMap))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Mount all /v1/... routes. HandlerFromMuxWithBaseURL registers every route
|
// Mount all /v1/... routes. HandlerFromMuxWithBaseURL registers every route
|
||||||
// from the OpenAPI spec onto the provided chi router with the given prefix,
|
// from the OpenAPI spec onto the provided chi router with the given prefix,
|
||||||
// so the router itself is the http.Handler we serve.
|
// so the router itself is the http.Handler we serve.
|
||||||
|
|||||||
Reference in New Issue
Block a user