FieldSelector: strings.Join(fieldSelectors, ","),
	})
	c.queue = controllers.NewQueue("repair pods",
		controllers.WithReconciler(c.Reconcile),
		controllers.WithMaxAttempts(5))
	c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject))

	return c, nil
}

func (c *Controller) Run(stop <-chan struct{}) {
	kube.WaitForCacheSync("repair controller", stop, c.pods.HasSynced)
	c.queue.Run(stop)
	c.pods.ShutdownHandlers()

Davanum Srinivas <******@****.***> 1652185809 -0400

    service.istio.io/canonical-name: helloworld-helloworld-helloworld-helloworld-helloworld-hellowo
    service.istio.io/canonical-revision: latest
  name: helloworld-helloworld
  ownerReferences:
  - apiVersion: foo/v1
    controller: true
    kind: Bar
    name: helloworld-helloworld-helloworld-helloworld-helloworld-hellowo-ld
    uid: 12345678-1234-1234-1234-123456789012
spec:
  containers:
  - image: fake.docker.io/google-samples/hello-go-gke:1.0

See the License for the specific language governing permissions and
limitations under the License.
*/

// Package controller contains code for controllers (like the replication
// controller).

		client:                   opts.Client,
		mcsSupported:             true,
	}
	c.queue = controllers.NewQueue("auto export",
		controllers.WithReconciler(c.Reconcile),
		controllers.WithMaxAttempts(5))

	c.services = kclient.NewFiltered[*v1.Service](opts.Client, kubetypes.Filter{ObjectFilter: opts.Client.ObjectFilter()})

	// Only handle add. The controller only acts on parts of the service

Davanum Srinivas <******@****.***> 1652185809 -0400

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/tools/cache"

	"istio.io/istio/pkg/kube"
	"istio.io/istio/pkg/kube/controllers"
	"istio.io/istio/pkg/queue"
	"istio.io/istio/pkg/test/framework/components/echo"
)

var _ cache.Controller = &podController{}

type podHandler func(pod *corev1.Pod) error

type podHandlers struct {
	added   podHandler
	updated podHandler
	deleted podHandler

```text
name                  time/op
Controllers/krt-8     13.4ms ±23%
Controllers/legacy-8  11.4ms ± 6%

name                  alloc/op
Controllers/krt-8     15.2MB ± 0%
Controllers/legacy-8  12.9MB ± 0%
```

### Future work

#### Object optimizations

One important aspect of `krt` is its ability to automatically detect if objects have changed, and only trigger dependencies if so.

// components.  This includes replication controllers, service endpoints and
// nodes.
package app

import (
	"context"

	"k8s.io/controller-manager/controller"
	"k8s.io/kubernetes/cmd/kube-controller-manager/names"
	endpointslicecontroller "k8s.io/kubernetes/pkg/controller/endpointslice"
	endpointslicemirroringcontroller "k8s.io/kubernetes/pkg/controller/endpointslicemirroring"
)

	}

	t0 := time.Now()
	cl.logger.Infof("Starting Pilot K8S CRD controller")

	if !kube.WaitForCacheSync("crdclient", stop, cl.informerSynced) {
		cl.logger.Errorf("Failed to sync Pilot K8S CRD controller cache")
		return
	}
	cl.logger.Infof("Pilot K8S CRD controller synced in %v", time.Since(t0))
	cl.queue.Run(stop)
	cl.logger.Infof("controller terminated")
}

func (cl *Client) informerSynced() bool {