Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

CNF-12093: remove amq #92

Merged
merged 1 commit into from
Jun 12, 2024
Merged

CNF-12093: remove amq #92

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 0 additions & 2 deletions go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,8 +3,6 @@ module github.com/redhat-cne/sdk-go
go 1.21

require (
github.com/Azure/go-amqp v0.17.5
github.com/cloudevents/sdk-go/protocol/amqp/v2 v2.15.2
github.com/cloudevents/sdk-go/v2 v2.15.2
github.com/google/go-cmp v0.5.8
github.com/google/uuid v1.6.0
Expand Down
7 changes: 0 additions & 7 deletions go.sum
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,25 +1,18 @@
github.com/Azure/go-amqp v0.17.5 h1:7Lsi9H9ijCAfqOaMiNmQ4c+GL9bdrpCjebNKhV/eQ+c=
github.com/Azure/go-amqp v0.17.5/go.mod h1:9YJ3RhxRT1gquYnzpZO1vcYMMpAdJT+QEg6fwmw9Zlg=
github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=
github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=
github.com/cespare/xxhash/v2 v2.1.2 h1:YRXhKfTDauu4ajMg1TPgFO5jnlC2HCbmLXMcTG5cbYE=
github.com/cespare/xxhash/v2 v2.1.2/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
github.com/cloudevents/sdk-go/protocol/amqp/v2 v2.15.2 h1:OhJ1zLIEPqyw4leCmqgEKUilwE8HA6JkryP1ptdoPLU=
github.com/cloudevents/sdk-go/protocol/amqp/v2 v2.15.2/go.mod h1:C0mhM7xabBtXpJx7qHE4uewN+KRaC2WHf8vCGP+7mWU=
github.com/cloudevents/sdk-go/v2 v2.15.2 h1:54+I5xQEnI73RBhWHxbI1XJcqOFOVJN85vb41+8mHUc=
github.com/cloudevents/sdk-go/v2 v2.15.2/go.mod h1:lL7kSWAE/V8VI4Wh0jbL2v/jvqsm6tjmaQBSvxcv4uE=
github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/fortytw2/leaktest v1.3.0 h1:u8491cBMTQ8ft8aeV+adlcytMZylmA5nnwwkRZjI8vw=
github.com/fortytw2/leaktest v1.3.0/go.mod h1:jDsjWgpAGjm2CA7WthBh/CdZYEPF31XHquHwclZch5g=
github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=
github.com/golang/protobuf v1.3.5/go.mod h1:6O5/vntMXwX2lRkT1hjjk0nAC1IDOTvTlVgjlRvqsdk=
github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
github.com/golang/protobuf v1.5.2 h1:ROPKBNFfQgOUMifHyP+KYbvpjbdoFNs+aK7DXlji0Tw=
github.com/golang/protobuf v1.5.2/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
github.com/google/go-cmp v0.5.1/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/google/go-cmp v0.5.8 h1:e6P7q2lk1O+qJJb4BtCQXlK8vWEO8V1ZeuEdJNOqZyg=
github.com/google/go-cmp v0.5.8/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
Expand Down
2 changes: 1 addition & 1 deletion pkg/channel/data.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
32 changes: 0 additions & 32 deletions pkg/errorhandler/errorhandler.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,17 +21,6 @@ type ErrorHandler interface {
Error() string
}

// ReceiverNotFoundError amqp receiver not found
type ReceiverNotFoundError struct {
Name string
Desc string
}

// Error receiver not found error string
func (r ReceiverNotFoundError) Error() string {
return fmt.Sprintf("receiver %s not found", r.Name)
}

// ReceiverError receiver general error
type ReceiverError struct {
Name string
Expand All @@ -43,17 +32,6 @@ func (r ReceiverError) Error() string {
return fmt.Sprintf("receiver %s error %s", r.Name, r.Desc)
}

// SenderError sender amqp error
type SenderError struct {
Name string
Desc string
}

// Error sender error string
func (sr SenderError) Error() string {
return fmt.Sprintf("sender %s error %s", sr.Name, sr.Desc)
}

// SenderNotFoundError sender not found custom error
type SenderNotFoundError struct {
Name string
Expand All @@ -65,16 +43,6 @@ func (s SenderNotFoundError) Error() string {
return fmt.Sprintf("sender %s not found", s.Name)
}

// AMQPConnectionError custom amqp connection error
type AMQPConnectionError struct {
Desc string
}

// Error amqp connection error string
func (a AMQPConnectionError) Error() string {
return fmt.Sprintf("amqp connection error %s", a.Desc)
}

// HTTPConnectionError custom http connection error
type HTTPConnectionError struct {
Desc string
Expand Down
Loading
Loading