const overloadThreshold … type TopologyCache … type EndpointZoneInfo … type allocation … // NewTopologyCache initializes a new TopologyCache. func NewTopologyCache() *TopologyCache { … } // GetOverloadedServices returns a list of Service keys that refer to Services // that have crossed the overload threshold for any zone. func (t *TopologyCache) GetOverloadedServices() []string { … } // AddHints adds or updates topology hints on EndpointSlices and returns updated // lists of EndpointSlices to create and update. func (t *TopologyCache) AddHints(logger klog.Logger, si *SliceInfo) ([]*discovery.EndpointSlice, []*discovery.EndpointSlice, []*EventBuilder) { … } // SetHints sets topology hints for the provided serviceKey and addrType in this // cache. func (t *TopologyCache) SetHints(serviceKey string, addrType discovery.AddressType, allocatedHintsByZone EndpointZoneInfo) { … } func (t *TopologyCache) setHintsLocked(serviceKey string, addrType discovery.AddressType, allocatedHintsByZone EndpointZoneInfo) { … } // RemoveHints removes topology hints for the provided serviceKey and addrType // from this cache. func (t *TopologyCache) RemoveHints(serviceKey string, addrType discovery.AddressType) { … } // SetNodes updates the Node distribution for the TopologyCache. func (t *TopologyCache) SetNodes(logger klog.Logger, nodes []*v1.Node) { … } // HasPopulatedHints checks whether there are populated hints for a given service in the cache. func (t *TopologyCache) HasPopulatedHints(serviceKey string) bool { … } func (t *TopologyCache) hasPopulatedHintsLocked(serviceKey string) bool { … } // getAllocations returns a set of minimum and maximum allocations per zone. If // it is not possible to provide allocations that are below the overload // threshold, a nil value will be returned. func (t *TopologyCache) getAllocations(numEndpoints int) (map[string]allocation, *EventBuilder) { … } // Nodes with any of these labels set to any value will be excluded from // topology capacity calculations. func hasExcludedLabels(labels map[string]string) bool { … }
Codebase Browser
kubernetes