Skip to content

Commit

Permalink
unit test bug fix
Browse files Browse the repository at this point in the history
  • Loading branch information
liuchangyan committed Nov 22, 2022
1 parent 3ef5c30 commit bdce2f4
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 10 deletions.
8 changes: 4 additions & 4 deletions pkg/apis/config/defaults_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,15 +52,15 @@ func TestGetBrokerConfig(t *testing.T) {
if c.Delivery.DeadLetterSink.Ref.Name != "mt-handle-error" {
t.Error("GetBrokerConfig Failed, wanted mt-handle-error, got:", c.Delivery.DeadLetterSink.Ref.Name)
}
c, err = defaults.GetBrokerConfig("some-namespace")
c, err = defaults.GetBrokerConfig("some-namespace-three")
if err != nil {
t.Error("GetBrokerConfig Failed =", err)
}
if c.Name != "someothername" {
t.Error("GetBrokerConfig Failed, wanted someothername, got:", c.Name)
}
// Test GetBrokerConfig in different namespace
c, err = defaults.GetBrokerConfig("some-namespace-two")
c, err = defaults.GetBrokerConfig("some-namespace")
if err != nil {
t.Error("GetBrokerConfig Failed =", err)
}
Expand All @@ -71,7 +71,7 @@ func TestGetBrokerConfig(t *testing.T) {
t.Error("GetBrokerConfig Failed, wanted kafka-handle-error, got:", c.Delivery.DeadLetterSink.Ref.Name)
}

c, err = defaults.GetBrokerConfig("some-namespace-three")
c, err = defaults.GetBrokerConfig("some-namespace-two")
if err != nil {
t.Error("GetBrokerConfig Failed =", err)
}
Expand Down Expand Up @@ -114,7 +114,7 @@ func TestGetBrokerClass(t *testing.T) {
if c != "MTChannelBasedBroker" {
t.Error("GetBrokerClass Failed, wanted MTChannelBasedBroker, got:", c)
}
c, err = defaults.GetBrokerClass("some-namespace")
c, err = defaults.GetBrokerClass("some-namespace-three")
if err != nil {
t.Error("GetBrokerClass Failed =", err)
}
Expand Down
11 changes: 5 additions & 6 deletions pkg/apis/config/testdata/config-br-defaults.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,10 @@ data:
namespaceDefaults:
some-namespace:
brokerClass: KafkaBroker
some-namespace-two:
brokerClass: KafkaBroker
some-namespace-three:
brokerClass: someotherbrokerclass
apiVersion: v1
kind: ConfigMap
Expand All @@ -96,9 +100,4 @@ data:
name: someother-handle-error
namespace: someothernamespace
backoffPolicy: linear
backoffDelay: 5s
some-namespace-two:
brokerClass: KafkaBroker
some-namespace-three:
brokerClass: KafkaBroker
backoffDelay: 5s

0 comments on commit bdce2f4

Please sign in to comment.