@@ -87,25 +87,26 @@ func (ts *EventTransformStatus) InitializeConditions() {
87
87
ts .GetConditionSet ().Manage (ts ).InitializeConditions ()
88
88
}
89
89
90
- func (ts * EventTransformStatus ) PropagateJsonataDeploymentStatus (ds appsv1.DeploymentStatus ) {
90
+ func (ts * EventTransformStatus ) PropagateJsonataDeploymentStatus (ds appsv1.DeploymentStatus ) bool {
91
91
defer ts .propagateTransformJsonataReadiness ()
92
92
if ts .JsonataTransformationStatus == nil {
93
93
ts .JsonataTransformationStatus = & JsonataEventTransformationStatus {}
94
94
}
95
95
ts .JsonataTransformationStatus .Deployment = ds
96
96
if ds .Replicas > 0 && ds .Replicas == ds .AvailableReplicas {
97
97
transformJsonataConditionSet .Manage (ts ).MarkTrue (TransformationJsonataDeploymentReady )
98
- } else {
99
- transformJsonataConditionSet .Manage (ts ).MarkFalse (TransformationJsonataDeploymentReady , TransformationJsonataDeploymentUnavailable , "Expected replicas: %d, available: %d" , ds .Replicas , ds .AvailableReplicas )
98
+ return true
100
99
}
100
+ transformJsonataConditionSet .Manage (ts ).MarkFalse (TransformationJsonataDeploymentReady , TransformationJsonataDeploymentUnavailable , "Expected replicas: %d, available: %d" , ds .Replicas , ds .AvailableReplicas )
101
+ return false
101
102
}
102
103
103
104
func (ts * EventTransformStatus ) PropagateJsonataSinkBindingUnset () {
104
105
defer ts .propagateTransformJsonataReadiness ()
105
106
transformJsonataConditionSet .Manage (ts ).MarkTrue (TransformationJsonataSinkBindingReady )
106
107
}
107
108
108
- func (ts * EventTransformStatus ) PropagateJsonataSinkBindingStatus (sbs sourcesv1.SinkBindingStatus ) {
109
+ func (ts * EventTransformStatus ) PropagateJsonataSinkBindingStatus (sbs sourcesv1.SinkBindingStatus ) bool {
109
110
defer ts .propagateTransformJsonataReadiness ()
110
111
if ts .JsonataTransformationStatus == nil {
111
112
ts .JsonataTransformationStatus = & JsonataEventTransformationStatus {}
@@ -118,15 +119,18 @@ func (ts *EventTransformStatus) PropagateJsonataSinkBindingStatus(sbs sourcesv1.
118
119
topLevel := sbs .GetCondition (apis .ConditionReady )
119
120
if topLevel == nil {
120
121
transformJsonataConditionSet .Manage (ts ).MarkUnknown (TransformationJsonataSinkBindingReady , "" , "" )
121
- return
122
+ return false
122
123
}
123
124
if topLevel .IsTrue () {
124
125
transformJsonataConditionSet .Manage (ts ).MarkTrue (TransformationJsonataSinkBindingReady )
125
- } else if topLevel .IsFalse () {
126
+ return true
127
+ }
128
+ if topLevel .IsFalse () {
126
129
transformJsonataConditionSet .Manage (ts ).MarkFalse (TransformationJsonataSinkBindingReady , topLevel .Reason , topLevel .Message )
127
- } else {
128
- transformJsonataConditionSet .Manage (ts ).MarkUnknown (TransformationJsonataSinkBindingReady , topLevel .Reason , topLevel .Message )
130
+ return false
129
131
}
132
+ transformJsonataConditionSet .Manage (ts ).MarkUnknown (TransformationJsonataSinkBindingReady , topLevel .Reason , topLevel .Message )
133
+ return false
130
134
}
131
135
132
136
func (ts * EventTransformStatus ) propagateTransformJsonataReadiness () {
0 commit comments