Function newReconcilerTree

controllers/trace/reconciler_tree.go:124–155

(ctx context.Context, mClient client.Client, recorder record.EventRecorder, rules []OwnershipRule)

}

func newReconcilerTree(ctx context.Context, mClient client.Client, recorder record.EventRecorder, rules []OwnershipRule) (ReconcilerTree, error) {
	dag := graph.NewDAG()
	reconcilers := make(map[tracev1.ObjectType]reconcile.Reconciler)
	for _, rule := range rules {
		dag.AddVertex(rule.Primary)
		reconciler, err := newReconciler(mClient, recorder, rule.Primary)
		if err != nil {
			return nil, err
		}
		reconcilers[rule.Primary] = reconciler
		for _, resource := range rule.OwnedResources {
			dag.AddVertex(resource.Secondary)
			dag.Connect(rule.Primary, resource.Secondary)
			reconciler, err = newReconciler(mClient, recorder, resource.Secondary)
			if err != nil {
				return nil, err
			}
			reconcilers[resource.Secondary] = reconciler
		}
	}
	// DAG should be valid(one and only one root without cycle)
	if err := dag.Validate(); err != nil {
		return nil, err
	}

	return &reconcilerTree{
		ctx:         ctx,
		cli:         mClient,
		tree:        dag,
		reconcilers: reconcilers,
	}, nil
}

func newReconciler(mClient client.Client, recorder record.EventRecorder, objectType tracev1.ObjectType) (reconcile.Reconciler, error) {
	reconcilerF, ok := reconcilerFuncMap[objectType]