@@ -87,25 +87,26 @@ func (ts *EventTransformStatus) InitializeConditions() {
8787 ts .GetConditionSet ().Manage (ts ).InitializeConditions ()
8888}
8989
90- func (ts * EventTransformStatus ) PropagateJsonataDeploymentStatus (ds appsv1.DeploymentStatus ) {
90+ func (ts * EventTransformStatus ) PropagateJsonataDeploymentStatus (ds appsv1.DeploymentStatus ) bool {
9191 defer ts .propagateTransformJsonataReadiness ()
9292 if ts .JsonataTransformationStatus == nil {
9393 ts .JsonataTransformationStatus = & JsonataEventTransformationStatus {}
9494 }
9595 ts .JsonataTransformationStatus .Deployment = ds
9696 if ds .Replicas > 0 && ds .Replicas == ds .AvailableReplicas {
9797 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
10099 }
100+ transformJsonataConditionSet .Manage (ts ).MarkFalse (TransformationJsonataDeploymentReady , TransformationJsonataDeploymentUnavailable , "Expected replicas: %d, available: %d" , ds .Replicas , ds .AvailableReplicas )
101+ return false
101102}
102103
103104func (ts * EventTransformStatus ) PropagateJsonataSinkBindingUnset () {
104105 defer ts .propagateTransformJsonataReadiness ()
105106 transformJsonataConditionSet .Manage (ts ).MarkTrue (TransformationJsonataSinkBindingReady )
106107}
107108
108- func (ts * EventTransformStatus ) PropagateJsonataSinkBindingStatus (sbs sourcesv1.SinkBindingStatus ) {
109+ func (ts * EventTransformStatus ) PropagateJsonataSinkBindingStatus (sbs sourcesv1.SinkBindingStatus ) bool {
109110 defer ts .propagateTransformJsonataReadiness ()
110111 if ts .JsonataTransformationStatus == nil {
111112 ts .JsonataTransformationStatus = & JsonataEventTransformationStatus {}
@@ -118,15 +119,18 @@ func (ts *EventTransformStatus) PropagateJsonataSinkBindingStatus(sbs sourcesv1.
118119 topLevel := sbs .GetCondition (apis .ConditionReady )
119120 if topLevel == nil {
120121 transformJsonataConditionSet .Manage (ts ).MarkUnknown (TransformationJsonataSinkBindingReady , "" , "" )
121- return
122+ return false
122123 }
123124 if topLevel .IsTrue () {
124125 transformJsonataConditionSet .Manage (ts ).MarkTrue (TransformationJsonataSinkBindingReady )
125- } else if topLevel .IsFalse () {
126+ return true
127+ }
128+ if topLevel .IsFalse () {
126129 transformJsonataConditionSet .Manage (ts ).MarkFalse (TransformationJsonataSinkBindingReady , topLevel .Reason , topLevel .Message )
127- } else {
128- transformJsonataConditionSet .Manage (ts ).MarkUnknown (TransformationJsonataSinkBindingReady , topLevel .Reason , topLevel .Message )
130+ return false
129131 }
132+ transformJsonataConditionSet .Manage (ts ).MarkUnknown (TransformationJsonataSinkBindingReady , topLevel .Reason , topLevel .Message )
133+ return false
130134}
131135
132136func (ts * EventTransformStatus ) propagateTransformJsonataReadiness () {
0 commit comments