fixed go linter errors

pkg/channel/jetstream/controller/controller.go

@@ -21,6 +21,8 @@ import (
 	"fmt"
 	"time"
 
+	"k8s.io/utils/ptr"
+
 	"knative.dev/pkg/configmap"
 	"knative.dev/pkg/reconciler"
 
@@ -32,8 +34,6 @@ import (
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/util/wait"
 	"k8s.io/client-go/tools/cache"
-	"k8s.io/utils/pointer"
-
 	kubeclient "knative.dev/pkg/client/injection/kube/client"
 	deploymentinformer "knative.dev/pkg/client/injection/kube/informers/apps/v1/deployment"
 	endpointsinformer "knative.dev/pkg/client/injection/kube/informers/core/v1/endpoints"
@@ -146,9 +146,9 @@ func getControllerOwnerRef(ctx context.Context) (*metav1.OwnerReference, error)
 	ownerRef := metav1.OwnerReference{
 		APIVersion: "rbac.authorization.k8s.io/v1",
 		Kind:       "ClusterRole",
-		Controller: pointer.BoolPtr(true),
+		Controller: ptr.To(true),
 	}
-	err := wait.PollImmediate(interval, timeout, func() (bool, error) {
+	err := wait.PollUntilContextTimeout(ctx, interval, timeout, true, func(ctx context.Context) (done bool, err error) {
 		k8sClient := kubeclient.Get(ctx)
 		clusterRole, err := k8sClient.RbacV1().ClusterRoles().Get(ctx, jetstream.ControllerName, metav1.GetOptions{})
 		if err != nil {
@@ -158,6 +158,7 @@ func getControllerOwnerRef(ctx context.Context) (*metav1.OwnerReference, error)
 		ownerRef.UID = clusterRole.UID
 		return true, nil
 	})
+
 	if err != nil {
 		return nil, err
 	}

pkg/channel/jetstream/controller/reconciler.go

@@ -20,11 +20,12 @@ import (
 	"context"
 	"fmt"
 
+	"knative.dev/pkg/ptr"
+
 	"github.com/google/go-cmp/cmp"
 	"go.uber.org/zap"
 	"k8s.io/apimachinery/pkg/api/equality"
 	"k8s.io/apimachinery/pkg/labels"
-	"k8s.io/utils/pointer"
 	"knative.dev/eventing/pkg/apis/eventing"
 	"knative.dev/pkg/apis"
 	"knative.dev/pkg/controller"
@@ -64,13 +65,8 @@ const (
 	dispatcherServiceCreated        = "DispatcherServiceCreated"
 	dispatcherServiceFailed         = "DispatcherServiceFailed"
 	dispatcherServiceUpdated        = "DispatcherServiceUpdated"
-	natsJetStreamChannelReconciled  = "NatsJetStreamChannelReconciled"
 )
 
-func newReconciledNormal(namespace, name string) reconciler.Event {
-	return reconciler.NewEvent(corev1.EventTypeNormal, natsJetStreamChannelReconciled, "NatsJetStreamChannel reconciled: \"%s/%s\"", namespace, name)
-}
-
 func newDeploymentWarn(err error) reconciler.Event {
 	return reconciler.NewEvent(corev1.EventTypeWarning, dispatcherDeploymentFailed, "Reconciling dispatcher Deployment failed with: %s", err)
 }
@@ -500,7 +496,7 @@ func (r *Reconciler) cleanDispatcherResources(ctx context.Context, namespace str
 	}
 
 	toUpdate := deployment.DeepCopy()
-	toUpdate.Spec.Replicas = pointer.Int32(0)
+	toUpdate.Spec.Replicas = ptr.Int32(0)
 
 	_, err = r.kubeClientSet.AppsV1().Deployments(namespace).Update(ctx, toUpdate, metav1.UpdateOptions{})
 	if err != nil {

pkg/channel/jetstream/dispatcher/controller.go

@@ -56,7 +56,7 @@ func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl
 		logger.Panicf("unable to process required environment variables: %v", err)
 	}
 
-	err := tracing.SetupDynamicPublishing(logger, cmw, "jetstream-ch-dispatcher", "config-tracing")
+	_, err := tracing.SetupPublishingWithDynamicConfig(logger, cmw, "jetstream-ch-dispatcher", "config-tracing")
 	if err != nil {
 		logger.Fatalw("failed to setup tracing", zap.Error(err))
 	}

pkg/common/error/subscriber.go

@@ -33,7 +33,7 @@ func (e *SubscriberErrors) AddError(uid string, err error) {
 }
 
 func (e SubscriberErrors) Error() string {
-	if e == nil || len(e) == 0 {
+	if len(e) == 0 {
 		return ""
 	}