From 8c99fc7720998063b8bac6da11005b5ce60a04c2 Mon Sep 17 00:00:00 2001
From: Jack Ding <7378668+jzding@users.noreply.github.com>
Date: Wed, 12 Jun 2024 14:29:52 -0400
Subject: [PATCH] remove amq (#66)

Signed-off-by: Jack Ding <jackding@gmail.com>
---
 go.mod                                                  | 2 +-
 go.sum                                                  | 4 ++--
 server.go                                               | 2 +-
 vendor/github.com/redhat-cne/sdk-go/pkg/channel/data.go | 2 +-
 vendor/github.com/redhat-cne/sdk-go/v1/pubsub/pubsub.go | 6 +++---
 vendor/modules.txt                                      | 2 +-
 6 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/go.mod b/go.mod
index d712b2b..ffb300a 100644
--- a/go.mod
+++ b/go.mod
@@ -7,7 +7,7 @@ require (
 	github.com/google/uuid v1.6.0
 	github.com/gorilla/mux v1.8.0
 	github.com/prometheus/client_golang v1.14.0
-	github.com/redhat-cne/sdk-go v1.0.0
+	github.com/redhat-cne/sdk-go v1.0.1-0.20240612145917-11968a1cd0b5
 	github.com/sirupsen/logrus v1.8.1
 	github.com/stretchr/testify v1.8.0
 	golang.org/x/net v0.7.0
diff --git a/go.sum b/go.sum
index 4bb9926..07cde99 100644
--- a/go.sum
+++ b/go.sum
@@ -53,8 +53,8 @@ github.com/prometheus/common v0.42.0 h1:EKsfXEYo4JpWMHH5cg+KOUWeuJSov1Id8zGR8eeI
 github.com/prometheus/common v0.42.0/go.mod h1:xBwqVerjNdUDjgODMpudtOMwlOwf2SaTr1yjz4b7Zbc=
 github.com/prometheus/procfs v0.8.0 h1:ODq8ZFEaYeCaZOJlZZdJA2AbQR98dSHSM1KW/You5mo=
 github.com/prometheus/procfs v0.8.0/go.mod h1:z7EfXMXOkbkqb9IINtpCn86r/to3BnA0uaxHdg830/4=
-github.com/redhat-cne/sdk-go v1.0.0 h1:7bkyZa2pxXerJA1L28U6cjJ7Dz9Y3xSH7THF7imlKbM=
-github.com/redhat-cne/sdk-go v1.0.0/go.mod h1:A7dN1yEB9aziTPyl6M24apOECGOqKMbieKs7ydKrE/I=
+github.com/redhat-cne/sdk-go v1.0.1-0.20240612145917-11968a1cd0b5 h1:QM52C/K6MspPaPBOUId5pMBZxvwDuYOlTqpWcIG4xSI=
+github.com/redhat-cne/sdk-go v1.0.1-0.20240612145917-11968a1cd0b5/go.mod h1:KzrDvnkv+1G4iyCyUhbzB168j7q6sD5/e8T3MvlUfYY=
 github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=
 github.com/rogpeppe/go-internal v1.10.0 h1:TMyTOH3F/DB16zRVcYyreMH6GnZZrwQVAoYjRBZyWFQ=
 github.com/rogpeppe/go-internal v1.10.0/go.mod h1:UQnix2H7Ngw/k4C5ijL5+65zddjncjaFoBhdsK/akog=
diff --git a/server.go b/server.go
index bc39ce6..45e307c 100644
--- a/server.go
+++ b/server.go
@@ -61,7 +61,7 @@ const (
 type Server struct {
 	port    int
 	apiPath string
-	//data out is amqp in channel
+	//data out is transport in channel
 	dataOut    chan<- *channel.DataChan
 	closeCh    <-chan struct{}
 	HTTPClient *http.Client
diff --git a/vendor/github.com/redhat-cne/sdk-go/pkg/channel/data.go b/vendor/github.com/redhat-cne/sdk-go/pkg/channel/data.go
index 684c30d..7c20be5 100644
--- a/vendor/github.com/redhat-cne/sdk-go/pkg/channel/data.go
+++ b/vendor/github.com/redhat-cne/sdk-go/pkg/channel/data.go
@@ -30,7 +30,7 @@ type DataChan struct {
 	Type Type
 	// OnReceiveFn  to do on OnReceive
 	OnReceiveFn func(e cloudevents.Event)
-	// OnReceiveOverrideFn Optional for event, but override for status pings.This is an override function on receiving msg by amqp listener,
+	// OnReceiveOverrideFn Optional for event, but override for status pings.This is an override function on receiving msg by transport,
 	// if not set then the data is sent to out channel and processed by side-car  default method
 	OnReceiveOverrideFn func(e cloudevents.Event, dataChan *DataChan) error
 	// ProcessEventFn  Optional, this allows to customize message handler thar was received at the out channel
diff --git a/vendor/github.com/redhat-cne/sdk-go/v1/pubsub/pubsub.go b/vendor/github.com/redhat-cne/sdk-go/v1/pubsub/pubsub.go
index a7d001d..081a8ba 100644
--- a/vendor/github.com/redhat-cne/sdk-go/v1/pubsub/pubsub.go
+++ b/vendor/github.com/redhat-cne/sdk-go/v1/pubsub/pubsub.go
@@ -104,17 +104,17 @@ func (p *API) ReloadStore() {
 	}
 }
 
-// HasTransportEnabled flag to indicate if amqp is enabled
+// HasTransportEnabled ...
 func (p *API) HasTransportEnabled() bool {
 	return p.transportEnabled
 }
 
-// DisableTransport disables usage of amqp
+// DisableTransport ...
 func (p *API) DisableTransport() {
 	p.transportEnabled = false
 }
 
-// EnableTransport enable usage of amqp
+// EnableTransport ...
 func (p *API) EnableTransport() {
 	p.transportEnabled = true
 }
diff --git a/vendor/modules.txt b/vendor/modules.txt
index 5ecc884..e35a18c 100644
--- a/vendor/modules.txt
+++ b/vendor/modules.txt
@@ -68,7 +68,7 @@ github.com/prometheus/common/model
 github.com/prometheus/procfs
 github.com/prometheus/procfs/internal/fs
 github.com/prometheus/procfs/internal/util
-# github.com/redhat-cne/sdk-go v1.0.0
+# github.com/redhat-cne/sdk-go v1.0.1-0.20240612145917-11968a1cd0b5
 ## explicit; go 1.21
 github.com/redhat-cne/sdk-go/pkg/channel
 github.com/redhat-cne/sdk-go/pkg/event