in correlation/inbound_http_options.go [59:72]
func WithCIDRsTrustedForPropagation(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 propagation %s: %v, propagation disabled", s, err)
config.invalidCIDRsForPropagation = true
} else {
config.trustedCIDRsForPropagation = append(config.trustedCIDRsForPropagation, *ipNet)
}
}
}
}