networking

Documentation

Index

• Variables
• func GetPSTSStrategy(psts *networkingv1alpha1.PodSubnetTopologySpread) *networkingv1alpha1.IPAllocationStrategy
• func GetPodSubnetTopologySpreadName(pod *corev1.Pod) string
• func GetReleaseStrategy(psts *networkingv1alpha1.PodSubnetTopologySpread) networkingv1alpha1.ReleaseStrategy
• func ISCustomReuseModeWEP(wep *networkingv1alpha1.WorkloadEndpoint) bool
• func IsCustomMode(psts *networkingv1alpha1.PodSubnetTopologySpread) bool
• func IsElasticMode(psts *networkingv1alpha1.PodSubnetTopologySpread) bool
• func IsEndWithNum(name string) bool
• func IsFixIPStatefulSetPodWep(wep *networkingv1alpha1.WorkloadEndpoint) bool
• func IsFixedIPMode(psts *networkingv1alpha1.PodSubnetTopologySpread) bool
• func IsManualMode(psts *networkingv1alpha1.PodSubnetTopologySpread) bool
• func IsReuseIPCustomPSTS(psts *networkingv1alpha1.PodSubnetTopologySpread) bool
• func IsSubnetTopologySpreadPod(pod *corev1.Pod) bool
• func NeedReleaseReuseModeWEP(wep *networkingv1alpha1.WorkloadEndpoint) bool
• func OwnerByPodSubnetTopologySpread(wep *networkingv1alpha1.WorkloadEndpoint, ...) bool
• func PSTSContainsAvailableSubnet(psts *networkingv1alpha1.PodSubnetTopologySpread) bool
• func PSTSMode(psts *networkingv1alpha1.PodSubnetTopologySpread) (*networkingv1alpha1.IPAllocationStrategy, bool)

Variables

var (
	AnnotationCCEPrefix = "cce.baidubce.com/"
	// annotation for PodSubnetTopologySpread
	AnnotationPodSubnetTopologySpread = AnnotationCCEPrefix + "PodSubnetTopologySpread"

	// cce defined k8s resource name
	ResourceIPForNode  = corev1.ResourceName(AnnotationCCEPrefix + "ip")
	ResourceENIForNode = corev1.ResourceName(AnnotationCCEPrefix + "eni")

	// CrossVPCEni resource name
	ResourceCrossVPCEni = corev1.ResourceName("cross-vpc-eni.cce.io/eni")

	// topodlogy key for psts
	TopologyKeyOfPod = "topology.kubernetes.io/zone"
	// AnnotationDisablePSTSPodAffinity This annotation is included on the pod, which means that the pod does not expect to use the scheduling function extended by pSTS
	AnnotationDisablePSTSPodAffinity = AnnotationCCEPrefix + "DisablePodSubnetTopologySpreadScheduler"
)

Functions

func GetPSTSStrategy

func GetPSTSStrategy(psts *networkingv1alpha1.PodSubnetTopologySpread) *networkingv1alpha1.IPAllocationStrategy

GetPSTSStrategy Recursively obtain the IP application policy

func GetPodSubnetTopologySpreadName

func GetPodSubnetTopologySpreadName(pod *corev1.Pod) string

func GetReleaseStrategy

func GetReleaseStrategy(psts *networkingv1alpha1.PodSubnetTopologySpread) networkingv1alpha1.ReleaseStrategy

GetReleaseStrategy defaults to release strategy is TTL

func ISCustomReuseModeWEP

func ISCustomReuseModeWEP(wep *networkingv1alpha1.WorkloadEndpoint) bool

IsCustomReuseModeWEP WorkloadEndpoint type is custom

func IsCustomMode

func IsCustomMode(psts *networkingv1alpha1.PodSubnetTopologySpread) bool

IsCustomMode psts type is custom

func IsElasticMode

func IsElasticMode(psts *networkingv1alpha1.PodSubnetTopologySpread) bool

func IsEndWithNum

func IsEndWithNum(name string) bool

func IsFixIPStatefulSetPodWep

func IsFixIPStatefulSetPodWep(wep *networkingv1alpha1.WorkloadEndpoint) bool

func IsFixedIPMode

func IsFixedIPMode(psts *networkingv1alpha1.PodSubnetTopologySpread) bool

func IsManualMode

func IsManualMode(psts *networkingv1alpha1.PodSubnetTopologySpread) bool

func IsReuseIPCustomPSTS

func IsReuseIPCustomPSTS(psts *networkingv1alpha1.PodSubnetTopologySpread) bool

IsReuseIPCustomPSTS whether to enable the reuse IP mode

func IsSubnetTopologySpreadPod

func IsSubnetTopologySpreadPod(pod *corev1.Pod) bool

Whether pod complies with the topology distribution of pod subnet

func NeedReleaseReuseModeWEP

func NeedReleaseReuseModeWEP(wep *networkingv1alpha1.WorkloadEndpoint) bool

func OwnerByPodSubnetTopologySpread

func OwnerByPodSubnetTopologySpread(wep *networkingv1alpha1.WorkloadEndpoint, psts *networkingv1alpha1.PodSubnetTopologySpread) bool

func PSTSContainsAvailableSubnet

func PSTSContainsAvailableSubnet(psts *networkingv1alpha1.PodSubnetTopologySpread) bool

PSTSContainsAvailableSubnet whatever length of the available subnet of psts greater than 0

func PSTSMode

func PSTSMode(psts *networkingv1alpha1.PodSubnetTopologySpread) (*networkingv1alpha1.IPAllocationStrategy, bool)

PSTSMode slecte mod of psts and return true if a available subnet in psts