in correlation/inbound_http_options.go [76:91]
func WithCIDRsTrustedForXForwardedFor(trustedCIDRs []string) InboundHandlerOption {
return func(config *inboundHandlerConfig) {
for _, s := range trustedCIDRs {
_, ipNet, err := net.ParseCIDR(s)
if err != nil {
logrus.Errorf("Bad trusted CIDR for XForwardedFor %s: %v", s, err)
} else {
config.trustedCIDRsForXForwardedFor = append(config.trustedCIDRsForXForwardedFor, *ipNet)
}
}
config.xffAllowed = func(ip string) bool {
return isTrustedIP(ip, config.trustedCIDRsForXForwardedFor)
}
}
}