INNER CODE UNIT · Go

reflectors

liqotech/liqo · cmd/crd-replicator/main.go:93

	reflectors := make(map[liqov1beta1.ClusterID]*reflection.Reflector)
	d := &crdreplicator.Controller{
		Scheme:    mgr.GetScheme(),
		Client:    mgr.GetClient(),
		ClusterID: clusterID,

		RegisteredResources: resources.GetResourcesToReplicate(),
		ReflectionManager:   reflectionManager,
		Reflectors:          reflectors,

		IdentityReader: identitymanager.NewCertificateIdentityReader(ctx,
			mgr.GetClient(), k8sClient, mgr.GetConfig(),
			clusterID, namespaceManager),
	}
	if err = d.SetupWithManager(mgr); err != nil {
		klog.Error(err, "unable to setup the crdReplicator controller")
		os.Exit(1)
	}

View source record →