INNER CODE UNIT · Go

reflectionManager

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

	reflectionManager := reflection.NewManager(dynClient, clusterID, *workers, *resyncPeriod)
	reflectionManager.Start(ctx, resources.GetResourcesToReplicate())

	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 {

View source record →