Function NewIngressHandler

backend/handlers/network/ingresses/ingresses.go:42–62

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

}

func NewIngressHandler(ctx context.Context, config, cluster string, container container.Container) *IngressHandler {
	informer := container.SharedInformerFactory(config, cluster).Networking().V1().Ingresses().Informer()
	informer.SetTransform(helpers.StripUnusedFields)

	handler := &IngressHandler{
		BaseHandler: base.BaseHandler{
			Kind:             "Ingress",
			Container:        container,
			Informer:         informer,
			RestClient:       container.ClientSet(config, cluster).NetworkingV1().RESTClient(),
			QueryConfig:      config,
			QueryCluster:     cluster,
			InformerCacheKey: fmt.Sprintf("%s-%s-IngressInformer", config, cluster),
			TransformFunc:    transformItems,
		},
	}
	cache := base.ResourceEventHandler[*networkingV1.Ingress](&handler.BaseHandler)
	handler.BaseHandler.StartInformer(cache)
	handler.BaseHandler.WaitForSync(ctx)
	return handler
}

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