Skip to content
This repository has been archived by the owner on Jun 4, 2021. It is now read-only.

Commit

Permalink
use MT Broker for tests (#1279)
Browse files Browse the repository at this point in the history
  • Loading branch information
vaikas authored May 27, 2020
1 parent 8f46312 commit 1f30240
Show file tree
Hide file tree
Showing 4 changed files with 6 additions and 6 deletions.
6 changes: 3 additions & 3 deletions test/e2e-tests.sh
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ fi

# Eventing main config path from HEAD.
readonly EVENTING_CONFIG="./config/"
readonly EVENTING_CHANNEL_BROKER_CONFIG="./config/brokers/channel-broker"
readonly EVENTING_MT_CHANNEL_BROKER_CONFIG="./config/brokers/mt-channel-broker"

# Vendored eventing test iamges.
readonly VENDOR_EVENTING_TEST_IMAGES="vendor/knative.dev/eventing/test/test_images/"
Expand Down Expand Up @@ -84,8 +84,8 @@ function knative_setup() {
git clone https://github.com/knative/eventing
cd eventing
ko apply -f ${EVENTING_CONFIG}
# Install Channel Based Broker
ko apply -f ${EVENTING_CHANNEL_BROKER_CONFIG}
# Install MT Channel Based Broker
ko apply -f ${EVENTING_MT_CHANNEL_BROKER_CONFIG}
popd
fi
wait_until_pods_running knative-eventing || fail_test "Knative Eventing did not come up"
Expand Down
2 changes: 1 addition & 1 deletion test/e2e/broker_channel_flow_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,5 +24,5 @@ import (
)

func TestBrokerChannelFlow(t *testing.T) {
helpers.BrokerChannelFlowTestHelper(t, "ChannelBasedBroker" /*brokerClass*/, channelTestRunner)
helpers.BrokerChannelFlowTestHelper(t, "MTChannelBasedBroker" /*brokerClass*/, channelTestRunner)
}
2 changes: 1 addition & 1 deletion test/e2e/broker_dls_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,5 +31,5 @@ func TestBrokerDeadLetterSink(t *testing.T) {
{APIVersion: "messaging.knative.dev/v1alpha1", Kind: "KafkaChannel"},
}

helpers.TestBrokerWithConfig(t, "ChannelBasedBroker" /*brokerClass*/, channelTestRunner)
helpers.TestBrokerWithConfig(t, "MTChannelBasedBroker" /*brokerClass*/, channelTestRunner)
}
2 changes: 1 addition & 1 deletion test/e2e/broker_event_transformation_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,5 +24,5 @@ import (
)

func TestEventTransformationForTrigger(t *testing.T) {
helpers.EventTransformationForTriggerTestHelper(t, "ChannelBasedBroker" /*brokerClass*/, channelTestRunner)
helpers.EventTransformationForTriggerTestHelper(t, "MTChannelBasedBroker" /*brokerClass*/, channelTestRunner)
}

0 comments on commit 1f30240

Please sign in to comment.