type Allocators …
type ServiceNodePort …
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) { … }
func (al *Allocators) initIPFamilyFields(after After, before Before) error { … }
func (al *Allocators) txnAllocClusterIPs(service *api.Service, dryRun bool) (transaction, error) { … }
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) { … }
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 { … }
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) { … }
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 { … }
func (al *Allocators) updateHealthCheckNodePort(after After, before Before, nodePortOp *portallocator.PortAllocationOperation) (bool, error) { … }
func (al *Allocators) releaseAllocatedResources(svc *api.Service) { … }
func (al *Allocators) releaseClusterIPs(service *api.Service) (released map[api.IPFamily]string, err error) { … }
func (al *Allocators) Destroy() { … }
func containsNumber(haystack []int, needle int) bool { … }
func containsNodePort(serviceNodePorts []ServiceNodePort, serviceNodePort ServiceNodePort) bool { … }
func findRequestedNodePort(port int, servicePorts []api.ServicePort) int { … }
func shouldAllocateNodePorts(service *api.Service) bool { … }
func collectServiceNodePorts(service *api.Service) []int { … }
func isMatchingPreferDualStackClusterIPFields(after After, before Before) bool { … }
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 { … }
func familyOf(ip string) api.IPFamily { … }