| |
@@ -0,0 +1,62 @@
|
| |
+ diff --git a/examples/example_hyper.rs b/examples/example_hyper.rs
|
| |
+ index c9d02bc..a6eda1b 100644
|
| |
+ --- a/examples/example_hyper.rs
|
| |
+ +++ b/examples/example_hyper.rs
|
| |
+ @@ -16,9 +16,7 @@ extern crate lazy_static;
|
| |
+ #[macro_use]
|
| |
+ extern crate prometheus;
|
| |
+
|
| |
+ -use hyper::header::ContentType;
|
| |
+ -use hyper::mime::Mime;
|
| |
+ -use hyper::server::{Request, Response, Server};
|
| |
+ +use hyper::{header::CONTENT_TYPE, rt::Future, service::service_fn_ok, Body, Response, Server};
|
| |
+
|
| |
+ use prometheus::{Counter, Encoder, Gauge, HistogramVec, TextEncoder};
|
| |
+
|
| |
+ @@ -44,24 +42,35 @@ lazy_static! {
|
| |
+ }
|
| |
+
|
| |
+ fn main() {
|
| |
+ - let encoder = TextEncoder::new();
|
| |
+ - let addr = "127.0.0.1:9898";
|
| |
+ - println!("listening addr {:?}", addr);
|
| |
+ - Server::http(addr)
|
| |
+ - .unwrap()
|
| |
+ - .handle(move |_: Request<'_, '_>, mut res: Response<'_>| {
|
| |
+ + let addr = ([127, 0, 0, 1], 9898).into();
|
| |
+ + println!("Listening address: {:?}", addr);
|
| |
+ +
|
| |
+ + let new_service = || {
|
| |
+ + let encoder = TextEncoder::new();
|
| |
+ + service_fn_ok(move |_request| {
|
| |
+ HTTP_COUNTER.inc();
|
| |
+ let timer = HTTP_REQ_HISTOGRAM.with_label_values(&["all"]).start_timer();
|
| |
+
|
| |
+ let metric_families = prometheus::gather();
|
| |
+ let mut buffer = vec![];
|
| |
+ encoder.encode(&metric_families, &mut buffer).unwrap();
|
| |
+ - res.headers_mut()
|
| |
+ - .set(ContentType(encoder.format_type().parse::<Mime>().unwrap()));
|
| |
+ - res.send(&buffer).unwrap();
|
| |
+ + HTTP_BODY_GAUGE.set(buffer.len() as f64);
|
| |
+ +
|
| |
+ + let response = Response::builder()
|
| |
+ + .status(200)
|
| |
+ + .header(CONTENT_TYPE, encoder.format_type())
|
| |
+ + .body(Body::from(buffer))
|
| |
+ + .unwrap();
|
| |
+
|
| |
+ timer.observe_duration();
|
| |
+ - HTTP_BODY_GAUGE.set(buffer.len() as f64);
|
| |
+ +
|
| |
+ + response
|
| |
+ })
|
| |
+ - .unwrap();
|
| |
+ + };
|
| |
+ +
|
| |
+ + let server = Server::bind(&addr)
|
| |
+ + .serve(new_service)
|
| |
+ + .map_err(|e| eprintln!("Server error: {}", e));
|
| |
+ +
|
| |
+ + hyper::rt::run(server);
|
| |
+ }
|
| |
See: https://github.com/pingcap/rust-prometheus/pull/249