Skip to content

Commit 0064c4b

Browse files
upgrade to latest dependencies (#399)
bumping knative.dev/client/pkg 5d83f5c...a01fc2f: > a01fc2f upgrade to latest dependencies (# 2047) > 1c77c31 upgrade to latest dependencies (# 2046) > b0d8345 upgrade to latest dependencies (# 2045) > a30107d upgrade to latest dependencies (# 2044) > 13867f1 upgrade to latest dependencies (# 2043) > 1e16021 upgrade to latest dependencies (# 2042) bumping knative.dev/serving 109f3f0...6bab565: > 6bab565 approve workflows if ok-to-test label is present (# 16054) > 36ddb35 Update net-istio nightly (# 16064) > 45bf006 Update net-contour nightly (# 16067) > 4b1cb5b Update net-kourier nightly (# 16066) > 0237da7 Update net-gateway-api nightly (# 16065) > a0e1543 Serving Metric Tweaks (# 16062) > 1fb2561 Update net-istio nightly (# 16059) > 3ba1c33 Update net-kourier nightly (# 16058) > 790ea34 Update net-contour nightly (# 16057) > 80b3b0d Update net-gateway-api nightly (# 16060) > 74eb3dc upgrade to latest dependencies (# 16055) > 961ce6a Bump the github-actions group with 4 updates (# 16052) bumping knative.dev/networking 8f495ee...1dd9be9: > 1dd9be9 upgrade to latest dependencies (# 1081) bumping knative.dev/eventing 3e86e93...c9cfca8: > c9cfca8 Update request reply types (# 8698) > ea44c30 [Automated] Update eventing-eventing-integrations nightly (# 8702) > e24129c feat: enable KN_VERIFY_CORRELATION_ID in cesql runtimes (# 8700) > 8c44e16 [main] Upgrade to latest dependencies (# 8695) bumping google.golang.org/protobuf 7e776d4...0833cf3: > 0833cf3 all: release v1.36.8 > 0af3f0f all: set Go language version to Go 1.23 > 5ccbdec types: regenerate using latest protobuf v32 release > 708d96f all: start v1.36.7-devel bumping golang.org/x/sync 7fad2c9...04914c2: > 04914c2 all: upgrade go directive to at least 1.24.0 [generated] bumping knative.dev/eventing-kafka-broker bd49e77...20212a5: > 20212a5 [# 4514] dataplane/dispatcher - close KubernetesClient and reuse existing Vert.x instance in Kubernetes Client (# 4515) > 1baf063 Update community files (# 4510) > 7e37247 Update eventing nightly (# 4501) bumping knative.dev/pkg 528bde3...8c9c1d3: > 8c9c1d3 [controller] fix depth metrics (# 3253) > 3ec4afe Bump github.com/prometheus/client_golang from 1.23.0 to 1.23.2 (# 3252) > 455d6e9 Bump golang.org/x/sync from 0.16.0 to 0.17.0 in the golang-x group (# 3249) > efb6a4f Add threadiness in log line (# 3247) > eafac73 Bump github.com/prometheus/common from 0.65.0 to 0.66.1 (# 3250) Signed-off-by: Knative Automation <[email protected]>
1 parent 9b8ecc0 commit 0064c4b

File tree

15 files changed

+104
-73
lines changed

15 files changed

+104
-73
lines changed

go.mod

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -12,10 +12,10 @@ require (
1212
k8s.io/api v0.33.4
1313
k8s.io/apimachinery v0.33.4
1414
k8s.io/client-go v0.33.4
15-
knative.dev/client/pkg v0.0.0-20250901022440-5d83f5ca1c77
16-
knative.dev/eventing-kafka-broker v0.46.1-0.20250902055842-bd49e7709170
15+
knative.dev/client/pkg v0.0.0-20250908140348-a01fc2fb038c
16+
knative.dev/eventing-kafka-broker v0.46.1-0.20250908122347-20212a58b91a
1717
knative.dev/hack v0.0.0-20250902153942-1499de21e119
18-
knative.dev/pkg v0.0.0-20250903014743-528bde37b646
18+
knative.dev/pkg v0.0.0-20250909010931-8c9c1d368e4b
1919
)
2020

2121
require (
@@ -88,13 +88,13 @@ require (
8888
go.yaml.in/yaml/v2 v2.4.2 // indirect
8989
golang.org/x/net v0.43.0 // indirect
9090
golang.org/x/oauth2 v0.30.0 // indirect
91-
golang.org/x/sync v0.16.0 // indirect
91+
golang.org/x/sync v0.17.0 // indirect
9292
golang.org/x/sys v0.35.0 // indirect
9393
golang.org/x/term v0.34.0 // indirect
9494
golang.org/x/text v0.28.0 // indirect
9595
golang.org/x/time v0.12.0 // indirect
9696
gomodules.xyz/jsonpatch/v2 v2.5.0 // indirect
97-
google.golang.org/protobuf v1.36.7 // indirect
97+
google.golang.org/protobuf v1.36.8 // indirect
9898
gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect
9999
gopkg.in/inf.v0 v0.9.1 // indirect
100100
gopkg.in/ini.v1 v1.67.0 // indirect
@@ -106,9 +106,9 @@ require (
106106
k8s.io/klog/v2 v2.130.1 // indirect
107107
k8s.io/kube-openapi v0.0.0-20250318190949-c8a335a9a2ff // indirect
108108
k8s.io/utils v0.0.0-20241210054802-24370beab758 // indirect
109-
knative.dev/eventing v0.46.1-0.20250829061938-3e86e9387750 // indirect
110-
knative.dev/networking v0.0.0-20250820015349-8f495ee80e52 // indirect
111-
knative.dev/serving v0.46.1-0.20250830231539-109f3f00a892 // indirect
109+
knative.dev/eventing v0.46.1-0.20250908062745-c9cfca897068 // indirect
110+
knative.dev/networking v0.0.0-20250903015244-1dd9be99b5c9 // indirect
111+
knative.dev/serving v0.46.1-0.20250905135143-6bab56591b55 // indirect
112112
sigs.k8s.io/gateway-api v1.1.0 // indirect
113113
sigs.k8s.io/json v0.0.0-20241014173422-cfa47c3a1cc8 // indirect
114114
sigs.k8s.io/kustomize/api v0.13.5-0.20230601165947-6ce0bf390ce3 // indirect

go.sum

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -270,13 +270,13 @@ github.com/pkg/sftp v1.13.1/go.mod h1:3HaPG6Dq1ILlpPZRO0HVMrsydcdLt6HRDccSgb87qR
270270
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
271271
github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 h1:Jamvg5psRIccs7FGNTlIRMkT8wgtp5eCXdBlqhYGL6U=
272272
github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
273-
github.com/prometheus/client_golang v1.23.0 h1:ust4zpdl9r4trLY/gSjlm07PuiBq2ynaXXlptpfy8Uc=
274-
github.com/prometheus/client_golang v1.23.0/go.mod h1:i/o0R9ByOnHX0McrTMTyhYvKE4haaf2mW08I+jGAjEE=
273+
github.com/prometheus/client_golang v1.23.2 h1:Je96obch5RDVy3FDMndoUsjAhG5Edi49h0RJWRi/o0o=
274+
github.com/prometheus/client_golang v1.23.2/go.mod h1:Tb1a6LWHB3/SPIzCoaDXI4I8UHKeFTEQ1YCr+0Gyqmg=
275275
github.com/prometheus/client_model v0.0.0-20190812154241-14fe0d1b01d4/go.mod h1:xMI15A0UPsDsEKsMN9yxemIoYk6Tm2C1GtYGdfGttqA=
276276
github.com/prometheus/client_model v0.6.2 h1:oBsgwpGs7iVziMvrGhE53c/GrLUsZdHnqNwqPLxwZyk=
277277
github.com/prometheus/client_model v0.6.2/go.mod h1:y3m2F6Gdpfy6Ut/GBsUqTWZqCUvMVzSfMLjcu6wAwpE=
278-
github.com/prometheus/common v0.65.0 h1:QDwzd+G1twt//Kwj/Ww6E9FQq1iVMmODnILtW1t2VzE=
279-
github.com/prometheus/common v0.65.0/go.mod h1:0gZns+BLRQ3V6NdaerOhMbwwRbNh9hkGINtQAsP5GS8=
278+
github.com/prometheus/common v0.66.1 h1:h5E0h5/Y8niHc5DlaLlWLArTQI7tMrsfQjHV+d9ZoGs=
279+
github.com/prometheus/common v0.66.1/go.mod h1:gcaUsgf3KfRSwHY4dIMXLPV0K/Wg1oZ8+SbZk/HH/dA=
280280
github.com/prometheus/otlptranslator v0.0.0-20250717125610-8549f4ab4f8f h1:QQB6SuvGZjK8kdc2YaLJpYhV8fxauOsjE6jgcL6YJ8Q=
281281
github.com/prometheus/otlptranslator v0.0.0-20250717125610-8549f4ab4f8f/go.mod h1:P8AwMgdD7XEr6QRUJ2QWLpiAZTgTE2UYgjlu3svompI=
282282
github.com/prometheus/procfs v0.17.0 h1:FuLQ+05u4ZI+SS/w9+BWEM2TXiHKsUQ9TADiRH7DuK0=
@@ -489,8 +489,8 @@ golang.org/x/sync v0.0.0-20200317015054-43a5402ce75a/go.mod h1:RxMgew5VJxzue5/jJ
489489
golang.org/x/sync v0.0.0-20200625203802-6e8e738ad208/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
490490
golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
491491
golang.org/x/sync v0.0.0-20201207232520-09787c993a3a/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
492-
golang.org/x/sync v0.16.0 h1:ycBJEhp9p4vXvUZNszeOq0kGTPghopOL8q0fq3vstxw=
493-
golang.org/x/sync v0.16.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=
492+
golang.org/x/sync v0.17.0 h1:l60nONMj9l5drqw6jlhIELNv9I0A4OFgRsG9k2oT9Ug=
493+
golang.org/x/sync v0.17.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI=
494494
golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
495495
golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
496496
golang.org/x/sys v0.0.0-20190312061237-fead79001313/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -701,8 +701,8 @@ google.golang.org/protobuf v1.23.0/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2
701701
google.golang.org/protobuf v1.23.1-0.20200526195155-81db48ad09cc/go.mod h1:EGpADcykh3NcUnDUJcl1+ZksZNG86OlYog2l/sGQquU=
702702
google.golang.org/protobuf v1.24.0/go.mod h1:r/3tXBNzIEhYS9I1OUVjXDlt8tc493IdKGjtUeSXeh4=
703703
google.golang.org/protobuf v1.25.0/go.mod h1:9JNX74DMeImyA3h4bdi1ymwjUzf21/xIlbajtzgsN7c=
704-
google.golang.org/protobuf v1.36.7 h1:IgrO7UwFQGJdRNXH/sQux4R1Dj1WAKcLElzeeRaXV2A=
705-
google.golang.org/protobuf v1.36.7/go.mod h1:jduwjTPXsFjZGTmRluh+L6NjiWu7pchiJ2/5YcXBHnY=
704+
google.golang.org/protobuf v1.36.8 h1:xHScyCOEuuwZEc6UtSOvPbAT4zRh0xcNRYekJwfqyMc=
705+
google.golang.org/protobuf v1.36.8/go.mod h1:fuxRtAxBytpl4zzqUh6/eyUujkJdNiuEkXntxiD/uRU=
706706
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
707707
gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
708708
gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
@@ -747,20 +747,20 @@ k8s.io/kube-openapi v0.0.0-20250318190949-c8a335a9a2ff h1:/usPimJzUKKu+m+TE36gUy
747747
k8s.io/kube-openapi v0.0.0-20250318190949-c8a335a9a2ff/go.mod h1:5jIi+8yX4RIb8wk3XwBo5Pq2ccx4FP10ohkbSKCZoK8=
748748
k8s.io/utils v0.0.0-20241210054802-24370beab758 h1:sdbE21q2nlQtFh65saZY+rRM6x6aJJI8IUa1AmH/qa0=
749749
k8s.io/utils v0.0.0-20241210054802-24370beab758/go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0=
750-
knative.dev/client/pkg v0.0.0-20250901022440-5d83f5ca1c77 h1:J1NypQZm93enGgyHf1uVIfzqLuoluGzohAMIYE15G9k=
751-
knative.dev/client/pkg v0.0.0-20250901022440-5d83f5ca1c77/go.mod h1:ciFzqvuixRHJk/MywR0AIFeICpQjSjgwT3BLO6nivlg=
752-
knative.dev/eventing v0.46.1-0.20250829061938-3e86e9387750 h1:ZqFoKQxx+t6kMp0dhseLj1BEkzj3KnmrTR0l3DEQ6Mg=
753-
knative.dev/eventing v0.46.1-0.20250829061938-3e86e9387750/go.mod h1:LGrT69aBGGhjY+hmO7wwJzBQLCqkhJf10v9fcorJHKY=
754-
knative.dev/eventing-kafka-broker v0.46.1-0.20250902055842-bd49e7709170 h1:y//rdUEqLpWjbQ9Q4V/DUlirvaoLzrr1viAbNX+58eY=
755-
knative.dev/eventing-kafka-broker v0.46.1-0.20250902055842-bd49e7709170/go.mod h1:PiyJTtQJ4tnaNqyixqEjGDXZECKvVV/ftooKtZlk3bc=
750+
knative.dev/client/pkg v0.0.0-20250908140348-a01fc2fb038c h1:tlUFUTjvL8Y76VHV3a40T1nS7mFiPWTr8ojl2EAdCRw=
751+
knative.dev/client/pkg v0.0.0-20250908140348-a01fc2fb038c/go.mod h1:PK3no+3UPgfu4WeRtLahrG00osghHip+mr7au5oOZnY=
752+
knative.dev/eventing v0.46.1-0.20250908062745-c9cfca897068 h1:Qa8Kqsh7m5WCfUdrPCwTVEethluJ53GIPTZKHIt3CH0=
753+
knative.dev/eventing v0.46.1-0.20250908062745-c9cfca897068/go.mod h1:Cbonqnx7nVDpS7bbjZxm7ouDecCfdk2Xx5m2P7EAuj4=
754+
knative.dev/eventing-kafka-broker v0.46.1-0.20250908122347-20212a58b91a h1:ZfoQiwCnHK7bw7vbFf5EfClHBa4Qw3GybVMJ40H8/xs=
755+
knative.dev/eventing-kafka-broker v0.46.1-0.20250908122347-20212a58b91a/go.mod h1:PiyJTtQJ4tnaNqyixqEjGDXZECKvVV/ftooKtZlk3bc=
756756
knative.dev/hack v0.0.0-20250902153942-1499de21e119 h1:NbQvjnFK1tL489LN0qAybWy0E17Jpziwcv/XIHwfp6M=
757757
knative.dev/hack v0.0.0-20250902153942-1499de21e119/go.mod h1:R0ritgYtjLDO9527h5vb5X6gfvt5LCrJ55BNbVDsWiY=
758-
knative.dev/networking v0.0.0-20250820015349-8f495ee80e52 h1:otZjfxLAOcn1wV9Yl8i7VZ4aDWiS2NEo2Kyg3b0a4pA=
759-
knative.dev/networking v0.0.0-20250820015349-8f495ee80e52/go.mod h1:rEXgxXZ7rmrif823YRJgaQO89jySTDor0NNEq6tlC6Q=
760-
knative.dev/pkg v0.0.0-20250903014743-528bde37b646 h1:90qlepWL0OJjPN8bkwX7CiyUwMGcGi++mslcbfIKNfQ=
761-
knative.dev/pkg v0.0.0-20250903014743-528bde37b646/go.mod h1:ROyn4KNeXnoDS85bZkA7wiVpZgqZCukoh8u6xrDZyHo=
762-
knative.dev/serving v0.46.1-0.20250830231539-109f3f00a892 h1:WAqiayiyAzuyEgNBnQu2At0Zxh5r1IyCZr+s+H/OqXk=
763-
knative.dev/serving v0.46.1-0.20250830231539-109f3f00a892/go.mod h1:PGfROWOyTtcs2qOk9JRv4ZTJMxMjZPyyI9RSUMOY6Sw=
758+
knative.dev/networking v0.0.0-20250903015244-1dd9be99b5c9 h1:upUH3vfEUpTZOmBqbfBeWaaywodeHeE6l9W96Gx4IEE=
759+
knative.dev/networking v0.0.0-20250903015244-1dd9be99b5c9/go.mod h1:0U6fhV37+SthfCKiPK7WwMNhoiH/xhpztEVfi7FpjkY=
760+
knative.dev/pkg v0.0.0-20250909010931-8c9c1d368e4b h1:Gscoeovr8XvQffYg6l2d7V8M5FuaJg34Hjg8e9sg21Y=
761+
knative.dev/pkg v0.0.0-20250909010931-8c9c1d368e4b/go.mod h1:OLfYBCgDhdEpaC2TEixU3e7byMEQmke/MHP3xsR7Gmo=
762+
knative.dev/serving v0.46.1-0.20250905135143-6bab56591b55 h1:8LalhZhcjcm3HjaJ2mb7WqECE9HS451UBcWSD/LQ0WI=
763+
knative.dev/serving v0.46.1-0.20250905135143-6bab56591b55/go.mod h1:i/Y4PwFeTihf3fjCQ6zd8d8tu5c5yxwabOxysL3aGDk=
764764
rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
765765
rsc.io/quote/v3 v3.1.0/go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0=
766766
rsc.io/sampler v1.3.0/go.mod h1:T1hPZKmBbMNahiBKFy5HrXp6adAjACjK9JXDnKaTXpA=

vendor/google.golang.org/protobuf/internal/genid/api_gen.go

Lines changed: 6 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

vendor/google.golang.org/protobuf/internal/version/version.go

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

vendor/google.golang.org/protobuf/types/descriptorpb/descriptor.pb.go

Lines changed: 7 additions & 3 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

vendor/knative.dev/eventing/pkg/apis/eventing/v1alpha1/requestreply_defaults.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,12 @@ import (
2727
func (rr *RequestReply) SetDefaults(ctx context.Context) {
2828
ctx = apis.WithinParent(ctx, rr.ObjectMeta)
2929
rr.Spec.SetDefaults(ctx)
30+
31+
if rr.Labels == nil {
32+
rr.Labels = make(map[string]string)
33+
}
34+
35+
rr.Labels["eventing.knative.dev/broker"] = rr.Spec.BrokerRef.Name
3036
}
3137

3238
func (rrs *RequestReplySpec) SetDefaults(ctx context.Context) {
@@ -41,4 +47,5 @@ func (rrs *RequestReplySpec) SetDefaults(ctx context.Context) {
4147
if rrs.ReplyAttribute == "" {
4248
rrs.ReplyAttribute = "replyid"
4349
}
50+
4451
}

vendor/knative.dev/eventing/pkg/apis/eventing/v1alpha1/requestreply_lifecycle.go

Lines changed: 14 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -21,14 +21,14 @@ import (
2121
v1 "knative.dev/pkg/apis/duck/v1"
2222
)
2323

24-
var requestReplyCondSet = apis.NewLivingConditionSet(RequestReplyConditionIngress, RequestReplyConditionTriggers, RequestReplyConditionAddressable, RequestReplyConditionEventPoliciesReady)
24+
var requestReplyCondSet = apis.NewLivingConditionSet(RequestReplyConditionTriggers, RequestReplyConditionAddressable, RequestReplyConditionEventPoliciesReady, RequestReplyConditionBrokerReady)
2525

2626
const (
2727
RequestReplyConditionReady = apis.ConditionReady
28-
RequestReplyConditionIngress apis.ConditionType = "IngressReady"
2928
RequestReplyConditionTriggers apis.ConditionType = "TriggersReady"
3029
RequestReplyConditionAddressable apis.ConditionType = "Addressable"
3130
RequestReplyConditionEventPoliciesReady apis.ConditionType = "EventPoliciesReady"
31+
RequestReplyConditionBrokerReady apis.ConditionType = "BrokerReady"
3232
)
3333

3434
// GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
@@ -81,14 +81,6 @@ func (rr *RequestReplyStatus) MarkTriggersNotReadyWithReason(reason, messageForm
8181
rr.GetConditionSet().Manage(rr).MarkUnknown(RequestReplyConditionTriggers, reason, messageFormat, messageA...)
8282
}
8383

84-
func (rr *RequestReplyStatus) MarkIngressReady() {
85-
rr.GetConditionSet().Manage(rr).MarkTrue(RequestReplyConditionIngress)
86-
}
87-
88-
func (rr *RequestReplyStatus) MarkIngressNotReadyWithReason(reason, messageFormat string, messageA ...interface{}) {
89-
rr.GetConditionSet().Manage(rr).MarkUnknown(RequestReplyConditionIngress, reason, messageFormat, messageA...)
90-
}
91-
9284
func (rr *RequestReplyStatus) MarkEventPoliciesTrue() {
9385
rr.GetConditionSet().Manage(rr).MarkTrue(RequestReplyConditionEventPoliciesReady)
9486
}
@@ -104,3 +96,15 @@ func (rr *RequestReplyStatus) MarkEventPoliciesFailed(reason, messageFormat stri
10496
func (rr *RequestReplyStatus) MarkEventPoliciesUnknown(reason, messageFormat string, messageA ...interface{}) {
10597
rr.GetConditionSet().Manage(rr).MarkUnknown(RequestReplyConditionEventPoliciesReady, reason, messageFormat, messageA...)
10698
}
99+
100+
func (rr *RequestReplyStatus) MarkBrokerReady() {
101+
rr.GetConditionSet().Manage(rr).MarkTrue(RequestReplyConditionBrokerReady)
102+
}
103+
104+
func (rr *RequestReplyStatus) MarkBrokerNotReady(reason, messageFormat string, messageA ...interface{}) {
105+
rr.GetConditionSet().Manage(rr).MarkFalse(RequestReplyConditionBrokerReady, reason, messageFormat, messageA...)
106+
}
107+
108+
func (rr *RequestReplyStatus) MarkBrokerUnknown(reason, messageFormat string, messageA ...interface{}) {
109+
rr.GetConditionSet().Manage(rr).MarkUnknown(RequestReplyConditionBrokerReady, reason, messageFormat, messageA...)
110+
}

vendor/knative.dev/eventing/pkg/apis/eventing/v1alpha1/requestreply_types.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -76,8 +76,6 @@ type RequestReplySpec struct {
7676
Timeout *string `json:"timeout,omitempty"`
7777

7878
Delivery *eventingduckv1.DeliverySpec `json:"delivery,omitempty"`
79-
80-
Secrets []string `json:"secrets"`
8179
}
8280

8381
// RequestReplyStatus represents the current state of a RequestReply.
@@ -95,6 +93,12 @@ type RequestReplyStatus struct {
9593
// AppliedEventPoliciesStatus contains the list of EventPolicies which apply to this Broker.
9694
// +optional
9795
eventingduckv1.AppliedEventPoliciesStatus `json:",inline"`
96+
97+
// DesiredReplicas is the number of replicas (StatefulSet pod + trigger) that is desired
98+
DesiredReplicas *int32 `json:"desiredReplicas,omitempty"`
99+
100+
// ReadyReplicas is the number of ready replicas (StatefulSet pod + trigger) for this RequestReply resource
101+
ReadyReplicas *int32 `json:"readyReplicas,omitempty"`
98102
}
99103

100104
// +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object

vendor/knative.dev/eventing/pkg/apis/eventing/v1alpha1/requestreply_validation.go

Lines changed: 6 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -53,14 +53,13 @@ func (rrs *RequestReplySpec) Validate(ctx context.Context) *apis.FieldError {
5353

5454
if rrs.Timeout != nil {
5555
timeout, err := period.Parse(*rrs.Timeout)
56-
if err != nil || timeout.IsZero() || timeout.IsNegative() {
57-
errs = errs.Also(apis.ErrInvalidValue(*rrs.Timeout, "timeout"))
56+
if err != nil {
57+
errs = errs.Also(apis.ErrInvalidValue(*rrs.Timeout, "timeout", err.Error()))
58+
} else if timeout.IsNegative() || timeout.IsZero() {
59+
errs = errs.Also(apis.ErrInvalidValue(*rrs.Timeout, "timeout", "timeout must be a positive duration"))
5860
}
59-
60-
}
61-
62-
if len(rrs.Secrets) == 0 {
63-
errs = errs.Also(apis.ErrInvalidValue(rrs.Secrets, "secrets", "one or more secrets must be provided"))
61+
} else {
62+
errs = errs.Also(apis.ErrMissingField("timeout"))
6463
}
6564

6665
if rrs.CorrelationAttribute == "" ||

vendor/knative.dev/eventing/pkg/apis/eventing/v1alpha1/zz_generated.deepcopy.go

Lines changed: 10 additions & 5 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)