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

Commit

Permalink
Updating broker to be v1 in BrokerRedelivery test (#1511)
Browse files Browse the repository at this point in the history
Signed-off-by: Pierangelo Di Pilato <[email protected]>
  • Loading branch information
pierDipi authored Aug 28, 2020
1 parent c239fd5 commit 312de09
Showing 1 changed file with 8 additions and 8 deletions.
16 changes: 8 additions & 8 deletions test/e2e/broker_redelivery_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,9 +24,9 @@ import (

metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/utils/pointer"
eventingduckv1beta1 "knative.dev/eventing/pkg/apis/duck/v1beta1"
eventingduckv1 "knative.dev/eventing/pkg/apis/duck/v1"
"knative.dev/eventing/pkg/apis/eventing"
"knative.dev/eventing/pkg/apis/eventing/v1beta1"
v1 "knative.dev/eventing/pkg/apis/eventing/v1"
"knative.dev/eventing/test/e2e/helpers"
testlib "knative.dev/eventing/test/lib"
"knative.dev/eventing/test/lib/resources"
Expand All @@ -40,14 +40,14 @@ func ChannelBasedBrokerCreator(channel metav1.TypeMeta, brokerClass string) help
// create a ConfigMap used by the broker.
config := client.CreateBrokerConfigMapOrFail("config-"+brokerName, &channel)

backoff := eventingduckv1beta1.BackoffPolicyLinear
backoff := eventingduckv1.BackoffPolicyLinear

// create a new broker.
client.CreateBrokerV1Beta1OrFail(brokerName,
resources.WithBrokerClassForBrokerV1Beta1(brokerClass),
resources.WithConfigForBrokerV1Beta1(config),
func(broker *v1beta1.Broker) {
broker.Spec.Delivery = &eventingduckv1beta1.DeliverySpec{
client.CreateBrokerV1OrFail(brokerName,
resources.WithBrokerClassForBrokerV1(brokerClass),
resources.WithConfigForBrokerV1(config),
func(broker *v1.Broker) {
broker.Spec.Delivery = &eventingduckv1.DeliverySpec{
Retry: &numRetries,
BackoffPolicy: &backoff,
BackoffDelay: pointer.StringPtr("PT1S"),
Expand Down

0 comments on commit 312de09

Please sign in to comment.