Function NewPodsHandler

backend/handlers/workloads/pods/pods.go:63–98

(ctx context.Context, config, cluster string, container container.Container)

}

func NewPodsHandler(ctx context.Context, config, cluster string, container container.Container) *PodsHandler {
	informer := container.SharedInformerFactory(config, cluster).Core().V1().Pods().Informer()
	informer.SetTransform(helpers.StripUnusedFields)
	clientSet := container.ClientSet(config, cluster)

	handler := &PodsHandler{
		BaseHandler: base.BaseHandler{
			Kind:             "Pod",
			Container:        container,
			RestClient:       clientSet.CoreV1().RESTClient(),
			Informer:         informer,
			QueryConfig:      config,
			QueryCluster:     cluster,
			InformerCacheKey: fmt.Sprintf("%s-%s-podInformer", config, cluster),
			TransformFunc:    transformItems,
		},
		restConfig:        container.RestConfig(config, cluster),
		clientSet:         clientSet,
		replicasetHandler: replicaset.NewReplicaSetHandler(ctx, config, cluster, container),
	}

	additionalEvents := []map[string]func(){
		{
			"pods-deployments": func() {
				go handler.DeploymentsPods()
				go handler.NodePods()
			},
		},
	}

	cache := base.ResourceEventHandler[*v1.Pod](&handler.BaseHandler, additionalEvents...)
	handler.BaseHandler.StartInformer(cache)
	handler.BaseHandler.WaitForSync(ctx)

	return handler
}

func transformItems(items []any, b *base.BaseHandler) ([]byte, error) {
	var list []v1.Pod