subnetset

package
v1.0.2 Latest Latest
Warning

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

Go to latest
Published: Dec 19, 2023 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ResultNormal            = common.ResultNormal
	ResultRequeue           = common.ResultRequeue
	ResultRequeueAfter5mins = common.ResultRequeueAfter5mins
	MetricResTypeSubnetSet  = common.MetricResTypeSubnetSet
)
View Source
var PredicateFuncsNs = predicate.Funcs{
	CreateFunc: func(e event.CreateEvent) bool {
		return false
	},
	UpdateFunc: func(e event.UpdateEvent) bool {
		oldObj := e.ObjectOld.(*v1.Namespace)
		newObj := e.ObjectNew.(*v1.Namespace)
		log.V(1).Info("receive namespace update event", "name", oldObj.Name)
		if reflect.DeepEqual(oldObj.ObjectMeta.Labels, newObj.ObjectMeta.Labels) {
			log.Info("label of namespace is not changed, ignore it", "name", oldObj.Name)
			return false
		}
		return true
	},
	DeleteFunc: func(e event.DeleteEvent) bool {
		return false
	},
}
View Source
var VPCPredicate = predicate.Funcs{
	CreateFunc: func(e event.CreateEvent) bool {
		return true
	},
	UpdateFunc: func(e event.UpdateEvent) bool {
		return false
	},
	DeleteFunc: func(e event.DeleteEvent) bool {
		return true
	},
	GenericFunc: func(genericEvent event.GenericEvent) bool {
		return false
	},
}

Functions

func StartSubnetSetController

func StartSubnetSetController(mgr ctrl.Manager, commonService servicecommon.Service) error

Types

type EnqueueRequestForNamespace

type EnqueueRequestForNamespace struct {
	Client client.Client
}

func (*EnqueueRequestForNamespace) Create

func (*EnqueueRequestForNamespace) Delete

func (*EnqueueRequestForNamespace) Generic

func (*EnqueueRequestForNamespace) Update

type SubnetSetReconciler

type SubnetSetReconciler struct {
	Client  client.Client
	Scheme  *apimachineryruntime.Scheme
	Service *subnet.SubnetService
}

SubnetSetReconciler reconciles a SubnetSet object

func (*SubnetSetReconciler) DeleteSubnetForSubnetSet

func (r *SubnetSetReconciler) DeleteSubnetForSubnetSet(obj v1alpha1.SubnetSet, updataStatus bool) error

func (*SubnetSetReconciler) GarbageCollector

func (r *SubnetSetReconciler) GarbageCollector(cancel chan bool, timeout time.Duration)

GarbageCollector collect Subnet which there is no port attached on it. cancel is used to break the loop during UT

func (*SubnetSetReconciler) Reconcile

func (r *SubnetSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*SubnetSetReconciler) Start

func (r *SubnetSetReconciler) Start(mgr ctrl.Manager) error

Start setup manager

type VPCHandler

type VPCHandler struct {
	Client client.Client
}

func (*VPCHandler) Create

func (*VPCHandler) Delete

func (*VPCHandler) Generic

func (*VPCHandler) Update

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL