diff --git a/go.mod b/go.mod index d44331e893..b4ab143d46 100644 --- a/go.mod +++ b/go.mod @@ -24,11 +24,11 @@ require ( k8s.io/client-go v0.35.8 k8s.io/code-generator v0.35.8 knative.dev/caching v0.0.0-20260821014320-af6341f3ab2b - knative.dev/eventing v0.50.1-0.20260907114944-07b1e8ab96e5 + knative.dev/eventing v0.50.1-0.20260921114233-7c892cfc4d72 knative.dev/hack v0.0.0-20260428014158-b2a37f1b6e7b - knative.dev/pkg v0.0.0-20260825072334-d2a153acc00c - knative.dev/reconciler-test v0.0.0-20260821021027-c844fc2204aa - knative.dev/serving v0.50.1-0.20260825144834-618b0c275af1 + knative.dev/pkg v0.0.0-20260918182429-5dc1978f0042 + knative.dev/reconciler-test v0.0.0-20260921021034-087b0fddd896 + knative.dev/serving v0.50.1-0.20260921122632-47ddb67c5cf2 sigs.k8s.io/cluster-inventory-api v0.1.3 sigs.k8s.io/controller-tools v0.20.1 sigs.k8s.io/yaml v1.6.0 @@ -198,7 +198,7 @@ require ( google.golang.org/genproto v0.0.0-20260128011058-8636f8732409 // indirect google.golang.org/genproto/googleapis/api v0.0.0-20260803160001-6ac0973c030d // indirect google.golang.org/genproto/googleapis/rpc v0.0.0-20260803160001-6ac0973c030d // indirect - google.golang.org/grpc v1.83.1 // indirect + google.golang.org/grpc v1.83.2 // indirect google.golang.org/protobuf v1.36.12-0.20260120151049-f2248ac996af // indirect gopkg.in/evanphx/json-patch.v4 v4.13.0 // indirect gopkg.in/inf.v0 v0.9.1 // indirect @@ -211,7 +211,7 @@ require ( k8s.io/klog/v2 v2.140.0 // indirect k8s.io/kube-openapi v0.0.0-20260319004828-5883c5ee87b9 // indirect k8s.io/utils v0.0.0-20260210185600-b8788abfbbc2 // indirect - knative.dev/networking v0.0.0-20260821014922-17b28c62e1cb // indirect + knative.dev/networking v0.0.0-20260919094129-7d916c7f8aa5 // indirect sigs.k8s.io/controller-runtime v0.23.3 // indirect sigs.k8s.io/gateway-api v1.5.0 // indirect sigs.k8s.io/json v0.0.0-20250730193827-2d320260d730 // indirect diff --git a/go.sum b/go.sum index 4aacac0126..1e930f33ab 100644 --- a/go.sum +++ b/go.sum @@ -1718,8 +1718,8 @@ google.golang.org/grpc v1.46.0/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACu google.golang.org/grpc v1.46.2/go.mod h1:vN9eftEi1UMyUsIF80+uQXhHjbXYbm0uXoFCACuMGWk= google.golang.org/grpc v1.49.0/go.mod h1:ZgQEeidpAuNRZ8iRrlBKXZQP1ghovWIVhdJRyCDK+GI= google.golang.org/grpc v1.51.0/go.mod h1:wgNDFcnuBGmxLKI/qn4T+m5BtEBYXJPvibbUPsAIPww= -google.golang.org/grpc v1.83.1 h1:HIO0+BEtBP6soyqvqC8sNUjZ7bTs+0hFQuFF+RAy++Y= -google.golang.org/grpc v1.83.1/go.mod h1:kDyl6SKsiHKt0uylY5gtn5cEjkrIOhQOGDgIc4JGwzQ= +google.golang.org/grpc v1.83.2 h1:EManeRomTObA0BU7I8vXgg/78uE5MJ9M8B39EX2WscU= +google.golang.org/grpc v1.83.2/go.mod h1:YPI1hK3kDked6iHvgX3tR0y+nX/qpMFKhPgFsokw1S8= google.golang.org/grpc/cmd/protoc-gen-go-grpc v1.1.0/go.mod h1:6Kw0yEErY5E/yWrBtf03jp27GLLJujG4z/JK95pnjjw= google.golang.org/protobuf v0.0.0-20200109180630-ec00e32a8dfd/go.mod h1:DFci5gLYBciE7Vtevhsrf46CRTquxDuWsQurQQe4oz8= google.golang.org/protobuf v0.0.0-20200221191635-4d8936d0db64/go.mod h1:kwYJMbMJ01Woi6D6+Kah6886xMZcty6N08ah7+eCXa0= @@ -1840,18 +1840,18 @@ k8s.io/utils v0.0.0-20260210185600-b8788abfbbc2 h1:AZYQSJemyQB5eRxqcPky+/7EdBj0x k8s.io/utils v0.0.0-20260210185600-b8788abfbbc2/go.mod h1:xDxuJ0whA3d0I4mf/C4ppKHxXynQ+fxnkmQH0vTHnuk= knative.dev/caching v0.0.0-20260821014320-af6341f3ab2b h1:ijjMoP+WBTBEEKgCffxZnTXONr3IALnsdVtf1EBPWes= knative.dev/caching v0.0.0-20260821014320-af6341f3ab2b/go.mod h1:UElQ1b/rv+g4A5kJZNY21cYkys+qMX6PMqZAS71xrSs= -knative.dev/eventing v0.50.1-0.20260907114944-07b1e8ab96e5 h1:iEXK5JQdzdwyxVCi9qj+0K0+jCBn0ro+yfAHnAFvmVI= -knative.dev/eventing v0.50.1-0.20260907114944-07b1e8ab96e5/go.mod h1:sFjtIupSQHQIoapbfN8mE6qm9Sus+Dg3bWd2mQDStSA= +knative.dev/eventing v0.50.1-0.20260921114233-7c892cfc4d72 h1:eT0rciFNUOQzmXL1QlaVSvvPdaRc8tQgAaKzPny6ypY= +knative.dev/eventing v0.50.1-0.20260921114233-7c892cfc4d72/go.mod h1:sCPnAi4eWe+w1dOZ6HLTf1H3vz5MpJMde4EU+NXCWzI= knative.dev/hack v0.0.0-20260428014158-b2a37f1b6e7b h1:MvbV2F2BdI8qKrYYUhDwbUZbX0BAYRSIpXM2TOtTvs0= knative.dev/hack v0.0.0-20260428014158-b2a37f1b6e7b/go.mod h1:L5RzHgbvam0u8QFHfzCX6MKxu/a/gIGEdaRBqNiVbl0= -knative.dev/networking v0.0.0-20260821014922-17b28c62e1cb h1:ukTLqsBsPfPsvEvB7c8DsVoKpDGi4tMsHCDzL8y8ycM= -knative.dev/networking v0.0.0-20260821014922-17b28c62e1cb/go.mod h1:LcjiQvD89e7hdND0fI4O4sbWt7L8fEnb+9xPi5BEa5Y= -knative.dev/pkg v0.0.0-20260825072334-d2a153acc00c h1:x99AILfR+9/dMMSXTpD5akQkCxfqreR+Py40i4pUrmA= -knative.dev/pkg v0.0.0-20260825072334-d2a153acc00c/go.mod h1:79LFLJ+XR5kxkPWy4KBBJkdTrk00t7zynpgOpP8uKrs= -knative.dev/reconciler-test v0.0.0-20260821021027-c844fc2204aa h1:nv9Q4YBvKFLJCmnMS0pooQb8+4eFVuWWgaXv71NbsEk= -knative.dev/reconciler-test v0.0.0-20260821021027-c844fc2204aa/go.mod h1:DMKhLoD/0cSATDyAPlHH0vICDEZhr45LHzt9iCmavAY= -knative.dev/serving v0.50.1-0.20260825144834-618b0c275af1 h1:U7ixUp+rikVPkEEsYzn/PkL8t6OSDMfAFZfVxPb7JKQ= -knative.dev/serving v0.50.1-0.20260825144834-618b0c275af1/go.mod h1:TSVJNoOBCimZFxyVSe2+8CYuNLSlkMn4RxRSZDHditE= +knative.dev/networking v0.0.0-20260919094129-7d916c7f8aa5 h1:Yqrd7vuj98DZbQsKK3o8YeNudBUZcDn5O5JPMfRoYac= +knative.dev/networking v0.0.0-20260919094129-7d916c7f8aa5/go.mod h1:LcjiQvD89e7hdND0fI4O4sbWt7L8fEnb+9xPi5BEa5Y= +knative.dev/pkg v0.0.0-20260918182429-5dc1978f0042 h1:hZ4eQYaloFYHe70C6EAjGb3N9mKLPNOwhEdQmNs6v2M= +knative.dev/pkg v0.0.0-20260918182429-5dc1978f0042/go.mod h1:zhIH5iW5e2l3rajXrpi3u31lEUTncLniK5BhtSe4DpI= +knative.dev/reconciler-test v0.0.0-20260921021034-087b0fddd896 h1:YKfEHTidShv5y+ZyxeUGRbn/ioxO5+5tjPcsYHgunm0= +knative.dev/reconciler-test v0.0.0-20260921021034-087b0fddd896/go.mod h1:lldste35e30ZpGCU3doOxNAq7IYKuFx5glxXG4+Xvew= +knative.dev/serving v0.50.1-0.20260921122632-47ddb67c5cf2 h1:0t+e8eJVTp24jmI8lviLIu5s47nK4RtZRIVfZRsJwNQ= +knative.dev/serving v0.50.1-0.20260921122632-47ddb67c5cf2/go.mod h1:b8OvQc3buMBvxpXGFv262ToljNisIDmq1BHmUCNvRfI= nhooyr.io/websocket v1.8.6/go.mod h1:B70DZP8IakI65RVQ51MsWP/8jndNma26DVA/nFSCgW0= pgregory.net/rapid v1.1.0 h1:CMa0sjHSru3puNx+J0MIAuiiEV4N0qj8/cMWGBBCsjw= pgregory.net/rapid v1.1.0/go.mod h1:PY5XlDGj0+V1FCq0o192FdRhpKHGTRIWBgqjDBTrq04= diff --git a/vendor/google.golang.org/grpc/internal/transport/http2_server.go b/vendor/google.golang.org/grpc/internal/transport/http2_server.go index 63c6539a3d..82e13e64aa 100644 --- a/vendor/google.golang.org/grpc/internal/transport/http2_server.go +++ b/vendor/google.golang.org/grpc/internal/transport/http2_server.go @@ -522,6 +522,12 @@ func (t *http2Server) operateHeaders(ctx context.Context, frame *http2.MetaHeade delete(mdata, "host") } + // If :authority is still missing, i.e. no host or :authority header is + // present, reject the request as invalid. + if len(mdata[":authority"]) == 0 { + t.writeEarlyAbort(streamID, s.contentSubtype, status.New(codes.Internal, "no host or :authority header present"), http.StatusBadRequest, !frame.StreamEnded()) + return nil + } if frame.StreamEnded() { // s is just created by the caller. No lock needed. s.state = streamReadDone diff --git a/vendor/google.golang.org/grpc/internal/xds/server/routing.go b/vendor/google.golang.org/grpc/internal/xds/server/routing.go index 67dd7609e1..706872585e 100644 --- a/vendor/google.golang.org/grpc/internal/xds/server/routing.go +++ b/vendor/google.golang.org/grpc/internal/xds/server/routing.go @@ -62,11 +62,14 @@ func RouteAndProcess(ctx context.Context) error { if !ok { return errors.New("missing metadata in incoming context") } - // A41 added logic to the core grpc implementation to guarantee that once - // the RPC gets to this point, there will be a single, unambiguous authority - // present in the header map. + // A41 added logic to the core grpc implementation to guarantee that once the + // RPC gets to this point, there will be a single, unambiguous authority + // present in the header map. But add a defensive check to ensure authority + // header is present. authority := md.Get(":authority") - // authority[0] is safe because of the guarantee mentioned above. + if len(authority) == 0 { + return rc.statusErrWithNodeID(codes.Internal, "no :authority header present") + } vh := findBestMatchingVirtualHostServer(authority[0], rc.vhs) if vh == nil { return rc.statusErrWithNodeID(codes.Unavailable, "the incoming RPC did not match a configured Virtual Host") diff --git a/vendor/google.golang.org/grpc/version.go b/vendor/google.golang.org/grpc/version.go index 64ec3b3cfd..835dc07fdc 100644 --- a/vendor/google.golang.org/grpc/version.go +++ b/vendor/google.golang.org/grpc/version.go @@ -19,4 +19,4 @@ package grpc // Version is the current grpc version. -const Version = "1.83.1" +const Version = "1.83.2" diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_lifecycle.go index e961d3979c..52613289f5 100644 --- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1/trigger_lifecycle.go @@ -92,11 +92,11 @@ func (ts *TriggerStatus) PropagateBrokerCondition(bc *apis.Condition) { switch { case bc.Status == corev1.ConditionUnknown: - ts.MarkBrokerUnknown(bc.Reason, bc.Message) + ts.MarkBrokerUnknown(bc.Reason, "%s", bc.Message) case bc.Status == corev1.ConditionTrue: triggerCondSet.Manage(ts).MarkTrue(TriggerConditionBroker) case bc.Status == corev1.ConditionFalse: - ts.MarkBrokerFailed(bc.Reason, bc.Message) + ts.MarkBrokerFailed(bc.Reason, "%s", bc.Message) default: ts.MarkBrokerUnknown("BrokerUnknown", "The status of Broker is invalid: %v", bc.Status) } @@ -123,11 +123,11 @@ func (ts *TriggerStatus) PropagateSubscriptionCondition(sc *apis.Condition) { switch { case sc.Status == corev1.ConditionUnknown: - ts.MarkSubscribedUnknown(sc.Reason, sc.Message) + ts.MarkSubscribedUnknown(sc.Reason, "%s", sc.Message) case sc.Status == corev1.ConditionTrue: triggerCondSet.Manage(ts).MarkTrue(TriggerConditionSubscribed) case sc.Status == corev1.ConditionFalse: - ts.MarkNotSubscribed(sc.Reason, sc.Message) + ts.MarkNotSubscribed(sc.Reason, "%s", sc.Message) default: ts.MarkSubscribedUnknown("SubscriptionUnknown", "The status of Subscription is invalid: %v", sc.Status) } @@ -196,11 +196,11 @@ func (ts *TriggerStatus) PropagateDependencyStatus(ks *duckv1.Source) { switch { case kc.Status == corev1.ConditionUnknown: - ts.MarkDependencyUnknown(kc.Reason, kc.Message) + ts.MarkDependencyUnknown(kc.Reason, "%s", kc.Message) case kc.Status == corev1.ConditionTrue: ts.MarkDependencySucceeded() case kc.Status == corev1.ConditionFalse: - ts.MarkDependencyFailed(kc.Reason, kc.Message) + ts.MarkDependencyFailed(kc.Reason, "%s", kc.Message) default: ts.MarkDependencyUnknown("DependencyUnknown", "The status of Dependency is invalid: %v", kc.Status) } diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1alpha1/eventtransform_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1alpha1/eventtransform_lifecycle.go index 5caf1e105b..4cb48fe57a 100644 --- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1alpha1/eventtransform_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1alpha1/eventtransform_lifecycle.go @@ -120,11 +120,11 @@ func (ts *EventTransformStatus) PropagateJsonataCertificateStatus(cs cmv1.Certif return false } if topLevel.Status == cmmeta.ConditionUnknown { - transformJsonataConditionSet.Manage(ts).MarkUnknown(TransformationJsonataDeploymentReady, TransformationJsonataCertificateNotReady, "Certificate is progressing, "+topLevel.Reason+" Message: "+topLevel.Message) + transformJsonataConditionSet.Manage(ts).MarkUnknown(TransformationJsonataDeploymentReady, TransformationJsonataCertificateNotReady, "Certificate is progressing, %s Message: %s", topLevel.Reason, topLevel.Message) return false } if topLevel.Status == cmmeta.ConditionFalse { - transformJsonataConditionSet.Manage(ts).MarkFalse(TransformationJsonataDeploymentReady, TransformationJsonataCertificateNotReady, "Certificate is not ready, "+topLevel.Reason+" Message: "+topLevel.Message) + transformJsonataConditionSet.Manage(ts).MarkFalse(TransformationJsonataDeploymentReady, TransformationJsonataCertificateNotReady, "Certificate is not ready, %s Message: %s", topLevel.Reason, topLevel.Message) return false } return true @@ -155,10 +155,10 @@ func (ts *EventTransformStatus) PropagateJsonataSinkBindingStatus(sbs sourcesv1. return true } if topLevel.IsFalse() { - transformJsonataConditionSet.Manage(ts).MarkFalse(TransformationJsonataSinkBindingReady, topLevel.Reason, topLevel.Message) + transformJsonataConditionSet.Manage(ts).MarkFalse(TransformationJsonataSinkBindingReady, topLevel.Reason, "%s", topLevel.Message) return false } - transformJsonataConditionSet.Manage(ts).MarkUnknown(TransformationJsonataSinkBindingReady, topLevel.Reason, topLevel.Message) + transformJsonataConditionSet.Manage(ts).MarkUnknown(TransformationJsonataSinkBindingReady, topLevel.Reason, "%s", topLevel.Message) return false } @@ -187,9 +187,9 @@ func (ts *EventTransformStatus) propagateTransformationConditionStatus(cond *api } else if cond.IsTrue() { ts.GetConditionSet().Manage(ts).MarkTrue(TransformationConditionReady) } else if cond.IsFalse() { - ts.GetConditionSet().Manage(ts).MarkFalse(TransformationConditionReady, cond.Reason, cond.Message) + ts.GetConditionSet().Manage(ts).MarkFalse(TransformationConditionReady, cond.Reason, "%s", cond.Message) } else { - ts.GetConditionSet().Manage(ts).MarkUnknown(TransformationConditionReady, cond.Reason, cond.Message) + ts.GetConditionSet().Manage(ts).MarkUnknown(TransformationConditionReady, cond.Reason, "%s", cond.Message) } } diff --git a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_lifecycle.go index 139487e197..b992195d0c 100644 --- a/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/eventing/v1beta1/eventtype_lifecycle.go @@ -93,11 +93,11 @@ func (et *EventTypeStatus) PropagateBrokerStatus(bs *eventingv1.BrokerStatus) { } switch { case bc.Status == corev1.ConditionUnknown: - et.MarkBrokerUnknown(bc.Reason, bc.Message) + et.MarkBrokerUnknown(bc.Reason, "%s", bc.Message) case bc.Status == corev1.ConditionTrue: eventTypeCondSet.Manage(et).MarkTrue(EventTypeConditionBrokerReady) case bc.Status == corev1.ConditionFalse: - et.MarkBrokerFailed(bc.Reason, bc.Message) + et.MarkBrokerFailed(bc.Reason, "%s", bc.Message) default: et.MarkBrokerUnknown("BrokerUnknown", "The status of Broker is invalid: %v", bc.Status) } diff --git a/vendor/knative.dev/eventing/pkg/apis/messaging/v1/channel_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/messaging/v1/channel_lifecycle.go index c8cf84a190..86e07d0a54 100644 --- a/vendor/knative.dev/eventing/pkg/apis/messaging/v1/channel_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/messaging/v1/channel_lifecycle.go @@ -122,11 +122,11 @@ func (cs *ChannelStatus) PropagateStatuses(chs *eventingduck.ChannelableStatus) } else { switch { case readyCondition.Status == corev1.ConditionUnknown: - cs.MarkBackingChannelUnknown(readyCondition.Reason, readyCondition.Message) + cs.MarkBackingChannelUnknown(readyCondition.Reason, "%s", readyCondition.Message) case readyCondition.Status == corev1.ConditionTrue: cs.MarkBackingChannelReady() case readyCondition.Status == corev1.ConditionFalse: - cs.MarkBackingChannelFailed(readyCondition.Reason, readyCondition.Message) + cs.MarkBackingChannelFailed(readyCondition.Reason, "%s", readyCondition.Message) default: cs.MarkBackingChannelUnknown("BackingChannelUnknown", "The status of BackingChannel is invalid: %v", readyCondition.Status) } diff --git a/vendor/knative.dev/eventing/pkg/apis/sinks/v1alpha1/integration_sink_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sinks/v1alpha1/integration_sink_lifecycle.go index 78e1418b9f..186a5d4b1d 100644 --- a/vendor/knative.dev/eventing/pkg/apis/sinks/v1alpha1/integration_sink_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/sinks/v1alpha1/integration_sink_lifecycle.go @@ -132,13 +132,13 @@ func (s *IntegrationSinkStatus) PropagateDeploymentStatus(d *appsv1.Deployment) if cond.Type == appsv1.DeploymentAvailable { deploymentAvailableFound = true if cond.Status == corev1.ConditionFalse { - IntegrationSinkCondSet.Manage(s).MarkFalse(IntegrationSinkConditionDeploymentReady, cond.Reason, cond.Message) + IntegrationSinkCondSet.Manage(s).MarkFalse(IntegrationSinkConditionDeploymentReady, cond.Reason, "%s", cond.Message) return } } // Also check Progressing condition for failures (e.g., ImagePullBackOff, insufficient quota) if cond.Type == appsv1.DeploymentProgressing && cond.Status == corev1.ConditionFalse { - IntegrationSinkCondSet.Manage(s).MarkFalse(IntegrationSinkConditionDeploymentReady, cond.Reason, cond.Message) + IntegrationSinkCondSet.Manage(s).MarkFalse(IntegrationSinkConditionDeploymentReady, cond.Reason, "%s", cond.Message) return } } @@ -171,13 +171,13 @@ func (s *IntegrationSinkStatus) PropagateCertificateStatus(cs cmv1.CertificateSt if topLevel.Status == cmmeta.ConditionUnknown { IntegrationSinkCondSet.Manage(s).MarkUnknown(IntegrationSinkConditionCertificateReady, - IntegrationSinkCertificateNotReady, "Certificate is progressing, "+topLevel.Reason+" Message: "+topLevel.Message) + IntegrationSinkCertificateNotReady, "Certificate is progressing, %s Message: %s", topLevel.Reason, topLevel.Message) return false } if topLevel.Status == cmmeta.ConditionFalse { IntegrationSinkCondSet.Manage(s).MarkFalse(IntegrationSinkConditionCertificateReady, - IntegrationSinkCertificateNotReady, "Certificate is not ready, "+topLevel.Reason+" Message: "+topLevel.Message) + IntegrationSinkCertificateNotReady, "Certificate is not ready, %s Message: %s", topLevel.Reason, topLevel.Message) return false } @@ -201,7 +201,7 @@ func (s *IntegrationSinkStatus) SetAddresses(addresses ...duckv1.Addressable) { // MarkFailedTrustBundlePropagation marks the IntegrationSink's SinkBindingTrustBundlePropagated condition to False with // the provided reason and message. func (s *IntegrationSinkStatus) MarkFailedTrustBundlePropagation(reason, message string) { - IntegrationSinkCondSet.Manage(s).MarkFalse(IntegrationSinkTrustBundlePropagated, reason, message) + IntegrationSinkCondSet.Manage(s).MarkFalse(IntegrationSinkTrustBundlePropagated, reason, "%s", message) } // MarkTrustBundlePropagated marks the IntegrationSink's SinkBindingTrustBundlePropagated condition to True. diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1/apiserver_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/apiserver_lifecycle.go index 67aac5b69c..014671ff83 100644 --- a/vendor/knative.dev/eventing/pkg/apis/sources/v1/apiserver_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/apiserver_lifecycle.go @@ -112,9 +112,9 @@ func (s *ApiServerSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deploy apiserverCondSet.Manage(s).MarkUnknown(ApiServerConditionDeployed, "DeploymentUpdating", "Deployment has %d unavailable replica(s).", d.Status.UnavailableReplicas) } } else if cond.Status == corev1.ConditionFalse { - apiserverCondSet.Manage(s).MarkFalse(ApiServerConditionDeployed, cond.Reason, cond.Message) + apiserverCondSet.Manage(s).MarkFalse(ApiServerConditionDeployed, cond.Reason, "%s", cond.Message) } else if cond.Status == corev1.ConditionUnknown { - apiserverCondSet.Manage(s).MarkUnknown(ApiServerConditionDeployed, cond.Reason, cond.Message) + apiserverCondSet.Manage(s).MarkUnknown(ApiServerConditionDeployed, cond.Reason, "%s", cond.Message) } } } diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1/container_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/container_lifecycle.go index 79ac2aa2a3..9a09da854b 100644 --- a/vendor/knative.dev/eventing/pkg/apis/sources/v1/container_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/container_lifecycle.go @@ -80,11 +80,11 @@ func (s *ContainerSourceStatus) PropagateSinkBindingStatus(status *SinkBindingSt case cond.Status == corev1.ConditionTrue: containerCondSet.Manage(s).MarkTrue(ContainerSourceConditionSinkBindingReady) case cond.Status == corev1.ConditionFalse: - containerCondSet.Manage(s).MarkFalse(ContainerSourceConditionSinkBindingReady, cond.Reason, cond.Message) + containerCondSet.Manage(s).MarkFalse(ContainerSourceConditionSinkBindingReady, cond.Reason, "%s", cond.Message) case cond.Status == corev1.ConditionUnknown: - containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionSinkBindingReady, cond.Reason, cond.Message) + containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionSinkBindingReady, cond.Reason, "%s", cond.Message) default: - containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionSinkBindingReady, cond.Reason, cond.Message) + containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionSinkBindingReady, cond.Reason, "%s", cond.Message) } // Propagate SinkBindings AuthStatus to containersources AuthStatus @@ -101,9 +101,9 @@ func (s *ContainerSourceStatus) PropagateReceiveAdapterStatus(d *appsv1.Deployme if cond.Status == corev1.ConditionTrue { containerCondSet.Manage(s).MarkTrue(ContainerSourceConditionReceiveAdapterReady) } else if cond.Status == corev1.ConditionFalse { - containerCondSet.Manage(s).MarkFalse(ContainerSourceConditionReceiveAdapterReady, cond.Reason, cond.Message) + containerCondSet.Manage(s).MarkFalse(ContainerSourceConditionReceiveAdapterReady, cond.Reason, "%s", cond.Message) } else if cond.Status == corev1.ConditionUnknown { - containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionReceiveAdapterReady, cond.Reason, cond.Message) + containerCondSet.Manage(s).MarkUnknown(ContainerSourceConditionReceiveAdapterReady, cond.Reason, "%s", cond.Message) } } } diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_lifecycle.go index 7518c80118..3f6503c7da 100644 --- a/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/ping_lifecycle.go @@ -123,9 +123,9 @@ func (s *PingSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment) PingSourceCondSet.Manage(s).MarkUnknown(PingSourceConditionDeployed, "DeploymentUpdating", "Deployment has %d unavailable replica(s).", d.Status.UnavailableReplicas) } } else if cond.Status == corev1.ConditionFalse { - PingSourceCondSet.Manage(s).MarkFalse(PingSourceConditionDeployed, cond.Reason, cond.Message) + PingSourceCondSet.Manage(s).MarkFalse(PingSourceConditionDeployed, cond.Reason, "%s", cond.Message) } else if cond.Status == corev1.ConditionUnknown { - PingSourceCondSet.Manage(s).MarkUnknown(PingSourceConditionDeployed, cond.Reason, cond.Message) + PingSourceCondSet.Manage(s).MarkUnknown(PingSourceConditionDeployed, cond.Reason, "%s", cond.Message) } } } diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1/sinkbinding_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1/sinkbinding_lifecycle.go index 746e7ddcdc..4c65513907 100644 --- a/vendor/knative.dev/eventing/pkg/apis/sources/v1/sinkbinding_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1/sinkbinding_lifecycle.go @@ -88,7 +88,7 @@ func (sbs *SinkBindingStatus) InitializeConditions() { // MarkBindingUnavailable marks the SinkBinding's Ready condition to False with // the provided reason and message. func (sbs *SinkBindingStatus) MarkBindingUnavailable(reason, message string) { - sbCondSet.Manage(sbs).MarkFalse(SinkBindingConditionAvailable, reason, message) + sbCondSet.Manage(sbs).MarkFalse(SinkBindingConditionAvailable, reason, "%s", message) } // MarkBindingAvailable marks the SinkBinding's Ready condition to True. @@ -99,7 +99,7 @@ func (sbs *SinkBindingStatus) MarkBindingAvailable() { // MarkFailedTrustBundlePropagation marks the SinkBinding's SinkBindingTrustBundlePropagated condition to False with // the provided reason and message. func (sbs *SinkBindingStatus) MarkFailedTrustBundlePropagation(reason, message string) { - sbCondSet.Manage(sbs).MarkFalse(SinkBindingTrustBundlePropagated, reason, message) + sbCondSet.Manage(sbs).MarkFalse(SinkBindingTrustBundlePropagated, reason, "%s", message) } // MarkTrustBundlePropagated marks the SinkBinding's SinkBindingTrustBundlePropagated condition to True. diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/integration_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/integration_lifecycle.go index cc1270fb8b..be79ea5cf1 100644 --- a/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/integration_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/integration_lifecycle.go @@ -64,11 +64,11 @@ func (s *IntegrationSourceStatus) PropagateContainerSourceStatus(status *v1.Cont case cond.Status == corev1.ConditionTrue: IntegrationCondSet.Manage(s).MarkTrue(IntegrationSourceConditionContainerSourceReady) case cond.Status == corev1.ConditionFalse: - IntegrationCondSet.Manage(s).MarkFalse(IntegrationSourceConditionContainerSourceReady, cond.Reason, cond.Message) + IntegrationCondSet.Manage(s).MarkFalse(IntegrationSourceConditionContainerSourceReady, cond.Reason, "%s", cond.Message) case cond.Status == corev1.ConditionUnknown: - IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, cond.Reason, cond.Message) + IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, cond.Reason, "%s", cond.Message) default: - IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, cond.Reason, cond.Message) + IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, cond.Reason, "%s", cond.Message) } // Propagate ContainerSources AuthStatus to IntegrationSources AuthStatus diff --git a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta2/ping_lifecycle.go b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta2/ping_lifecycle.go index 4ca010aa73..dc81202810 100644 --- a/vendor/knative.dev/eventing/pkg/apis/sources/v1beta2/ping_lifecycle.go +++ b/vendor/knative.dev/eventing/pkg/apis/sources/v1beta2/ping_lifecycle.go @@ -110,9 +110,9 @@ func (s *PingSourceStatus) PropagateDeploymentAvailability(d *appsv1.Deployment) if cond.Status == corev1.ConditionTrue { PingSourceCondSet.Manage(s).MarkTrue(PingSourceConditionDeployed) } else if cond.Status == corev1.ConditionFalse { - PingSourceCondSet.Manage(s).MarkFalse(PingSourceConditionDeployed, cond.Reason, cond.Message) + PingSourceCondSet.Manage(s).MarkFalse(PingSourceConditionDeployed, cond.Reason, "%s", cond.Message) } else if cond.Status == corev1.ConditionUnknown { - PingSourceCondSet.Manage(s).MarkUnknown(PingSourceConditionDeployed, cond.Reason, cond.Message) + PingSourceCondSet.Manage(s).MarkUnknown(PingSourceConditionDeployed, cond.Reason, "%s", cond.Message) } } } diff --git a/vendor/knative.dev/eventing/test/rekt/resources/delivery/delivery.go b/vendor/knative.dev/eventing/test/rekt/resources/delivery/delivery.go index 6faaa5259e..6021722bed 100644 --- a/vendor/knative.dev/eventing/test/rekt/resources/delivery/delivery.go +++ b/vendor/knative.dev/eventing/test/rekt/resources/delivery/delivery.go @@ -117,6 +117,18 @@ func WithRetry(count int32, backoffPolicy *eventingv1.BackoffPolicyType, backoff } } +// WithBackoffMax adds the maximum backoff duration to the delivery config. +func WithBackoffMax(backoffMax string) manifest.CfgFn { + return func(cfg map[string]interface{}) { + if _, set := cfg["delivery"]; !set { + cfg["delivery"] = map[string]interface{}{} + } + delivery := cfg["delivery"].(map[string]interface{}) + + delivery["backoffMax"] = backoffMax + } +} + func WithFormat(format string) manifest.CfgFn { return func(cfg map[string]interface{}) { if _, set := cfg["delivery"]; !set { diff --git a/vendor/knative.dev/eventing/test/rekt/resources/trigger/trigger.go b/vendor/knative.dev/eventing/test/rekt/resources/trigger/trigger.go index 790e85e769..1a55e7620e 100644 --- a/vendor/knative.dev/eventing/test/rekt/resources/trigger/trigger.go +++ b/vendor/knative.dev/eventing/test/rekt/resources/trigger/trigger.go @@ -194,6 +194,9 @@ var WithDeadLetterSinkFromDestination = delivery.WithDeadLetterSinkFromDestinati // WithRetry adds the retry related config to a Trigger spec. var WithRetry = delivery.WithRetry +// WithBackoffMax adds the maximum backoff duration to a Trigger spec. +var WithBackoffMax = delivery.WithBackoffMax + // WithTimeout adds the timeout related config to the config. var WithTimeout = delivery.WithTimeout diff --git a/vendor/knative.dev/eventing/test/rekt/resources/trigger/trigger.yaml b/vendor/knative.dev/eventing/test/rekt/resources/trigger/trigger.yaml index b7825ffb5d..79b9831b44 100644 --- a/vendor/knative.dev/eventing/test/rekt/resources/trigger/trigger.yaml +++ b/vendor/knative.dev/eventing/test/rekt/resources/trigger/trigger.yaml @@ -96,6 +96,9 @@ spec: {{ if .delivery.backoffDelay }} backoffDelay: "{{ .delivery.backoffDelay}}" {{ end }} + {{ if .delivery.backoffMax }} + backoffMax: "{{ .delivery.backoffMax}}" + {{ end }} {{ if .delivery.format }} format: {{ .delivery.format }} {{ end }} diff --git a/vendor/knative.dev/networking/pkg/apis/networking/v1alpha1/certificate_lifecycle.go b/vendor/knative.dev/networking/pkg/apis/networking/v1alpha1/certificate_lifecycle.go index 3a3deba075..9ec83f748f 100644 --- a/vendor/knative.dev/networking/pkg/apis/networking/v1alpha1/certificate_lifecycle.go +++ b/vendor/knative.dev/networking/pkg/apis/networking/v1alpha1/certificate_lifecycle.go @@ -17,8 +17,6 @@ limitations under the License. package v1alpha1 import ( - "fmt" - "k8s.io/apimachinery/pkg/runtime/schema" "knative.dev/pkg/apis" ) @@ -35,19 +33,19 @@ func (cs *CertificateStatus) MarkReady() { // MarkNotReady marks the certificate status as unknown. func (cs *CertificateStatus) MarkNotReady(reason, message string) { - certificateCondSet.Manage(cs).MarkUnknown(CertificateConditionReady, reason, message) + certificateCondSet.Manage(cs).MarkUnknown(CertificateConditionReady, reason, "%s", message) } // MarkFailed marks the certificate as not ready. func (cs *CertificateStatus) MarkFailed(reason, message string) { - certificateCondSet.Manage(cs).MarkFalse(CertificateConditionReady, reason, message) + certificateCondSet.Manage(cs).MarkFalse(CertificateConditionReady, reason, "%s", message) } // MarkResourceNotOwned changes the ready condition to false to reflect that we don't own the // resource of the given kind and name. func (cs *CertificateStatus) MarkResourceNotOwned(kind, name string) { certificateCondSet.Manage(cs).MarkFalse(CertificateConditionReady, "NotOwned", - fmt.Sprintf("There is an existing %s %q that we do not own.", kind, name)) + "There is an existing %s %q that we do not own.", kind, name) } // IsReady returns true is the Certificate is ready diff --git a/vendor/knative.dev/networking/pkg/apis/networking/v1alpha1/ingress_lifecycle.go b/vendor/knative.dev/networking/pkg/apis/networking/v1alpha1/ingress_lifecycle.go index 451a91f959..80385daf3d 100644 --- a/vendor/knative.dev/networking/pkg/apis/networking/v1alpha1/ingress_lifecycle.go +++ b/vendor/knative.dev/networking/pkg/apis/networking/v1alpha1/ingress_lifecycle.go @@ -17,8 +17,6 @@ limitations under the License. package v1alpha1 import ( - "fmt" - "k8s.io/apimachinery/pkg/runtime/schema" "knative.dev/pkg/apis" ) @@ -57,7 +55,7 @@ func (is *IngressStatus) MarkNetworkConfigured() { // resource of the given kind and name has already been created, and we do not own it. func (is *IngressStatus) MarkResourceNotOwned(kind, name string) { ingressCondSet.Manage(is).MarkFalse(IngressConditionNetworkConfigured, "NotOwned", - fmt.Sprintf("There is an existing %s %q that we do not own.", kind, name)) + "There is an existing %s %q that we do not own.", kind, name) } // MarkLoadBalancerReady marks the Ingress with IngressConditionLoadBalancerReady, @@ -78,12 +76,12 @@ func (is *IngressStatus) MarkLoadBalancerNotReady() { // MarkLoadBalancerFailed marks the "IngressConditionLoadBalancerReady" condition to false. func (is *IngressStatus) MarkLoadBalancerFailed(reason, message string) { - ingressCondSet.Manage(is).MarkFalse(IngressConditionLoadBalancerReady, reason, message) + ingressCondSet.Manage(is).MarkFalse(IngressConditionLoadBalancerReady, reason, "%s", message) } // MarkIngressNotReady marks the "IngressConditionReady" condition to unknown. func (is *IngressStatus) MarkIngressNotReady(reason, message string) { - ingressCondSet.Manage(is).MarkUnknown(IngressConditionReady, reason, message) + ingressCondSet.Manage(is).MarkUnknown(IngressConditionReady, reason, "%s", message) } // IsReady returns true if the Status condition MetricConditionReady diff --git a/vendor/modules.txt b/vendor/modules.txt index 3441d8ba65..5a76539e39 100644 --- a/vendor/modules.txt +++ b/vendor/modules.txt @@ -1066,7 +1066,7 @@ google.golang.org/genproto/googleapis/api/monitoredres google.golang.org/genproto/googleapis/rpc/code google.golang.org/genproto/googleapis/rpc/errdetails google.golang.org/genproto/googleapis/rpc/status -# google.golang.org/grpc v1.83.1 +# google.golang.org/grpc v1.83.2 ## explicit; go 1.25.0 google.golang.org/grpc google.golang.org/grpc/attributes @@ -1878,7 +1878,7 @@ k8s.io/utils/trace ## explicit; go 1.25.0 knative.dev/caching/pkg/apis/caching knative.dev/caching/pkg/apis/caching/v1alpha1 -# knative.dev/eventing v0.50.1-0.20260907114944-07b1e8ab96e5 +# knative.dev/eventing v0.50.1-0.20260921114233-7c892cfc4d72 ## explicit; go 1.25.0 knative.dev/eventing/cmd/heartbeats knative.dev/eventing/pkg/apis @@ -1974,7 +1974,7 @@ knative.dev/eventing/test/upgrade/prober/wathola/sender # knative.dev/hack v0.0.0-20260428014158-b2a37f1b6e7b ## explicit; go 1.24 knative.dev/hack -# knative.dev/networking v0.0.0-20260821014922-17b28c62e1cb +# knative.dev/networking v0.0.0-20260919094129-7d916c7f8aa5 ## explicit; go 1.25.0 knative.dev/networking/pkg/apis/networking knative.dev/networking/pkg/apis/networking/v1alpha1 @@ -1985,7 +1985,7 @@ knative.dev/networking/pkg/client/clientset/versioned/typed/networking/v1alpha1 knative.dev/networking/pkg/config knative.dev/networking/pkg/http/header knative.dev/networking/pkg/ingress -# knative.dev/pkg v0.0.0-20260825072334-d2a153acc00c +# knative.dev/pkg v0.0.0-20260918182429-5dc1978f0042 ## explicit; go 1.25.0 knative.dev/pkg/apiextensions/storageversion knative.dev/pkg/apiextensions/storageversion/cmd/migrate @@ -2077,7 +2077,7 @@ knative.dev/pkg/webhook knative.dev/pkg/webhook/certificates knative.dev/pkg/webhook/certificates/resources knative.dev/pkg/webhook/resourcesemantics/conversion -# knative.dev/reconciler-test v0.0.0-20260821021027-c844fc2204aa +# knative.dev/reconciler-test v0.0.0-20260921021034-087b0fddd896 ## explicit; go 1.25.0 knative.dev/reconciler-test/cmd/eventshub knative.dev/reconciler-test/pkg/environment @@ -2106,7 +2106,7 @@ knative.dev/reconciler-test/pkg/resources/service knative.dev/reconciler-test/pkg/resources/serviceaccount knative.dev/reconciler-test/pkg/state knative.dev/reconciler-test/resources/certificate -# knative.dev/serving v0.50.1-0.20260825144834-618b0c275af1 +# knative.dev/serving v0.50.1-0.20260921122632-47ddb67c5cf2 ## explicit; go 1.25.0 knative.dev/serving/pkg/apis/autoscaling knative.dev/serving/pkg/apis/autoscaling/v1alpha1