common

Documentation

Index

• Constants
• Variables
• func AllocateSubnetFromSubnetSet(subnetSet *v1alpha1.SubnetSet, vpcService servicecommon.VPCServiceProvider, ...) (string, error)
• func GetDefaultSubnetSet(client k8sclient.Client, ctx context.Context, namespace string, ...) (*v1alpha1.SubnetSet, error)
• func GetVirtualMachineNameForSubnetPort(subnetPort *v1alpha1.SubnetPort) (string, error)
• func NodeIsMaster(node *v1.Node) bool
• func NumReconcile() int

Constants

const (
	MetricResTypeSecurityPolicy    = "securitypolicy"
	MetricResTypeNetworkPolicy     = "networkpolicy"
	MetricResTypeIPPool            = "ippool"
	MetricResTypeNSXServiceAccount = "nsxserviceaccount"
	MetricResTypeSubnetPort        = "subnetport"
	MetricResTypeStaticRoute       = "staticroute"
	MetricResTypeSubnet            = "subnet"
	MetricResTypeSubnetSet         = "subnetset"
	MetricResTypeVPC               = "vpc"
	MetricResTypeNamespace         = "namespace"
	MetricResTypePod               = "pod"
	MetricResTypeNode              = "node"
	MetricResTypeServiceLb         = "servicelb"
	MaxConcurrentReconciles        = 8

	LabelK8sMasterRole  = "node-role.kubernetes.io/master"
	LabelK8sControlRole = "node-role.kubernetes.io/control-plane"
)

const (
	ReasonSuccessfulDelete = "SuccessfulDelete"
	ReasonSuccessfulUpdate = "SuccessfulUpdate"
	ReasonFailDelete       = "FailDelete"
	ReasonFailUpdate       = "FailUpdate"
)

Variables

var (
	ResultNormal  = ctrl.Result{}
	ResultRequeue = ctrl.Result{Requeue: true}
	// for k8s events that need to retry in short loop, eg: namespace creation
	ResultRequeueAfter10sec = ctrl.Result{Requeue: true, RequeueAfter: 10 * time.Second}
	// for unstable event, eg: failed to k8s resources when reconciling, may due to k8s unstable
	ResultRequeueAfter5mins = ctrl.Result{Requeue: true, RequeueAfter: 5 * time.Minute}
)

Functions

func AllocateSubnetFromSubnetSet

func AllocateSubnetFromSubnetSet(subnetSet *v1alpha1.SubnetSet, vpcService servicecommon.VPCServiceProvider, subnetService servicecommon.SubnetServiceProvider, subnetPortService servicecommon.SubnetPortServiceProvider) (string, error)

func GetDefaultSubnetSet

func GetDefaultSubnetSet(client k8sclient.Client, ctx context.Context, namespace string, resourceType string) (*v1alpha1.SubnetSet, error)

func GetVirtualMachineNameForSubnetPort

func GetVirtualMachineNameForSubnetPort(subnetPort *v1alpha1.SubnetPort) (string, error)

func NodeIsMaster

func NodeIsMaster(node *v1.Node) bool

func NumReconcile

func NumReconcile() int

NumReconcile now uses the fix number of concurrency