subnet

Documentation

Index

• Variables
• func StartSubnetController(mgr ctrl.Manager, subnetService *subnet.SubnetService, ...) error
• type EnqueueRequestForNamespace
  • func (e *EnqueueRequestForNamespace) Create(_ context.Context, _ event.CreateEvent, _ workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForNamespace) Delete(_ context.Context, _ event.DeleteEvent, _ workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForNamespace) Generic(_ context.Context, _ event.GenericEvent, _ workqueue.RateLimitingInterface)
  • func (e *EnqueueRequestForNamespace) Update(_ context.Context, updateEvent event.UpdateEvent, ...)
• type SubnetReconciler
  • func (r *SubnetReconciler) DeleteSubnet(obj v1alpha1.Subnet) error
  • func (r *SubnetReconciler) GarbageCollector(cancel chan bool, timeout time.Duration)
  • func (r *SubnetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *SubnetReconciler) Start(mgr ctrl.Manager) error

Variables

var (
	ResultNormal            = common.ResultNormal
	ResultRequeue           = common.ResultRequeue
	ResultRequeueAfter5mins = common.ResultRequeueAfter5mins
	ResultRequeueAfter10sec = common.ResultRequeueAfter10sec
	MetricResTypeSubnet     = common.MetricResTypeSubnet
)

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("labels of namespace are not changed", "name", oldObj.Name)
			return false
		}
		return true
	},
	DeleteFunc: func(e event.DeleteEvent) bool {
		return false
	},
}

Functions

func StartSubnetController

func StartSubnetController(mgr ctrl.Manager, subnetService *subnet.SubnetService, subnetPortService servicecommon.SubnetPortServiceProvider, vpcService servicecommon.VPCServiceProvider) error

Types

type EnqueueRequestForNamespace

type EnqueueRequestForNamespace struct {
	Client client.Client
}

func (*EnqueueRequestForNamespace) Create

func (e *EnqueueRequestForNamespace) Create(_ context.Context, _ event.CreateEvent, _ workqueue.RateLimitingInterface)

func (*EnqueueRequestForNamespace) Delete

func (e *EnqueueRequestForNamespace) Delete(_ context.Context, _ event.DeleteEvent, _ workqueue.RateLimitingInterface)

func (*EnqueueRequestForNamespace) Generic

func (e *EnqueueRequestForNamespace) Generic(_ context.Context, _ event.GenericEvent, _ workqueue.RateLimitingInterface)

func (*EnqueueRequestForNamespace) Update

func (e *EnqueueRequestForNamespace) Update(_ context.Context, updateEvent event.UpdateEvent, l workqueue.RateLimitingInterface)

type SubnetReconciler

type SubnetReconciler struct {
	Client            client.Client
	Scheme            *apimachineryruntime.Scheme
	SubnetService     *subnet.SubnetService
	SubnetPortService servicecommon.SubnetPortServiceProvider
	VPCService        servicecommon.VPCServiceProvider
	Recorder          record.EventRecorder
}

SubnetReconciler reconciles a SubnetSet object

func (*SubnetReconciler) DeleteSubnet

func (r *SubnetReconciler) DeleteSubnet(obj v1alpha1.Subnet) error

func (*SubnetReconciler) GarbageCollector

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

func (*SubnetReconciler) Reconcile

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

func (*SubnetReconciler) Start

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

Start setup manager