add a counter for endpoints that opted out before loadbalancing

Signed-off-by: Mustafa Abdelrahman <[email protected]>

docs/operation/operation.md

@@ -921,6 +921,12 @@ The parameters of `-passive-health-check` option are:
 + `max-drop-probabilty=<float more than/equal to 0 and less than/equal to 1>` - the maximum possible probability of unhealthy endpoint being not considered
 while choosing the endpoint for the given request
 
+### Metrics
+
+A set of metrics will be exposed to track passive health checks:
+
+* `routing.endpoint.drop.loadbalancer`: Number of endpoints dropped before load balancing the requests 
+
 ## Memory consumption
 
 While Skipper is generally not memory bound, some features may require

proxy/healthy_endpoints.go

@@ -3,6 +3,7 @@ package proxy
 import (
 	"math/rand"
 
+	"github.com/zalando/skipper/metrics"
 	"github.com/zalando/skipper/routing"
 )
 
@@ -11,7 +12,7 @@ type healthyEndpoints struct {
 	endpointRegistry *routing.EndpointRegistry
 }
 
-func (h *healthyEndpoints) filterHealthyEndpoints(endpoints []routing.LBEndpoint, rt *routing.Route) []routing.LBEndpoint {
+func (h *healthyEndpoints) filterHealthyEndpoints(endpoints []routing.LBEndpoint, metrics metrics.Metrics) []routing.LBEndpoint {
 	if h == nil {
 		return endpoints
 	}
@@ -22,6 +23,7 @@ func (h *healthyEndpoints) filterHealthyEndpoints(endpoints []routing.LBEndpoint
 	for _, e := range endpoints {
 		if p < e.Metrics.HealthCheckDropProbability() {
 			/* drop */
+			metrics.IncCounter("routing.endpoint.drop.loadbalancer")
 		} else {
 			filtered = append(filtered, e)
 		}

proxy/proxy.go

@@ -540,7 +540,7 @@ func (p *Proxy) selectEndpoint(ctx *context) *routing.LBEndpoint {
 	rt := ctx.route
 	endpoints := rt.LBEndpoints
 	endpoints = p.fadein.filterFadeIn(endpoints, rt)
-	endpoints = p.heathlyEndpoints.filterHealthyEndpoints(endpoints, rt)
+	endpoints = p.heathlyEndpoints.filterHealthyEndpoints(endpoints, p.metrics)
 
 	lbctx := &routing.LBContext{
 		Request:     ctx.request,