-
Notifications
You must be signed in to change notification settings - Fork 117
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
bumping knative.dev/reconciler-test aae114c...0619dc3: > 0619dc3 Update community files (# 773) bumping knative.dev/hack ef6e7e9...b799531: > b799531 Update community files (# 403) bumping knative.dev/pkg 25f6002...0a99635: > 0a99635 Update community files (# 3112) bumping knative.dev/eventing ef6b31a...9d67389: > 9d67389 [chore] Do not generate SSL env vars for each struct entry, just once per containersource/image (# 8315) > 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) Signed-off-by: Knative Automation <automation@knative.team>
- Loading branch information
1 parent
6206167
commit 96083e7
Showing
51 changed files
with
1,968 additions
and
2,396 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
20 changes: 20 additions & 0 deletions
20
vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/doc.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,20 @@ | ||
| /* | ||
| Copyright 2020 The Knative Authors | ||
| Licensed under the Apache License, Version 2.0 (the "License"); | ||
| you may not use this file except in compliance with the License. | ||
| You may obtain a copy of the License at | ||
| http://www.apache.org/licenses/LICENSE-2.0 | ||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, | ||
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| See the License for the specific language governing permissions and | ||
| limitations under the License. | ||
| */ | ||
|
|
||
| // Package v1alpha1 contains API Schema definitions for the sources v1alpha1 API group. | ||
| // +k8s:deepcopy-gen=package | ||
| // +groupName=sources.knative.dev | ||
| package v1alpha1 |
36 changes: 36 additions & 0 deletions
36
vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/integration_conversion.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,36 @@ | ||
| /* | ||
| Copyright 2020 The Knative Authors | ||
| Licensed under the Apache License, Version 2.0 (the "License"); | ||
| you may not use this file except in compliance with the License. | ||
| You may obtain a copy of the License at | ||
| http://www.apache.org/licenses/LICENSE-2.0 | ||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, | ||
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| See the License for the specific language governing permissions and | ||
| limitations under the License. | ||
| */ | ||
|
|
||
| package v1alpha1 | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
|
|
||
| "knative.dev/pkg/apis" | ||
| ) | ||
|
|
||
| // ConvertTo implements apis.Convertible | ||
| // Converts source from v1alpha1.IntegrationSource into a higher version. | ||
| func (source *IntegrationSource) ConvertTo(ctx context.Context, obj apis.Convertible) error { | ||
| return fmt.Errorf("v1alpha1 is the highest known version, got: %T", source) | ||
| } | ||
|
|
||
| // ConvertFrom implements apis.Convertible | ||
| // Converts source from a higher version into v1beta2.IntegrationSource | ||
| func (source *IntegrationSource) ConvertFrom(ctx context.Context, obj apis.Convertible) error { | ||
| return fmt.Errorf("v1alpha1 is the highest known version, got: %T", source) | ||
| } |
26 changes: 26 additions & 0 deletions
26
vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/integration_defaults.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,26 @@ | ||
| /* | ||
| Copyright 2020 The Knative Authors | ||
| Licensed under the Apache License, Version 2.0 (the "License"); | ||
| you may not use this file except in compliance with the License. | ||
| You may obtain a copy of the License at | ||
| http://www.apache.org/licenses/LICENSE-2.0 | ||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, | ||
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| See the License for the specific language governing permissions and | ||
| limitations under the License. | ||
| */ | ||
|
|
||
| package v1alpha1 | ||
|
|
||
| import "context" | ||
|
|
||
| func (source *IntegrationSource) SetDefaults(ctx context.Context) { | ||
| source.Spec.SetDefaults(ctx) | ||
| } | ||
|
|
||
| func (source *IntegrationSourceSpec) SetDefaults(ctx context.Context) { | ||
| } |
76 changes: 76 additions & 0 deletions
76
vendor/knative.dev/eventing/pkg/apis/sources/v1alpha1/integration_lifecycle.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,76 @@ | ||
| /* | ||
| Copyright 2020 The Knative Authors | ||
| Licensed under the Apache License, Version 2.0 (the "License"); | ||
| you may not use this file except in compliance with the License. | ||
| You may obtain a copy of the License at | ||
| http://www.apache.org/licenses/LICENSE-2.0 | ||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, | ||
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| See the License for the specific language governing permissions and | ||
| limitations under the License. | ||
| */ | ||
|
|
||
| package v1alpha1 | ||
|
|
||
| import ( | ||
| corev1 "k8s.io/api/core/v1" | ||
| v1 "knative.dev/eventing/pkg/apis/sources/v1" | ||
| "knative.dev/pkg/apis" | ||
| ) | ||
|
|
||
| const ( | ||
| // IntegrationSourceConditionReady has status True when the IntegrationSource is ready to send events. | ||
| IntegrationSourceConditionReady = apis.ConditionReady | ||
|
|
||
| // IntegrationSourceConditionReceiveAdapterReady has status True when the IntegrationSource's Deployment is ready. | ||
| IntegrationSourceConditionContainerSourceReady apis.ConditionType = "ContainerSourceReady" | ||
| ) | ||
|
|
||
| var IntegrationCondSet = apis.NewLivingConditionSet( | ||
| IntegrationSourceConditionContainerSourceReady, | ||
| ) | ||
|
|
||
| // GetConditionSet retrieves the condition set for this resource. Implements the KRShaped interface. | ||
| func (*IntegrationSource) GetConditionSet() apis.ConditionSet { | ||
| return IntegrationCondSet | ||
| } | ||
|
|
||
| // GetTopLevelCondition returns the top level condition. | ||
| func (s *IntegrationSourceStatus) GetTopLevelCondition() *apis.Condition { | ||
| return IntegrationCondSet.Manage(s).GetTopLevelCondition() | ||
| } | ||
|
|
||
| // InitializeConditions sets relevant unset conditions to Unknown state. | ||
| func (s *IntegrationSourceStatus) InitializeConditions() { | ||
| IntegrationCondSet.Manage(s).InitializeConditions() | ||
| } | ||
|
|
||
| func (iss *IntegrationSourceStatus) IsReady() bool { | ||
| return IntegrationCondSet.Manage(iss).IsHappy() | ||
| } | ||
|
|
||
| func (s *IntegrationSourceStatus) PropagateContainerSourceStatus(status *v1.ContainerSourceStatus) { | ||
| //// Do not copy conditions nor observedGeneration | ||
| s.SourceStatus = *status.SourceStatus.DeepCopy() | ||
|
|
||
| cond := status.GetCondition(apis.ConditionReady) | ||
| switch { | ||
| case cond == nil: | ||
| IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, "", "") | ||
| case cond.Status == corev1.ConditionTrue: | ||
| IntegrationCondSet.Manage(s).MarkTrue(IntegrationSourceConditionContainerSourceReady) | ||
| case cond.Status == corev1.ConditionFalse: | ||
| IntegrationCondSet.Manage(s).MarkFalse(IntegrationSourceConditionContainerSourceReady, cond.Reason, cond.Message) | ||
| case cond.Status == corev1.ConditionUnknown: | ||
| IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, cond.Reason, cond.Message) | ||
| default: | ||
| IntegrationCondSet.Manage(s).MarkUnknown(IntegrationSourceConditionContainerSourceReady, cond.Reason, cond.Message) | ||
| } | ||
|
|
||
| // Propagate ContainerSources AuthStatus to IntegrationSources AuthStatus | ||
| s.Auth = status.Auth | ||
| } |
Oops, something went wrong.