Documentation
¶
Overview ¶
Package pod implements pod life cycle management
Package pod reconciles pods and takes care of gc events ¶
Package pod reconciles pods and takes care of gc events
Index ¶
- type Controller
- func (c *Controller) DeletePod(namespace, name string)
- func (c *Controller) EnactAnyPodCleanup(selector labels.Selector, pod *apiv1.Pod, strategy wfv1.PodGCStrategy, ...)
- func (c *Controller) GetPod(namespace string, podName string) (*apiv1.Pod, error)
- func (c *Controller) GetPodPhaseMetrics() map[string]int64
- func (c *Controller) GetPodsByIndex(index, key string) ([]interface{}, error)
- func (c *Controller) HasSynced() func() bool
- func (c *Controller) RemoveFinalizer(namespace, name string)
- func (c *Controller) Run(ctx context.Context, workers int)
- func (c *Controller) TerminateContainers(namespace, name string)
- func (c *Controller) TestingPodInformer() cache.SharedIndexInformer
- func (c *Controller) TestingProcessNextItem(ctx context.Context) bool
- func (c *Controller) TestingQueueNumRequeues(key string) int
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Controller ¶ added in v3.6.5
type Controller struct {
// contains filtered or unexported fields
}
Controller is a controller for pods
func NewController ¶ added in v3.6.5
func NewController(ctx context.Context, config *argoConfig.Config, restConfig *rest.Config, namespace string, clientSet kubernetes.Interface, wfInformer cache.SharedIndexInformer, metrics *metrics.Metrics, callback podEventCallback) *Controller
NewController creates a pod controller
func (*Controller) DeletePod ¶ added in v3.6.5
func (c *Controller) DeletePod(namespace, name string)
func (*Controller) EnactAnyPodCleanup ¶ added in v3.6.5
func (c *Controller) EnactAnyPodCleanup( selector labels.Selector, pod *apiv1.Pod, strategy wfv1.PodGCStrategy, workflowPhase wfv1.WorkflowPhase, delay time.Duration, )
func (*Controller) GetPodPhaseMetrics ¶ added in v3.6.5
func (c *Controller) GetPodPhaseMetrics() map[string]int64
GetPodPhaseMetrics obtains pod metrics
func (*Controller) GetPodsByIndex ¶ added in v3.6.5
func (c *Controller) GetPodsByIndex(index, key string) ([]interface{}, error)
TODO - return []*apiv1.Pod instead, save on duplicating this
func (*Controller) HasSynced ¶ added in v3.6.5
func (c *Controller) HasSynced() func() bool
func (*Controller) RemoveFinalizer ¶ added in v3.6.5
func (c *Controller) RemoveFinalizer(namespace, name string)
func (*Controller) Run ¶ added in v3.6.5
func (c *Controller) Run(ctx context.Context, workers int)
Run runs the pod controller
func (*Controller) TerminateContainers ¶ added in v3.6.5
func (c *Controller) TerminateContainers(namespace, name string)
func (*Controller) TestingPodInformer ¶ added in v3.6.5
func (c *Controller) TestingPodInformer() cache.SharedIndexInformer
func (*Controller) TestingProcessNextItem ¶ added in v3.6.5
func (c *Controller) TestingProcessNextItem(ctx context.Context) bool
func (*Controller) TestingQueueNumRequeues ¶ added in v3.6.5
func (c *Controller) TestingQueueNumRequeues(key string) int
Source Files
Click to show internal directories.
Click to hide internal directories.