Skip to content

Commit

Permalink
upgrade to latest dependencies
Browse files Browse the repository at this point in the history
bumping knative.dev/hack ce4c934...306ce74:
  > 306ce74 Update community files (# 414)
bumping knative.dev/eventing cee6e8c...fe83e25:
  > fe83e25 EventTransform: add reconciler unit tests (# 8513)
  > 1e889be SinkBinding: Set specific conditions for reconciler steps (# 8508)
  > 6073039 [main] Upgrade to latest dependencies (# 8512)
  > 3153b47 EventTransform: Inject tracing configurations (# 8479)
  > db0cf43 Update to the correct file (# 8507)
  > adaafa2 [Automated] Update eventing-eventing-integrations nightly (# 8506)
  > 714deeb Update k8s version in e2e tests (# 8503)
  > 54a2402 Fix golangci exclude config (# 8502)
  > 80dd84e Guard reserved access with lock and create vpods in tests (# 8457)
  > 5bcee30 Inject integration images from ConfigMap (# 8500)
  > ae049c8 Jsonata Event transform e2e tests (# 8499)
  > c828898 Generic code for Certificates (# 8489)
  > 351898d fix: verify trigger is not ready before pingsource dependency exists (# 8494)
  > c651616 Add initial iteration of eventing-integration resources (# 8493)
  > 51637df IntegrationSink prefactors (# 8486)
  > c429fc5 Remove unused code (# 8485)
  > 732ec62 Partial implementation of certmanager for integration sink (# 8481)
  > 5998cfe [main] Update community files (# 8480)
  > 9a7c6d5 [main] Upgrade to latest dependencies (# 8468)
bumping knative.dev/eventing-kafka-broker aed6672...d7042ae:
  > d7042ae Format go code (# 4268)
  > 902f7c0 Bump logging bundle in one batch, to latest (# 4278)
  > 06de84b 💫 Bump latest Quarkus and relevant dependencies (# 4270)
  > 7edc377 client: Allow configurable sarama conf.Version (# 4266)
  > 46550f1 Update community files (# 4267)
bumping knative.dev/pkg c925de2...0372c08:
  > 0372c08 Bump github.com/google/go-cmp from 0.6.0 to 0.7.0 (# 3152)
  > 9e26561 Update community files (# 3151)
bumping knative.dev/eventing-redis 70186dd...4a291f6:
  > 4a291f6 Update community files (# 649)
bumping github.com/google/go-cmp c3ad843...9b12f36:
  > 9b12f36 Detect proto.Message types when failing to export a field (# 370)
  > 4dd3d63 fix: type 'aribica' => 'arabica' (# 368)
  > 391980c Support compare functions with SortSlices and SortMaps (# 367)
bumping knative.dev/reconciler-test 62eb465...5ca0bd4:
  > 5ca0bd4 Update community files (# 786)

Signed-off-by: Knative Automation <[email protected]>
  • Loading branch information
knative-automation committed Feb 28, 2025
1 parent 43eabab commit 0b7494f
Show file tree
Hide file tree
Showing 89 changed files with 864 additions and 781 deletions.
14 changes: 7 additions & 7 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -11,12 +11,12 @@ require (
k8s.io/apimachinery v0.32.2
k8s.io/client-go v0.32.2
k8s.io/code-generator v0.32.2
knative.dev/eventing v0.44.1-0.20250217174749-cee6e8cca430
knative.dev/eventing-kafka-broker v0.43.1-0.20250214124052-aed6672d6d58
knative.dev/eventing-redis v0.44.1-0.20250217113756-70186ddb9bf0
knative.dev/hack v0.0.0-20250217122557-ce4c934f30e5
knative.dev/pkg v0.0.0-20250218011850-c925de2a3f07
knative.dev/reconciler-test v0.0.0-20250217113456-62eb465c1406
knative.dev/eventing v0.44.1-0.20250227153031-fe83e25214e9
knative.dev/eventing-kafka-broker v0.43.1-0.20250227113229-d7042ae105b4
knative.dev/eventing-redis v0.44.1-0.20250219014743-4a291f60c89c
knative.dev/hack v0.0.0-20250219013704-306ce745e077
knative.dev/pkg v0.0.0-20250226145529-0372c089c78f
knative.dev/reconciler-test v0.0.0-20250219013557-5ca0bd4fcad5
sigs.k8s.io/controller-runtime v0.13.1
)

Expand Down Expand Up @@ -48,7 +48,7 @@ require (
github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
github.com/golang/protobuf v1.5.4 // indirect
github.com/google/gnostic-models v0.6.9 // indirect
github.com/google/go-cmp v0.6.0 // indirect
github.com/google/go-cmp v0.7.0 // indirect
github.com/google/gofuzz v1.2.0 // indirect
github.com/google/uuid v1.6.0 // indirect
github.com/grpc-ecosystem/grpc-gateway/v2 v2.26.1 // indirect
Expand Down
32 changes: 16 additions & 16 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -193,8 +193,8 @@ github.com/google/go-cmp v0.5.4/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/
github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/google/go-cmp v0.5.8/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
github.com/google/go-cmp v0.5.9/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
github.com/google/gofuzz v1.2.0 h1:xRy4A+RhZaiKjJ1bPfwQ8sedCA+YS2YcCHW6ec7JMi0=
github.com/google/gofuzz v1.2.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
Expand Down Expand Up @@ -411,8 +411,8 @@ go.opentelemetry.io/otel/sdk v1.34.0 h1:95zS4k/2GOy069d321O8jWgYsW3MzVV+KuSPKp7W
go.opentelemetry.io/otel/sdk v1.34.0/go.mod h1:0e/pNiaMAqaykJGKbi+tSjWfNNHMTxoC9qANsCzbyxU=
go.opentelemetry.io/otel/sdk/metric v1.32.0 h1:rZvFnvmvawYb0alrYkjraqJq0Z4ZUJAiyYCU9snn1CU=
go.opentelemetry.io/otel/sdk/metric v1.32.0/go.mod h1:PWeZlq0zt9YkYAp3gjKZ0eicRYvOh1Gd+X99x6GHpCQ=
go.opentelemetry.io/otel/trace v1.32.0 h1:WIC9mYrXf8TmY/EXuULKc8hR17vE+Hjv2cssQDe03fM=
go.opentelemetry.io/otel/trace v1.32.0/go.mod h1:+i4rkvCraA+tG6AzwloGaCtkx53Fa+L+V8e9a7YvhT8=
go.opentelemetry.io/otel/trace v1.34.0 h1:+ouXS2V8Rd4hp4580a8q23bg0azF2nI8cqLYnC8mh/k=
go.opentelemetry.io/otel/trace v1.34.0/go.mod h1:Svm7lSjQD7kG7KJ/MUHPVXSDGz2OX4h0M2jHBhmSfRE=
go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
go.uber.org/atomic v1.10.0 h1:9qC72Qh0+3MqyJbAn8YU5xVq1frD8bn3JtD2oXtafVQ=
go.uber.org/atomic v1.10.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0=
Expand Down Expand Up @@ -787,18 +787,18 @@ k8s.io/kube-openapi v0.0.0-20241212222426-2c72e554b1e7 h1:hcha5B1kVACrLujCKLbr8X
k8s.io/kube-openapi v0.0.0-20241212222426-2c72e554b1e7/go.mod h1:GewRfANuJ70iYzvn+i4lezLDAFzvjxZYK1gn1lWcfas=
k8s.io/utils v0.0.0-20241210054802-24370beab758 h1:sdbE21q2nlQtFh65saZY+rRM6x6aJJI8IUa1AmH/qa0=
k8s.io/utils v0.0.0-20241210054802-24370beab758/go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0=
knative.dev/eventing v0.44.1-0.20250217174749-cee6e8cca430 h1:8tYtWlsRLzEgEs6XUygCNTQOQnCtSQluPBU4oIUaKD8=
knative.dev/eventing v0.44.1-0.20250217174749-cee6e8cca430/go.mod h1:Q/hVpW4CHEdx7vrMYRiGYw2mQdbREwqbkW050ZNgKho=
knative.dev/eventing-kafka-broker v0.43.1-0.20250214124052-aed6672d6d58 h1:1XgjenV1S2upvgB1uCkOONtPj4iI7VZL9tGi8QcDWD0=
knative.dev/eventing-kafka-broker v0.43.1-0.20250214124052-aed6672d6d58/go.mod h1:6/XGyq5tLpNztFYNDyvLeUZ/a3qUSkrp9JEet7N2AtU=
knative.dev/eventing-redis v0.44.1-0.20250217113756-70186ddb9bf0 h1:V1Aq7GGYbVANvjnNN5SLj1ymaCQuppngkbbL6/TkHr0=
knative.dev/eventing-redis v0.44.1-0.20250217113756-70186ddb9bf0/go.mod h1:h+V1PCDjvxq768ULHX4NqGgc8FX9dZnQWvB2LA2fGvI=
knative.dev/hack v0.0.0-20250217122557-ce4c934f30e5 h1:BIkxsbG01S563JJ68n4SIeIpizDlAcf1vgss6b1QAhE=
knative.dev/hack v0.0.0-20250217122557-ce4c934f30e5/go.mod h1:R0ritgYtjLDO9527h5vb5X6gfvt5LCrJ55BNbVDsWiY=
knative.dev/pkg v0.0.0-20250218011850-c925de2a3f07 h1:uqBiMwd2Es/qA63Qda5qdjCjzhm2f4/Fh7SUVY6EgFc=
knative.dev/pkg v0.0.0-20250218011850-c925de2a3f07/go.mod h1:ogeAD7DbAoOeKK7fIwUYsEerf+dnEIjJpeAtOYcoyRk=
knative.dev/reconciler-test v0.0.0-20250217113456-62eb465c1406 h1:2qEiveD8LKwWPZmjTjhgy0MPChPJbPMXf8CpRvogjTI=
knative.dev/reconciler-test v0.0.0-20250217113456-62eb465c1406/go.mod h1:MgX538jlc+yX6k2wWWVPspP64eqLnw/0OAVdTeJJLEM=
knative.dev/eventing v0.44.1-0.20250227153031-fe83e25214e9 h1:rkeydldG+qoe0xPzviUWA7OpldeG9WMztGUMsEjSfQo=
knative.dev/eventing v0.44.1-0.20250227153031-fe83e25214e9/go.mod h1:WsyK1x7DoajDF7Vim1f4prGv6fEP9WbkiZYX/na8IK8=
knative.dev/eventing-kafka-broker v0.43.1-0.20250227113229-d7042ae105b4 h1:3o03X3zrUiBqYxzrysjjCai093QMECRcsncRD9+UFcw=
knative.dev/eventing-kafka-broker v0.43.1-0.20250227113229-d7042ae105b4/go.mod h1:6/XGyq5tLpNztFYNDyvLeUZ/a3qUSkrp9JEet7N2AtU=
knative.dev/eventing-redis v0.44.1-0.20250219014743-4a291f60c89c h1:QlzOtHe02RpuYkLwsTsje5M0kMryEHs0SMFSgu2nSc8=
knative.dev/eventing-redis v0.44.1-0.20250219014743-4a291f60c89c/go.mod h1:h+V1PCDjvxq768ULHX4NqGgc8FX9dZnQWvB2LA2fGvI=
knative.dev/hack v0.0.0-20250219013704-306ce745e077 h1:kcYrHAI+x7KHChjFfJ37Sq5QNAIwQExRor+g6Rbg1K0=
knative.dev/hack v0.0.0-20250219013704-306ce745e077/go.mod h1:R0ritgYtjLDO9527h5vb5X6gfvt5LCrJ55BNbVDsWiY=
knative.dev/pkg v0.0.0-20250226145529-0372c089c78f h1:udznvloLcWaixDGrENQ9HRcj1fiMlE6cP8L0V3K4V74=
knative.dev/pkg v0.0.0-20250226145529-0372c089c78f/go.mod h1:ijkSiVyNl0yTjfRsGx3infOo9ohlyE1lTCri9iUHR80=
knative.dev/reconciler-test v0.0.0-20250219013557-5ca0bd4fcad5 h1:1j57zjXSniTDmw9p55y6GRQ5FbBRthLm9ytCkiRZNxg=
knative.dev/reconciler-test v0.0.0-20250219013557-5ca0bd4fcad5/go.mod h1:MgX538jlc+yX6k2wWWVPspP64eqLnw/0OAVdTeJJLEM=
rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
rsc.io/quote/v3 v3.1.0/go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0=
rsc.io/sampler v1.3.0/go.mod h1:T1hPZKmBbMNahiBKFy5HrXp6adAjACjK9JXDnKaTXpA=
Expand Down
64 changes: 44 additions & 20 deletions vendor/github.com/google/go-cmp/cmp/cmpopts/sort.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

7 changes: 7 additions & 0 deletions vendor/github.com/google/go-cmp/cmp/internal/function/func.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

10 changes: 9 additions & 1 deletion vendor/github.com/google/go-cmp/cmp/options.go

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
Expand Up @@ -87,25 +87,26 @@ func (ts *EventTransformStatus) InitializeConditions() {
ts.GetConditionSet().Manage(ts).InitializeConditions()
}

func (ts *EventTransformStatus) PropagateJsonataDeploymentStatus(ds appsv1.DeploymentStatus) {
func (ts *EventTransformStatus) PropagateJsonataDeploymentStatus(ds appsv1.DeploymentStatus) bool {
defer ts.propagateTransformJsonataReadiness()
if ts.JsonataTransformationStatus == nil {
ts.JsonataTransformationStatus = &JsonataEventTransformationStatus{}
}
ts.JsonataTransformationStatus.Deployment = ds
if ds.Replicas > 0 && ds.Replicas == ds.AvailableReplicas {
transformJsonataConditionSet.Manage(ts).MarkTrue(TransformationJsonataDeploymentReady)
} else {
transformJsonataConditionSet.Manage(ts).MarkFalse(TransformationJsonataDeploymentReady, TransformationJsonataDeploymentUnavailable, "Expected replicas: %d, available: %d", ds.Replicas, ds.AvailableReplicas)
return true
}
transformJsonataConditionSet.Manage(ts).MarkFalse(TransformationJsonataDeploymentReady, TransformationJsonataDeploymentUnavailable, "Expected replicas: %d, available: %d", ds.Replicas, ds.AvailableReplicas)
return false
}

func (ts *EventTransformStatus) PropagateJsonataSinkBindingUnset() {
defer ts.propagateTransformJsonataReadiness()
transformJsonataConditionSet.Manage(ts).MarkTrue(TransformationJsonataSinkBindingReady)
}

func (ts *EventTransformStatus) PropagateJsonataSinkBindingStatus(sbs sourcesv1.SinkBindingStatus) {
func (ts *EventTransformStatus) PropagateJsonataSinkBindingStatus(sbs sourcesv1.SinkBindingStatus) bool {
defer ts.propagateTransformJsonataReadiness()
if ts.JsonataTransformationStatus == nil {
ts.JsonataTransformationStatus = &JsonataEventTransformationStatus{}
Expand All @@ -118,15 +119,18 @@ func (ts *EventTransformStatus) PropagateJsonataSinkBindingStatus(sbs sourcesv1.
topLevel := sbs.GetCondition(apis.ConditionReady)
if topLevel == nil {
transformJsonataConditionSet.Manage(ts).MarkUnknown(TransformationJsonataSinkBindingReady, "", "")
return
return false
}
if topLevel.IsTrue() {
transformJsonataConditionSet.Manage(ts).MarkTrue(TransformationJsonataSinkBindingReady)
} else if topLevel.IsFalse() {
return true
}
if topLevel.IsFalse() {
transformJsonataConditionSet.Manage(ts).MarkFalse(TransformationJsonataSinkBindingReady, topLevel.Reason, topLevel.Message)
} else {
transformJsonataConditionSet.Manage(ts).MarkUnknown(TransformationJsonataSinkBindingReady, topLevel.Reason, topLevel.Message)
return false
}
transformJsonataConditionSet.Manage(ts).MarkUnknown(TransformationJsonataSinkBindingReady, topLevel.Reason, topLevel.Message)
return false
}

func (ts *EventTransformStatus) propagateTransformJsonataReadiness() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -41,15 +41,15 @@ type IntegrationSink struct {
Status IntegrationSinkStatus `json:"status,omitempty"`
}

// Check the interfaces that JobSink should be implementing.
// Check the interfaces that IntegrationSink should be implementing.
var (
_ runtime.Object = (*IntegrationSink)(nil)
_ kmeta.OwnerRefable = (*IntegrationSink)(nil)
_ apis.Validatable = (*IntegrationSink)(nil)
_ apis.Defaultable = (*IntegrationSink)(nil)
_ apis.HasSpec = (*IntegrationSink)(nil)
_ duckv1.KRShaped = (*IntegrationSink)(nil)
_ apis.Convertible = (*JobSink)(nil)
_ apis.Convertible = (*IntegrationSink)(nil)
)

type IntegrationSinkSpec struct {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,9 +42,11 @@ const (
)

var sbCondSet = apis.NewLivingConditionSet(
SinkBindingConditionAvailable,
SinkBindingConditionSinkProvided,
SinkBindingConditionOIDCIdentityCreated,
SinkBindingConditionOIDCTokenSecretCreated,
SinkBindingTrustBundlePropagated,
)

// GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
Expand Down Expand Up @@ -86,12 +88,23 @@ 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(SinkBindingConditionReady, reason, message)
sbCondSet.Manage(sbs).MarkFalse(SinkBindingConditionAvailable, reason, message)
}

// MarkBindingAvailable marks the SinkBinding's Ready condition to True.
func (sbs *SinkBindingStatus) MarkBindingAvailable() {
sbCondSet.Manage(sbs).MarkTrue(SinkBindingConditionReady)
sbCondSet.Manage(sbs).MarkTrue(SinkBindingConditionAvailable)
}

// 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)
}

// MarkTrustBundlePropagated marks the SinkBinding's SinkBindingTrustBundlePropagated condition to True.
func (sbs *SinkBindingStatus) MarkTrustBundlePropagated() {
sbCondSet.Manage(sbs).MarkTrue(SinkBindingTrustBundlePropagated)
}

// MarkSink sets the condition that the source has a sink configured.
Expand All @@ -106,6 +119,11 @@ func (sbs *SinkBindingStatus) MarkSink(addr *duckv1.Addressable) {
}
}

// MarkSinkFailed sets the condition that the source has a sink configured.
func (sbs *SinkBindingStatus) MarkSinkFailed(reason, messageFormat string, messageA ...interface{}) {
sbCondSet.Manage(sbs).MarkFalse(SinkBindingConditionSinkProvided, reason, messageFormat, messageA...)
}

func (sbs *SinkBindingStatus) MarkOIDCIdentityCreatedSucceeded() {
sbCondSet.Manage(sbs).MarkTrue(SinkBindingConditionOIDCIdentityCreated)
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,14 +70,18 @@ type SinkBindingSpec struct {
}

const (
// SinkBindingConditionReady is configured to indicate whether the Binding
// SinkBindingConditionAvailable is configured to indicate whether the Binding
// has been configured for resources subject to its runtime contract.
SinkBindingConditionReady = apis.ConditionReady
SinkBindingConditionAvailable apis.ConditionType = "SinkBindingAvailable"

// SinkBindingConditionSinkProvided is configured to indicate whether the
// sink has been properly extracted from the resolver.
SinkBindingConditionSinkProvided apis.ConditionType = "SinkProvided"

// SinkBindingTrustBundlePropagated is configured to indicate whether the
// TLS trust bundle has been properly propagated.
SinkBindingTrustBundlePropagated apis.ConditionType = "TrustBundlePropagated"

// SinkBindingConditionOIDCIdentityCreated is configured to indicate whether
// the OIDC identity has been created for the sink.
SinkBindingConditionOIDCIdentityCreated apis.ConditionType = "OIDCIdentityCreated"
Expand Down

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Loading

0 comments on commit 0b7494f

Please sign in to comment.