common

package
v3.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 9, 2018 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Overview

Package common contains the OpenShift SDN code that is shared between master, node, and proxy

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ClusterNetworkListContains 

func ClusterNetworkListContains(clusterNetworks []ClusterNetwork, ipaddr net.IP) (*net.IPNet, bool)

func ClusterNetworkToString 

func ClusterNetworkToString(n *networkapi.ClusterNetwork) string

func HostSubnetToString 

func HostSubnetToString(subnet *networkapi.HostSubnet) string

func InformerFuncs added in v3.10.0 

func InformerFuncs(objType runtime.Object, addOrUpdateFunc InformerAddOrUpdateFunc, deleteFunc InformerDeleteFunc) kcache.ResourceEventHandlerFuncs

Types

type ClusterNetwork 

type ClusterNetwork struct {
	ClusterCIDR      *net.IPNet
	HostSubnetLength uint32
}

type DNS 

type DNS struct {
	// contains filtered or unexported fields
}

func NewDNS 

func NewDNS(resolverConfigFile string) (*DNS, error)

func (*DNS) Add 

func (d *DNS) Add(dns string) error

func (*DNS) Get 

func (d *DNS) Get(dns string) dnsValue

func (*DNS) GetMinQueryTime 

func (d *DNS) GetMinQueryTime() (time.Time, bool)

func (*DNS) Size 

func (d *DNS) Size() int

func (*DNS) Update 

func (d *DNS) Update() (error, bool)

type EgressDNS 

type EgressDNS struct {

	// Report changes when there are dns updates
	Updates chan EgressDNSUpdate
	// contains filtered or unexported fields
}

func NewEgressDNS 

func NewEgressDNS() *EgressDNS

func (*EgressDNS) Add 

func (e *EgressDNS) Add(policy networkapi.EgressNetworkPolicy)

func (*EgressDNS) Delete 

func (e *EgressDNS) Delete(policy networkapi.EgressNetworkPolicy)

func (*EgressDNS) GetIPs 

func (e *EgressDNS) GetIPs(policy networkapi.EgressNetworkPolicy, dnsName string) []net.IP

func (*EgressDNS) GetMinQueryTime 

func (e *EgressDNS) GetMinQueryTime() (time.Time, ktypes.UID, string, bool)

func (*EgressDNS) GetNetCIDRs 

func (e *EgressDNS) GetNetCIDRs(policy networkapi.EgressNetworkPolicy, dnsName string) []net.IPNet

func (*EgressDNS) Sync 

func (e *EgressDNS) Sync()

func (*EgressDNS) Update 

func (e *EgressDNS) Update(policyUID ktypes.UID) (error, bool)

type EgressDNSUpdate 

type EgressDNSUpdate struct {
	UID       ktypes.UID
	Namespace string
}

type EgressIPTracker added in v3.11.0 

type EgressIPTracker struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewEgressIPTracker added in v3.11.0 

func NewEgressIPTracker(watcher EgressIPWatcher) *EgressIPTracker

func (*EgressIPTracker) DeleteNetNamespaceEgress added in v3.11.0 

func (eit *EgressIPTracker) DeleteNetNamespaceEgress(vnid uint32)

func (*EgressIPTracker) Ping added in v3.11.0 

func (eit *EgressIPTracker) Ping(ip string, timeout time.Duration) bool

Ping a node and return whether or not we think it is online. We do this by trying to open a TCP connection to the "discard" service (port 9); if the node is offline, the attempt will either time out with no response, or else return "no route to host" (and we will return false). If the node is online then we presumably will get a "connection refused" error; but the code below assumes that anything other than timeout or "no route" indicates that the node is online.

func (*EgressIPTracker) ReallocateEgressIPs added in v3.11.0 

func (eit *EgressIPTracker) ReallocateEgressIPs() map[string][]string

ReallocateEgressIPs returns a map from Node name to array-of-Egress-IP for all auto-allocated egress IPs

func (*EgressIPTracker) SetNodeOffline added in v3.11.0 

func (eit *EgressIPTracker) SetNodeOffline(nodeIP string, offline bool)

func (*EgressIPTracker) Start added in v3.11.0 

func (eit *EgressIPTracker) Start(hostSubnetInformer networkinformers.HostSubnetInformer, netNamespaceInformer networkinformers.NetNamespaceInformer)

func (*EgressIPTracker) UpdateHostSubnetEgress added in v3.11.0 

func (eit *EgressIPTracker) UpdateHostSubnetEgress(hs *networkapi.HostSubnet)

func (*EgressIPTracker) UpdateNetNamespaceEgress added in v3.11.0 

func (eit *EgressIPTracker) UpdateNetNamespaceEgress(netns *networkapi.NetNamespace)

type EgressIPWatcher added in v3.11.0 

type EgressIPWatcher interface {
	ClaimEgressIP(vnid uint32, egressIP, nodeIP string)
	ReleaseEgressIP(egressIP, nodeIP string)

	SetNamespaceEgressNormal(vnid uint32)
	SetNamespaceEgressDropped(vnid uint32)
	SetNamespaceEgressViaEgressIP(vnid uint32, egressIP, nodeIP string)

	UpdateEgressCIDRs()
}

type InformerAddOrUpdateFunc added in v3.10.0 

type InformerAddOrUpdateFunc func(interface{}, interface{}, watch.EventType)

type InformerDeleteFunc added in v3.10.0 

type InformerDeleteFunc func(interface{})

type NetworkInfo 

type NetworkInfo struct {
	ClusterNetworks []ClusterNetwork
	ServiceNetwork  *net.IPNet
	VXLANPort       uint32
}

func GetNetworkInfo 

func GetNetworkInfo(networkClient networkclient.Interface) (*NetworkInfo, error)

func ParseNetworkInfo 

func ParseNetworkInfo(clusterNetwork []networkapi.ClusterNetworkEntry, serviceNetwork string, vxlanPort *uint32) (*NetworkInfo, error)

func (*NetworkInfo) CheckClusterObjects 

func (ni *NetworkInfo) CheckClusterObjects(subnets []networkapi.HostSubnet, pods []kapi.Pod, services []kapi.Service) error

func (*NetworkInfo) CheckHostNetworks 

func (ni *NetworkInfo) CheckHostNetworks(hostIPNets []*net.IPNet) error

func (*NetworkInfo) ValidateNodeIP 

func (ni *NetworkInfo) ValidateNodeIP(nodeIP string) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.