Function processRouteDef

routing/datasource.go:532–559

processes a route definition for the routing table

(o *Options, cpm map[string]PredicateSpec, def *eskip.Route)

// processes a route definition for the routing table
func processRouteDef(o *Options, cpm map[string]PredicateSpec, def *eskip.Route) (*Route, error) {
	scheme, host, err := SplitBackend(def.Backend, def.BackendType, def.Shunt)
	if err != nil {
		return nil, fmt.Errorf("%w: failed to parse backend address %q: %w", errFailedBackendSplit, def.Backend, err)
	}

	fs, err := createFilters(o, def.Filters, cpm)
	if err != nil {
		return nil, err
	}

	def, err = mergeLegacyNonTreePredicates(def)
	if err != nil {
		return nil, err
	}

	cps, weight, err := processPredicates(o, cpm, def.Predicates)
	if err != nil {
		return nil, err
	}

	r := &Route{Route: *def, Scheme: scheme, Host: host, Predicates: cps, Filters: fs, weight: weight}
	if err := processTreePredicates(r, def.Predicates); err != nil {
		return nil, err
	}

	return r, nil
}

// convert a slice of predicate specs to a map keyed by their names
func mapPredicates(cps []PredicateSpec) map[string]PredicateSpec {