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