Reconciler Implementation and Design

    1. Update the and initialize the Status conditions as defined in samplesource_lifecycle.go and samplesource_types.go:

    2. Follow the later Reconcile/Create the Receive Adapter procedure.

    3. If successful, update the Status and MarkDeployed:

      1. src.Status.PropagateDeploymentAvailability(ra)

    4. Follow the later procedure for the receive adapter targeting the sink.

    5. MarkSink with the result:

      1. src.Status.MarkSink(sb.Status.SinkURI)

    6. Return a new reconciler event stating that the process is done:

      1. return pkgreconciler.NewEvent(corev1.EventTypeNormal, "SampleSourceReconciled", "SampleSource reconciled: \"%s/%s\"", namespace, name)

    Verify the specified kubernetes resources are valid, and update the Status accordingly

    Assemble the ReceiveAdapterArgs

    NB The exact arguments may change based on functional requirements Create the underlying deployment from the arguments provided, matching pod templates, labels, owner references, etc as needed to fill out the deployment Example: pkg/reconciler/sample/resources/receive_adapter.go

    1. Otherwise, create the deployment

      1. ra, err = r.KubeClientSet.AppsV1().Deployments(namespace).Create(expected)

    2. Check if the expected vs existing spec is different, and update the deployment if required

      1. } else if r.podSpecImageSync(expected.Spec.Template.Spec, ra.Spec.Template.Spec) {
      2.     ra.Spec.Template.Spec = expected.Spec.Template.Spec
      3.     if ra, err = r.KubeClientSet.AppsV1().Deployments(namespace).Update(ra); err != nil {
      4.         return ra, err
      5.     }

    Instead of directly giving the details of the sink to the receive adapter, use a SinkBinding to bind the receive adapter with the sink.

    Steps here are almost the same with the Deployment reconciliation mentioned earlier, but it is for another resource, SinkBinding.

    1. Create a Reference for the receive adapter deployment. This deployment will be SinkBinding‘s source:

      1.     APIVersion: appsv1.SchemeGroupVersion.String(),
      2.     Kind:       "Deployment",
      3.     Namespace:  ra.Namespace,
      4.     Name:       ra.Name,
      5. }

    2. Fetch the existing SinkBinding

      1. namespace := owner.GetObjectMeta().GetNamespace()
      2. sb, err := r.EventingClientSet.SourcesV1alpha2().SinkBindings(namespace).Get(expected.Name, metav1.GetOptions{})

    3. If it doesn’t exist, create it

      1. sb, err = r.EventingClientSet.SourcesV1alpha2().SinkBindings(namespace).Create(expected)

    4. Check if the expected vs existing spec is different, and update the SinkBinding if required