48 lines
1.2 KiB
TypeScript
48 lines
1.2 KiB
TypeScript
import {Injectable} from '@angular/core';
|
|
import {Observable} from "rxjs";
|
|
import {HttpClient} from "@angular/common/http";
|
|
import {Metric} from "../models/Metric";
|
|
import {map} from 'rxjs/operators';
|
|
import {StatusIntMap} from "../models/StatusIntMap";
|
|
|
|
@Injectable({
|
|
providedIn: 'root'
|
|
})
|
|
export class FetchMetricsService {
|
|
|
|
constructor(private http: HttpClient) {
|
|
}
|
|
|
|
private fetchMetrics(url:string):Observable<Metric[]>{
|
|
return this.http.get(url,
|
|
{responseType: 'text'}).pipe<Metric[]>(map(value => JSON.parse(value,
|
|
(key, value) => {
|
|
if (key === 'timestamp') {
|
|
value = new Date(value)
|
|
}
|
|
|
|
return value;
|
|
})))
|
|
}
|
|
|
|
getDead(): Observable<Metric[]> {
|
|
return this.fetchMetrics("http://localhost:4200/api/v1/metrics/dead");
|
|
}
|
|
|
|
getOk():Observable<Metric[]>{
|
|
return this.fetchMetrics("http://localhost:4200/api/v1/metrics/ok")
|
|
}
|
|
|
|
getUnknown():Observable<Metric[]> {
|
|
return this.fetchMetrics("http://localhost:4200/api/v1/metrics/unknown")
|
|
}
|
|
|
|
getNotGood():Observable<Metric[]> {
|
|
return this.fetchMetrics("http://localhost:4200/api/v1/metrics/not-good")
|
|
}
|
|
|
|
getCount():Observable<StatusIntMap>{
|
|
return this.http.get<StatusIntMap>("http://localhost:4200/api/v1/metrics")
|
|
}
|
|
}
|