Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewTopologyCache (0.21 sec)

  1. pkg/controller/endpointslice/endpointslice_controller.go

    			},
    			UpdateFunc: func(oldObj, newObj interface{}) {
    				c.updateNode(oldObj, newObj)
    			},
    			DeleteFunc: func(_ interface{}) {
    				c.deleteNode()
    			},
    		})
    
    		c.topologyCache = topologycache.NewTopologyCache()
    	}
    
    	c.reconciler = endpointslicerec.NewReconciler(
    		c.client,
    		c.nodeLister,
    		c.maxEndpointsPerSlice,
    		c.endpointSliceTracker,
    		c.topologyCache,
    		c.eventRecorder,
    		controllerName,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 23.6K bytes
    - Viewed (0)
  2. pkg/controller/endpointslice/endpointslice_controller_test.go

    						v1.ResourceCPU: *nodeInfo.cpu,
    					}
    				}
    				esController.nodeStore.Add(node)
    				if tc.topologyCacheEnabled {
    					esController.topologyCache = topologycache.NewTopologyCache()
    					for serviceKey, endpointZoneInfo := range tc.endpointZoneInfo {
    						esController.topologyCache.SetHints(serviceKey, discovery.AddressTypeIPv4, endpointZoneInfo)
    					}
    				}
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
Back to top