func()

in rocketmq-knative/source/pkg/reconciler/eventtype/eventtype.go [51:79]

• 24 lines of code
• 7 McCabe index (conditional complexity)

func (r *Reconciler) Reconcile(ctx context.Context, owner metav1.Object, args *ReconcilerArgs) error {
	current, err := r.getEventTypes(ctx, args.Namespace, args.Labels, owner)
	if err != nil {
		return err
	}

	expected, err := r.makeEventTypes(args, owner)
	if err != nil {
		return err
	}

	toCreate, toDelete := r.computeDiff(current, expected)

	for _, eventType := range toDelete {
		err = r.Client.Delete(ctx, &eventType)
		if err != nil {
			return err
		}
	}

	for _, eventType := range toCreate {
		err = r.Client.Create(ctx, &eventType)
		if err != nil {
			return err
		}
	}

	return nil
}