pod

Documentation

Index

• Variables
• func StartPodController(mgr ctrl.Manager, commonService servicecommon.Service)
• type PodReconciler
  • func (r *PodReconciler) GarbageCollector(cancel chan bool, timeout time.Duration)
  • 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, commonService servicecommon.Service)

Types

type PodReconciler

type PodReconciler struct {
	client.Client
	Scheme  *apimachineryruntime.Scheme
	Service *subnetport.SubnetPortService
}

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) 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