kubernetes/pkg/registry/core/service/storage/alloc.go

type Allocators …

type ServiceNodePort …

// This is a trasitionary function to facilitate service REST flattening.
func makeAlloc(defaultFamily api.IPFamily, ipAllocs map[api.IPFamily]ipallocator.Interface, portAlloc portallocator.Interface) Allocators { … }

func (al *Allocators) allocateCreate(service *api.Service, dryRun bool) (transaction, error) { … }

// attempts to default service ip families according to cluster configuration
// while ensuring that provided families are configured on cluster.
func (al *Allocators) initIPFamilyFields(after After, before Before) error { … }

func (al *Allocators) txnAllocClusterIPs(service *api.Service, dryRun bool) (transaction, error) { … }

// allocates ClusterIPs for a service
func (al *Allocators) allocClusterIPs(service *api.Service, dryRun bool) (map[api.IPFamily]string, error) { … }

func (al *Allocators) allocIPs(service *api.Service, toAlloc map[api.IPFamily]string, dryRun bool) (map[api.IPFamily]string, error) { … }

// releases clusterIPs per family
func (al *Allocators) releaseIPs(toRelease map[api.IPFamily]string) (map[api.IPFamily]string, error) { … }

func (al *Allocators) txnAllocNodePorts(service *api.Service, dryRun bool) (transaction, error) { … }

func initNodePorts(service *api.Service, nodePortOp *portallocator.PortAllocationOperation) error { … }

// allocHealthCheckNodePort allocates health check node port to service.
func (al *Allocators) allocHealthCheckNodePort(service *api.Service, nodePortOp *portallocator.PortAllocationOperation) error { … }

func (al *Allocators) allocateUpdate(after After, before Before, dryRun bool) (transaction, error) { … }

func (al *Allocators) txnUpdateClusterIPs(after After, before Before, dryRun bool) (transaction, error) { … }

// handles type change/upgrade/downgrade change type for an update service
// this func does not perform actual release of clusterIPs. it returns
// a map[family]ip for the caller to release when everything else has
// executed successfully
func (al *Allocators) updateClusterIPs(after After, before Before, dryRun bool) (allocated map[api.IPFamily]string, toRelease map[api.IPFamily]string, err error) { … }

func (al *Allocators) txnUpdateNodePorts(after After, before Before, dryRun bool) (transaction, error) { … }

func (al *Allocators) releaseNodePorts(service *api.Service, nodePortOp *portallocator.PortAllocationOperation) { … }

func (al *Allocators) updateNodePorts(after After, before Before, nodePortOp *portallocator.PortAllocationOperation) error { … }

// updateHealthCheckNodePort handles HealthCheckNodePort allocation/release
// and adjusts HealthCheckNodePort during service update if needed.
func (al *Allocators) updateHealthCheckNodePort(after After, before Before, nodePortOp *portallocator.PortAllocationOperation) (bool, error) { … }

func (al *Allocators) releaseAllocatedResources(svc *api.Service) { … }

// releases allocated ClusterIPs for service that is about to be deleted
func (al *Allocators) releaseClusterIPs(service *api.Service) (released map[api.IPFamily]string, err error) { … }

func (al *Allocators) Destroy() { … }

// This is O(N), but we expect haystack to be small;
// so small that we expect a linear search to be faster
func containsNumber(haystack []int, needle int) bool { … }

// This is O(N), but we expect serviceNodePorts to be small;
// so small that we expect a linear search to be faster
func containsNodePort(serviceNodePorts []ServiceNodePort, serviceNodePort ServiceNodePort) bool { … }

// Loop through the service ports list, find one with the same port number and
// NodePort specified, return this NodePort otherwise return 0.
func findRequestedNodePort(port int, servicePorts []api.ServicePort) int { … }

func shouldAllocateNodePorts(service *api.Service) bool { … }

func collectServiceNodePorts(service *api.Service) []int { … }

// tests if two preferred dual-stack service have matching ClusterIPFields
// assumption: old service is a valid, default service (e.g., loaded from store)
func isMatchingPreferDualStackClusterIPFields(after After, before Before) bool { … }

// Helper to avoid nil-checks all over.  Callers of this need to be checking
// for an exact value.
func getIPFamilyPolicy(svc *api.Service) api.IPFamilyPolicy { … }

func sameClusterIPs(lhs, rhs *api.Service) bool { … }

func reducedClusterIPs(after After, before Before) bool { … }

func sameIPFamilies(lhs, rhs *api.Service) bool { … }

func reducedIPFamilies(after After, before Before) bool { … }

// Helper to get the IP family of a given IP.
func familyOf(ip string) api.IPFamily { … }