pod

Documentation

Index

• Constants
• func ClusterMetaNamespaceKeyFunc(pod *v1.Pod) (string, error)
• type PodController
  • func NewPodController(client kubernetes.Interface, podInformer coreinformers.PodInformer, ...) (*PodController, error)
  • func (ctrl *PodController) Run(ctx context.Context, workers int)

Constants

const (

	// name of the pod controller finalizer
	PodControllerFinalizerName = "pod.firefly.io/finalizer"
)

Functions

func ClusterMetaNamespaceKeyFunc

func ClusterMetaNamespaceKeyFunc(pod *v1.Pod) (string, error)

Types

type PodController

type PodController struct {
	// contains filtered or unexported fields
}

func NewPodController

func NewPodController(
	client kubernetes.Interface,
	podInformer coreinformers.PodInformer,
	clusterInformer clusterinformers.ClusterInformer,
	workerPodsInformer coreinformers.PodInformer,
	resyncPeriod time.Duration) (*PodController, error)

NewPodController returns a new *Controller.

func (*PodController) Run

func (ctrl *PodController) Run(ctx context.Context, workers int)

Run will not return until stopCh is closed. workers determines how many cluster will be handled in parallel.