// RepackSubsets takes a slice of EndpointSubset objects, expands it to the full // representation, and then repacks that into the canonical layout. This // ensures that code which operates on these objects can rely on the common // form for things like comparison. The result is a newly allocated slice. func RepackSubsets(subsets []v1.EndpointSubset) []v1.EndpointSubset { … } type addressKey … // mapAddressesByPort adds all ready and not-ready addresses into a map by a single port. func mapAddressesByPort(subset *v1.EndpointSubset, port v1.EndpointPort, allAddrs map[addressKey]*v1.EndpointAddress, portToAddrReadyMap map[v1.EndpointPort]addressSet) { … } // mapAddressByPort adds one address into a map by port, registering the address with a unique pointer, and preserving // any existing ready state. func mapAddressByPort(addr *v1.EndpointAddress, port v1.EndpointPort, ready bool, allAddrs map[addressKey]*v1.EndpointAddress, portToAddrReadyMap map[v1.EndpointPort]addressSet) *v1.EndpointAddress { … } type addressSet … type addrReady … func hashAddresses(addrs addressSet) string { … } func lessAddrReady(a, b addrReady) bool { … } type addrsReady … func (sl addrsReady) Len() int { … } func (sl addrsReady) Swap(i, j int) { … } func (sl addrsReady) Less(i, j int) bool { … } // LessEndpointAddress compares IP addresses lexicographically and returns true if first argument is lesser than second func LessEndpointAddress(a, b *v1.EndpointAddress) bool { … } // SortSubsets sorts an array of EndpointSubset objects in place. For ease of // use it returns the input slice. func SortSubsets(subsets []v1.EndpointSubset) []v1.EndpointSubset { … } func hashObject(hasher hash.Hash, obj interface{ … } type subsetsByHash … func (sl subsetsByHash) Len() int { … } func (sl subsetsByHash) Swap(i, j int) { … } func (sl subsetsByHash) Less(i, j int) bool { … } type addrsByIPAndUID … func (sl addrsByIPAndUID) Len() int { … } func (sl addrsByIPAndUID) Swap(i, j int) { … } func (sl addrsByIPAndUID) Less(i, j int) bool { … } type portsByHash … func (sl portsByHash) Len() int { … } func (sl portsByHash) Swap(i, j int) { … } func (sl portsByHash) Less(i, j int) bool { … }
Codebase Browser
kubernetes