const maxConcurrentRouteOperations …
var updateNetworkConditionBackoff …
type RouteController …
func New(routes cloudprovider.Routes, kubeClient clientset.Interface, nodeInformer coreinformers.NodeInformer, clusterName string, clusterCIDRs []*net.IPNet) *RouteController { … }
func (rc *RouteController) Run(ctx context.Context, syncPeriod time.Duration, controllerManagerMetrics *controllersmetrics.ControllerManagerMetrics) { … }
func (rc *RouteController) reconcileNodeRoutes(ctx context.Context) error { … }
type routeAction …
var keep …
var add …
var remove …
var update …
type routeNode …
func (rc *RouteController) reconcile(ctx context.Context, nodes []*v1.Node, routes []*cloudprovider.Route) error { … }
func (rc *RouteController) updateNetworkingCondition(node *v1.Node, routesCreated bool) error { … }
func (rc *RouteController) isResponsibleForRoute(route *cloudprovider.Route) bool { … }
func getRouteAction(routes []*cloudprovider.Route, cidr string, nodeName types.NodeName, realNodeAddrs []v1.NodeAddress) routeAction { … }
func equalNodeAddrs(addrs0 []v1.NodeAddress, addrs1 []v1.NodeAddress) bool { … }