Versions in this module Expand all Collapse all v4 v4.1.0 May 1, 2019 Changes in this version + func ClusterNetworkListContains(clusterNetworks []ClusterNetwork, ipaddr net.IP) (*net.IPNet, bool) + func ClusterNetworkToString(n *networkapi.ClusterNetwork) string + func HostSubnetToString(subnet *networkapi.HostSubnet) string + func InformerFuncs(objType runtime.Object, addOrUpdateFunc InformerAddOrUpdateFunc, ...) kcache.ResourceEventHandlerFuncs + func ValidateClusterNetwork(cn *networkapi.ClusterNetwork) error + func ValidateHostSubnet(hs *networkapi.HostSubnet) error + type ClusterNetwork struct + ClusterCIDR *net.IPNet + HostSubnetLength uint32 + type DNS struct + func NewDNS(resolverConfigFile string) (*DNS, error) + func (d *DNS) Add(dns string) error + func (d *DNS) Get(dns string) dnsValue + func (d *DNS) GetMinQueryTime() (time.Time, bool) + func (d *DNS) Size() int + func (d *DNS) Update() (error, bool) + type EgressDNS struct + Updates chan EgressDNSUpdate + func NewEgressDNS() *EgressDNS + func (e *EgressDNS) Add(policy networkapi.EgressNetworkPolicy) + func (e *EgressDNS) Delete(policy networkapi.EgressNetworkPolicy) + func (e *EgressDNS) GetIPs(policy networkapi.EgressNetworkPolicy, dnsName string) []net.IP + func (e *EgressDNS) GetMinQueryTime() (time.Time, ktypes.UID, string, bool) + func (e *EgressDNS) GetNetCIDRs(policy networkapi.EgressNetworkPolicy, dnsName string) []net.IPNet + func (e *EgressDNS) Sync() + func (e *EgressDNS) Update(policyUID ktypes.UID) (error, bool) + type EgressDNSUpdate struct + Namespace string + UID ktypes.UID + type EgressIPTracker struct + func NewEgressIPTracker(watcher EgressIPWatcher) *EgressIPTracker + func (eit *EgressIPTracker) DeleteNetNamespaceEgress(vnid uint32) + func (eit *EgressIPTracker) Ping(ip string, timeout time.Duration) bool + func (eit *EgressIPTracker) ReallocateEgressIPs() map[string][]string + func (eit *EgressIPTracker) SetNodeOffline(nodeIP string, offline bool) + func (eit *EgressIPTracker) Start(hostSubnetInformer networkinformers.HostSubnetInformer, ...) + func (eit *EgressIPTracker) UpdateHostSubnetEgress(hs *networkapi.HostSubnet) + func (eit *EgressIPTracker) UpdateNetNamespaceEgress(netns *networkapi.NetNamespace) + type EgressIPWatcher interface + ClaimEgressIP func(vnid uint32, egressIP, nodeIP string) + ReleaseEgressIP func(egressIP, nodeIP string) + SetNamespaceEgressDropped func(vnid uint32) + SetNamespaceEgressNormal func(vnid uint32) + SetNamespaceEgressViaEgressIP func(vnid uint32, egressIP, nodeIP string) + UpdateEgressCIDRs func() + type InformerAddOrUpdateFunc func(interface{}, interface{}, watch.EventType) + type InformerDeleteFunc func(interface{}) + type NetworkInfo struct + ClusterNetworks []ClusterNetwork + ServiceNetwork *net.IPNet + VXLANPort uint32 + func GetNetworkInfo(networkClient networkclient.Interface) (*NetworkInfo, error) + func ParseNetworkInfo(clusterNetwork []networkapi.ClusterNetworkEntry, serviceNetwork string, ...) (*NetworkInfo, error) + func (ni *NetworkInfo) CheckClusterObjects(subnets []networkapi.HostSubnet, pods []kapi.Pod, services []kapi.Service) error + func (ni *NetworkInfo) CheckHostNetworks(hostIPNets []*net.IPNet) error + func (ni *NetworkInfo) ValidateNodeIP(nodeIP string) error v4.0.0-alpha.0 Sep 13, 2018 Other modules containing this package gopkg.in/openshift/origin.v3