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(ctx context.Context, namespace, name string)
- func (c *Controller) DeletePodByUID(ctx context.Context, namespace, name, uid string)
- func (c *Controller) EnactAnyPodCleanup(ctx context.Context, selector labels.Selector, pod *apiv1.Pod, ...)
- func (c *Controller) GetPod(namespace string, podName string) (*apiv1.Pod, error)
- func (c *Controller) GetPodPhaseMetrics(ctx context.Context) map[string]int64
- func (c *Controller) GetPodsByIndex(index, key string) ([]interface{}, error)
- func (c *Controller) HasSynced() func() bool
- func (c *Controller) RemoveFinalizer(ctx context.Context, namespace, name string)
- func (c *Controller) Run(ctx context.Context, workers int)
- func (c *Controller) TerminateContainers(ctx context.Context, 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 ¶
type Controller struct {
// contains filtered or unexported fields
}
Controller is a controller for pods
func NewController ¶
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 ¶
func (c *Controller) DeletePod(ctx context.Context, namespace, name string)
func (*Controller) DeletePodByUID ¶
func (c *Controller) DeletePodByUID(ctx context.Context, namespace, name, uid string)
func (*Controller) EnactAnyPodCleanup ¶
func (c *Controller) EnactAnyPodCleanup( ctx context.Context, selector labels.Selector, pod *apiv1.Pod, strategy wfv1.PodGCStrategy, workflowPhase wfv1.WorkflowPhase, delay time.Duration, )
func (*Controller) GetPodPhaseMetrics ¶
func (c *Controller) GetPodPhaseMetrics(ctx context.Context) map[string]int64
GetPodPhaseMetrics obtains pod metrics
func (*Controller) GetPodsByIndex ¶
func (c *Controller) GetPodsByIndex(index, key string) ([]interface{}, error)
TODO - return []*apiv1.Pod instead, save on duplicating this
func (*Controller) HasSynced ¶
func (c *Controller) HasSynced() func() bool
func (*Controller) RemoveFinalizer ¶
func (c *Controller) RemoveFinalizer(ctx context.Context, namespace, name string)
func (*Controller) Run ¶
func (c *Controller) Run(ctx context.Context, workers int)
Run runs the pod controller
func (*Controller) TerminateContainers ¶
func (c *Controller) TerminateContainers(ctx context.Context, namespace, name string)
func (*Controller) TestingPodInformer ¶
func (c *Controller) TestingPodInformer() cache.SharedIndexInformer
func (*Controller) TestingProcessNextItem ¶
func (c *Controller) TestingProcessNextItem(ctx context.Context) bool
func (*Controller) TestingQueueNumRequeues ¶
func (c *Controller) TestingQueueNumRequeues(key string) int
Source Files
Click to show internal directories.
Click to hide internal directories.