pod

Documentation

Index

• Variables
• func StartPodController(mgr ctrl.Manager, subnetPortService *subnetport.SubnetPortService, ...)
• type PodReconciler
  • func (r *PodReconciler) GarbageCollector(cancel chan bool, timeout time.Duration)
  • func (r *PodReconciler) GetNodeByName(nodeName string) (*model.HostTransportNode, error)
  • func (r *PodReconciler) GetSubnetPathForPod(ctx context.Context, pod *v1.Pod) (string, error)
  • func (r *PodReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PodReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *PodReconciler) Start(mgr ctrl.Manager) error

Variables

var (
	MetricResTypePod = common.MetricResTypePod
)

Functions

func StartPodController

func StartPodController(mgr ctrl.Manager, subnetPortService *subnetport.SubnetPortService, subnetService servicecommon.SubnetServiceProvider, vpcService servicecommon.VPCServiceProvider, nodeService servicecommon.NodeServiceReader)

Types

type PodReconciler

type PodReconciler struct {
	client.Client
	Scheme *apimachineryruntime.Scheme

	SubnetPortService *subnetport.SubnetPortService
	SubnetService     servicecommon.SubnetServiceProvider
	VPCService        servicecommon.VPCServiceProvider
	NodeServiceReader servicecommon.NodeServiceReader
	Recorder          record.EventRecorder
}

PodReconciler reconciles a Pod object

func (*PodReconciler) GarbageCollector

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

GarbageCollector collect Pod which has been removed from crd. cancel is used to break the loop during UT

func (*PodReconciler) GetNodeByName

func (r *PodReconciler) GetNodeByName(nodeName string) (*model.HostTransportNode, error)

func (*PodReconciler) GetSubnetPathForPod

func (r *PodReconciler) GetSubnetPathForPod(ctx context.Context, pod *v1.Pod) (string, error)

func (*PodReconciler) Reconcile

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

func (*PodReconciler) SetupWithManager

func (r *PodReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

func (*PodReconciler) Start

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

Start setup manager and launch GC