fix deprecated x/net/context

Author: jotak

pkg/pipeline/encode/encode_kafka.go

@@ -18,6 +18,7 @@
 package encode
 
 import (
+	"context"
 	"encoding/json"
 
 	"github.com/netobserv/flowlogs-pipeline/pkg/api"
@@ -27,7 +28,6 @@ import (
 	"github.com/prometheus/client_golang/prometheus"
 	kafkago "github.com/segmentio/kafka-go"
 	log "github.com/sirupsen/logrus"
-	"golang.org/x/net/context"
 )
 
 type kafkaWriteMessage interface {

pkg/pipeline/encode/encode_kafka_test.go

@@ -18,6 +18,7 @@
 package encode
 
 import (
+	"context"
 	"encoding/json"
 	"testing"
 
@@ -28,7 +29,6 @@ import (
 	kafkago "github.com/segmentio/kafka-go"
 	"github.com/stretchr/testify/mock"
 	"github.com/stretchr/testify/require"
-	"golang.org/x/net/context"
 )
 
 const testKafkaConfig = `---

pkg/pipeline/encode/encode_s3.go

@@ -19,6 +19,7 @@ package encode
 
 import (
 	"bytes"
+	"context"
 	"encoding/json"
 	"fmt"
 	"sync"
@@ -32,7 +33,6 @@ import (
 	"github.com/netobserv/flowlogs-pipeline/pkg/pipeline/utils"
 	"github.com/prometheus/client_golang/prometheus"
 	log "github.com/sirupsen/logrus"
-	"golang.org/x/net/context"
 )
 
 const (

pkg/pipeline/ingest/ingest_kafka.go

@@ -18,6 +18,7 @@
 package ingest
 
 import (
+	"context"
 	"time"
 
 	"github.com/netobserv/flowlogs-pipeline/pkg/api"
@@ -28,7 +29,6 @@ import (
 	"github.com/netobserv/flowlogs-pipeline/pkg/pipeline/utils"
 	kafkago "github.com/segmentio/kafka-go"
 	"github.com/sirupsen/logrus"
-	"golang.org/x/net/context"
 )
 
 var klog = logrus.WithField("component", "ingest.Kafka")