Skip to content

Commit c99fb7d

Browse files
upgrade to latest dependencies
bumping knative.dev/reconciler-test aae114c...0619dc3: > 0619dc3 Update community files (# 773) bumping knative.dev/pkg 25f6002...0a99635: > 0a99635 Update community files (# 3112) bumping knative.dev/eventing ef6b31a...35d8c63: > 35d8c63 [chore] Use a generic access/secret key in the secret for AWS connections (# 8312) > f53d038 [main] Update community files (# 8307) > df34028 Add missing copyright boilerplate (# 8305) > 3f2b75b Use GetServiceHostname when passing URL to JobSink (# 8303) > fa6b4c5 Add jobsinks-addressable-resolver cluster role (# 8298) > b4b609a Add observedGeneration in JobSink OpenAPI schema (# 8297) > 2e4d353 Allow imc-controller to list JobSinks (# 8294) > 7bca815 IntegrationSource CRD (# 8238) > c859efd [main] Format Go code (# 8289) > 7c97e6f Schduler: MAXFILLUP strategy will spread vreplicas across multiple pods (# 8263) bumping knative.dev/hack ef6e7e9...b799531: > b799531 Update community files (# 403) Signed-off-by: Knative Automation <automation@knative.team>
1 parent 6206167 commit c99fb7d

File tree

51 files changed

+1968
-2396
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

51 files changed

+1968
-2396
lines changed

go.mod

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -35,10 +35,10 @@ require (
3535
k8s.io/apiserver v0.30.3
3636
k8s.io/client-go v0.30.3
3737
k8s.io/utils v0.0.0-20240711033017-18e509b52bc8
38-
knative.dev/eventing v0.43.1-0.20241028083747-ef6b31a697e7
39-
knative.dev/hack v0.0.0-20241025103803-ef6e7e983a60
40-
knative.dev/pkg v0.0.0-20241026180704-25f6002b00f3
41-
knative.dev/reconciler-test v0.0.0-20241024141702-aae114c1c0e3
38+
knative.dev/eventing v0.43.1-0.20241107164100-35d8c639d6e9
39+
knative.dev/hack v0.0.0-20241106013728-b7995315deb5
40+
knative.dev/pkg v0.0.0-20241106013442-0a99635c789e
41+
knative.dev/reconciler-test v0.0.0-20241106013737-0619dc3ecbcf
4242
sigs.k8s.io/controller-runtime v0.12.3
4343
sigs.k8s.io/yaml v1.4.0
4444
)

go.sum

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1214,14 +1214,14 @@ k8s.io/utils v0.0.0-20200912215256-4140de9c8800/go.mod h1:jPW/WVKK9YHAvNhRxK0md/
12141214
k8s.io/utils v0.0.0-20210819203725-bdf08cb9a70a/go.mod h1:jPW/WVKK9YHAvNhRxK0md/EJ228hCsBRufyofKtW8HA=
12151215
k8s.io/utils v0.0.0-20240711033017-18e509b52bc8 h1:pUdcCO1Lk/tbT5ztQWOBi5HBgbBP1J8+AsQnQCKsi8A=
12161216
k8s.io/utils v0.0.0-20240711033017-18e509b52bc8/go.mod h1:OLgZIPagt7ERELqWJFomSt595RzquPNLL48iOWgYOg0=
1217-
knative.dev/eventing v0.43.1-0.20241028083747-ef6b31a697e7 h1:pYKhXbvHVOmQumyKS7vjQBaB11rXzeAjz84z2L9qrtM=
1218-
knative.dev/eventing v0.43.1-0.20241028083747-ef6b31a697e7/go.mod h1:2mdt9J66vQYzxizDz8I/F6IGzV1QgwCkacBR8X12Ssk=
1219-
knative.dev/hack v0.0.0-20241025103803-ef6e7e983a60 h1:LjBbosBvW/9/qjzIJtGpehPsbNWVvy1Fz8yZvMbFWe4=
1220-
knative.dev/hack v0.0.0-20241025103803-ef6e7e983a60/go.mod h1:R0ritgYtjLDO9527h5vb5X6gfvt5LCrJ55BNbVDsWiY=
1221-
knative.dev/pkg v0.0.0-20241026180704-25f6002b00f3 h1:uUSDGlOIkdPT4svjlhi+JEnP2Ufw7AM/F5QDYiEL02U=
1222-
knative.dev/pkg v0.0.0-20241026180704-25f6002b00f3/go.mod h1:FeMbTLlxQqSASwlRCrYEOsZ0OKUgSj52qxhECwYCJsw=
1223-
knative.dev/reconciler-test v0.0.0-20241024141702-aae114c1c0e3 h1:pa3b/0EKzONPLBHqM0RFzG5EaB+k8OTyHGaUXWPIgns=
1224-
knative.dev/reconciler-test v0.0.0-20241024141702-aae114c1c0e3/go.mod h1:W9Kmdoxelg2mswUpDKerL/4Ih1/ouVhlSMeZeJ5LX9c=
1217+
knative.dev/eventing v0.43.1-0.20241107164100-35d8c639d6e9 h1:bX9XhlMvhSNIoBMavWqo1A4kRCEsqNkUJYM/qnfjouE=
1218+
knative.dev/eventing v0.43.1-0.20241107164100-35d8c639d6e9/go.mod h1:2mdt9J66vQYzxizDz8I/F6IGzV1QgwCkacBR8X12Ssk=
1219+
knative.dev/hack v0.0.0-20241106013728-b7995315deb5 h1:CfU5+6B+ylBd7mSGpvRqpzZV8H5ZQLGUwVygFzbE+1o=
1220+
knative.dev/hack v0.0.0-20241106013728-b7995315deb5/go.mod h1:R0ritgYtjLDO9527h5vb5X6gfvt5LCrJ55BNbVDsWiY=
1221+
knative.dev/pkg v0.0.0-20241106013442-0a99635c789e h1:Ksol0kNFrbJ9YfEsrRP60XGJS7eYAx6YLLji0fmxv/g=
1222+
knative.dev/pkg v0.0.0-20241106013442-0a99635c789e/go.mod h1:FeMbTLlxQqSASwlRCrYEOsZ0OKUgSj52qxhECwYCJsw=
1223+
knative.dev/reconciler-test v0.0.0-20241106013737-0619dc3ecbcf h1:FMgW5irj5xRPSRmtVICeLNHnZsnn7t8IFO0Fj3Kf+jo=
1224+
knative.dev/reconciler-test v0.0.0-20241106013737-0619dc3ecbcf/go.mod h1:W9Kmdoxelg2mswUpDKerL/4Ih1/ouVhlSMeZeJ5LX9c=
12251225
rsc.io/binaryregexp v0.2.0/go.mod h1:qTv7/COck+e2FymRvadv62gMdZztPaShugOCi3I+8D8=
12261226
rsc.io/quote/v3 v3.1.0/go.mod h1:yEA65RcK8LyAZtP9Kv3t0HmxON59tX3rD+tICJqUlj0=
12271227
rsc.io/sampler v1.3.0/go.mod h1:T1hPZKmBbMNahiBKFy5HrXp6adAjACjK9JXDnKaTXpA=

vendor/knative.dev/eventing/hack/update-codegen.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ group "Knative Codegen"
4949
# Knative Injection
5050
${KNATIVE_CODEGEN_PKG}/hack/generate-knative.sh "injection" \
5151
knative.dev/eventing/pkg/client knative.dev/eventing/pkg/apis \
52-
"sinks:v1alpha1 eventing:v1alpha1 eventing:v1beta1 eventing:v1beta2 eventing:v1beta3 eventing:v1 messaging:v1 flows:v1 sources:v1beta2 sources:v1 duck:v1beta1 duck:v1" \
52+
"sinks:v1alpha1 eventing:v1alpha1 eventing:v1beta1 eventing:v1beta2 eventing:v1beta3 eventing:v1 messaging:v1 flows:v1 sources:v1alpha1 sources:v1beta2 sources:v1 duck:v1beta1 duck:v1" \
5353
--go-header-file ${REPO_ROOT_DIR}/hack/boilerplate/boilerplate.go.txt
5454

5555
group "Generating API reference docs"

vendor/knative.dev/eventing/pkg/apis/sources/register.go

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,4 +56,10 @@ var (
5656
Group: GroupName,
5757
Resource: "containersources",
5858
}
59+
60+
// IntegrationSourceResource respresents a Knative Eventing Sources IntegrationSource
61+
IntegrationSourceResource = schema.GroupResource{
62+
Group: GroupName,
63+
Resource: "integrationsources",
64+
}
5965
)
Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,20 @@
1+
/*
2+
Copyright 2020 The Knative Authors
3+
4+
Licensed under the Apache License, Version 2.0 (the "License");
5+
you may not use this file except in compliance with the License.
6+
You may obtain a copy of the License at
7+
8+
http://www.apache.org/licenses/LICENSE-2.0
9+
10+
Unless required by applicable law or agreed to in writing, software
11+
distributed under the License is distributed on an "AS IS" BASIS,
12+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
See the License for the specific language governing permissions and
14+
limitations under the License.
15+
*/
16+
17+
// Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group.
18+
// +k8s:deepcopy-gen=package
19+
// +groupName=sources.knative.dev
20+
package v1alpha1
Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
/*
2+
Copyright 2020 The Knative Authors
3+
4+
Licensed under the Apache License, Version 2.0 (the "License");
5+
you may not use this file except in compliance with the License.
6+
You may obtain a copy of the License at
7+
8+
http://www.apache.org/licenses/LICENSE-2.0
9+
10+
Unless required by applicable law or agreed to in writing, software
11+
distributed under the License is distributed on an "AS IS" BASIS,
12+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
See the License for the specific language governing permissions and
14+
limitations under the License.
15+
*/
16+
17+
package v1alpha1
18+
19+
import (
20+
"context"
21+
"fmt"
22+
23+
"knative.dev/pkg/apis"
24+
)
25+
26+
// ConvertTo implements apis.Convertible
27+
// Converts source from v1alpha1.IntegrationSource into a higher version.
28+
func (source *IntegrationSource) ConvertTo(ctx context.Context, obj apis.Convertible) error {
29+
return fmt.Errorf("v1alpha1 is the highest known version, got: %T", source)
30+
}
31+
32+
// ConvertFrom implements apis.Convertible
33+
// Converts source from a higher version into v1beta2.IntegrationSource
34+
func (source *IntegrationSource) ConvertFrom(ctx context.Context, obj apis.Convertible) error {
35+
return fmt.Errorf("v1alpha1 is the highest known version, got: %T", source)
36+
}
Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
/*
2+
Copyright 2020 The Knative Authors
3+
4+
Licensed under the Apache License, Version 2.0 (the "License");
5+
you may not use this file except in compliance with the License.
6+
You may obtain a copy of the License at
7+
8+
http://www.apache.org/licenses/LICENSE-2.0
9+
10+
Unless required by applicable law or agreed to in writing, software
11+
distributed under the License is distributed on an "AS IS" BASIS,
12+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
See the License for the specific language governing permissions and
14+
limitations under the License.
15+
*/
16+
17+
package v1alpha1
18+
19+
import "context"
20+
21+
func (source *IntegrationSource) SetDefaults(ctx context.Context) {
22+
source.Spec.SetDefaults(ctx)
23+
}
24+
25+
func (source *IntegrationSourceSpec) SetDefaults(ctx context.Context) {
26+
}
Lines changed: 76 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,76 @@
1+
/*
2+
Copyright 2020 The Knative Authors
3+
4+
Licensed under the Apache License, Version 2.0 (the "License");
5+
you may not use this file except in compliance with the License.
6+
You may obtain a copy of the License at
7+
8+
http://www.apache.org/licenses/LICENSE-2.0
9+
10+
Unless required by applicable law or agreed to in writing, software
11+
distributed under the License is distributed on an "AS IS" BASIS,
12+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13+
See the License for the specific language governing permissions and
14+
limitations under the License.
15+
*/
16+
17+
package v1alpha1
18+
19+
import (
20+
corev1 "k8s.io/api/core/v1"
21+
v1 "knative.dev/eventing/pkg/apis/sources/v1"
22+
"knative.dev/pkg/apis"
23+
)
24+
25+
const (
26+
// IntegrationSourceConditionReady has status True when the IntegrationSource is ready to send events.
27+
IntegrationSourceConditionReady = apis.ConditionReady
28+
29+
// IntegrationSourceConditionReceiveAdapterReady has status True when the IntegrationSource's Deployment is ready.
30+
IntegrationSourceConditionContainerSourceReady apis.ConditionType = "ContainerSourceReady"
31+
)
32+
33+
var IntegrationCondSet = apis.NewLivingConditionSet(
34+
IntegrationSourceConditionContainerSourceReady,
35+
)
36+
37+
// GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface.
38+
func (*IntegrationSource) GetConditionSet() apis.ConditionSet {
39+
return IntegrationCondSet
40+
}
41+
42+
// GetTopLevelCondition returns the top level condition.
43+
func (s *IntegrationSourceStatus) GetTopLevelCondition() *apis.Condition {
44+
return IntegrationCondSet.Manage(s).GetTopLevelCondition()
45+
}
46+
47+
// InitializeConditions sets relevant unset conditions to Unknown state.
48+
func (s *IntegrationSourceStatus) InitializeConditions() {
49+
IntegrationCondSet.Manage(s).InitializeConditions()
50+
}
51+
52+
func (iss *IntegrationSourceStatus) IsReady() bool {
53+
return IntegrationCondSet.Manage(iss).IsHappy()
54+
}
55+
56+
func (s *IntegrationSourceStatus) PropagateContainerSourceStatus(status *v1.ContainerSourceStatus) {
57+
//// Do not copy conditions nor observedGeneration
58+
s.SourceStatus = *status.SourceStatus.DeepCopy()
59+
60+
cond := status.GetCondition(apis.ConditionReady)
61+
switch {
62+
case cond == nil:
63+
IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, "", "")
64+
case cond.Status == corev1.ConditionTrue:
65+
IntegrationCondSet.Manage(s).MarkTrue(IntegrationSourceConditionContainerSourceReady)
66+
case cond.Status == corev1.ConditionFalse:
67+
IntegrationCondSet.Manage(s).MarkFalse(IntegrationSourceConditionContainerSourceReady, cond.Reason, cond.Message)
68+
case cond.Status == corev1.ConditionUnknown:
69+
IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, cond.Reason, cond.Message)
70+
default:
71+
IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, cond.Reason, cond.Message)
72+
}
73+
74+
// Propagate ContainerSources AuthStatus to IntegrationSources AuthStatus
75+
s.Auth = status.Auth
76+
}

0 commit comments

Comments
 (0)