github
/
statping
mirror of https://github.com/statping/statping
1
0
Fork 0
Code Issues Releases Wiki Activity

Fix grpcCheck to RecordFailure 

Signed-off-by: thatInfrastructureGuy <thatInfrastructureGuy@gmail.com>
pull/806/head
thatInfrastructureGuy 2020-08-28 11:54:32 -07:00
parent 789443aab7
commit 7e3954e66e
No known key found for this signature in database
GPG Key ID: 3E9D4A7275BC5A6A
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
types/services/routine.go
View File

@ -184,7 +184,7 @@ func CheckGrpc(s *Service, record bool) (*Service, error) {
res, err := c.Check(ctx, in)
if err != nil {
if record {
recordFailure(s, fmt.Sprintf("GRPC Error %v", err))
RecordFailure(s, fmt.Sprintf("GRPC Error %v", err), "healthcheck")
}
return s, nil
}
@ -208,14 +208,14 @@ func CheckGrpc(s *Service, record bool) (*Service, error) {
if !(s.Expected.String == strings.TrimSpace(s.LastResponse)) {
log.Warnln(fmt.Sprintf("GRPC Service: '%s', Response: expected '%v', got '%v'", s.Name, s.LastResponse, s.Expected.String))
if record {
recordFailure(s, fmt.Sprintf("GRPC Response Body did not match '%v'", s.Expected.String))
RecordFailure(s, fmt.Sprintf("GRPC Response Body did not match '%v'", s.Expected.String), "response_body")
}
return s, nil
}
if s.ExpectedStatus != int(res.Status) {
if record {
recordFailure(s, fmt.Sprintf("GRPC Service: '%s', Status Code: expected '%v', got '%v'", s.Name, res.Status, healthpb.HealthCheckResponse_ServingStatus(s.ExpectedStatus)))
RecordFailure(s, fmt.Sprintf("GRPC Service: '%s', Status Code: expected '%v', got '%v'", s.Name, res.Status, healthpb.HealthCheckResponse_ServingStatus(s.ExpectedStatus)), "response_code")
}
return s, nil
}