Skip to content

Commit 3b06ad3

Browse files
committed
fix: r
Signed-off-by: ashing <[email protected]>
1 parent 5cf5ec7 commit 3b06ad3

File tree

3 files changed

+6
-14
lines changed

3 files changed

+6
-14
lines changed

internal/controller/httproute_controller.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,8 @@ func (r *HTTPRouteReconciler) Reconcile(ctx context.Context, req ctrl.Request) (
116116

117117
for _, gateway := range gateways {
118118
if err := ProcessGatewayProxy(r.Client, tctx, gateway.Gateway); err != nil {
119-
return ctrl.Result{}, err
119+
acceptStatus.status = false
120+
acceptStatus.msg = err.Error()
120121
}
121122
}
122123

internal/provider/adc/adc.go

Lines changed: 4 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ func (d *adcClient) getConfigs(rk ResourceKind) []adcConfig {
6565
return d.configs[rk]
6666
}
6767

68-
func (d *adcClient) getConfigsForGatewayProxy(rk ResourceKind, tctx *provider.TranslateContext, gatewayProxy *v1alpha1.GatewayProxy) (*adcConfig, error) {
68+
func (d *adcClient) getConfigsForGatewayProxy(tctx *provider.TranslateContext, gatewayProxy *v1alpha1.GatewayProxy) (*adcConfig, error) {
6969
if gatewayProxy == nil || gatewayProxy.Spec.Provider == nil {
7070
return nil, nil
7171
}
@@ -89,7 +89,8 @@ func (d *adcClient) getConfigsForGatewayProxy(rk ResourceKind, tctx *provider.Tr
8989
if provider.ControlPlane.Auth.AdminKey.ValueFrom != nil && provider.ControlPlane.Auth.AdminKey.ValueFrom.SecretKeyRef != nil {
9090
secretRef := provider.ControlPlane.Auth.AdminKey.ValueFrom.SecretKeyRef
9191
secret, ok := tctx.Secrets[types.NamespacedName{
92-
Namespace: rk.Namespace,
92+
// we should use gateway proxy namespace
93+
Namespace: gatewayProxy.GetNamespace(),
9394
Name: secretRef.Name,
9495
}]
9596
if ok {
@@ -112,7 +113,7 @@ func (d *adcClient) getConfigsForGatewayProxy(rk ResourceKind, tctx *provider.Tr
112113
func (d *adcClient) updateConfigs(rk ResourceKind, tctx *provider.TranslateContext) error {
113114
var configs []adcConfig
114115
for _, gatewayProxy := range tctx.GatewayProxies {
115-
config, err := d.getConfigsForGatewayProxy(rk, tctx, &gatewayProxy)
116+
config, err := d.getConfigsForGatewayProxy(tctx, &gatewayProxy)
116117
if err != nil {
117118
return err
118119
}
@@ -139,21 +140,12 @@ func (d *adcClient) Update(ctx context.Context, tctx *provider.TranslateContext,
139140
resourceTypes = append(resourceTypes, "service")
140141
case *gatewayv1.Gateway:
141142
result, err = d.translator.TranslateGateway(tctx, t.DeepCopy())
142-
if err != nil {
143-
return err
144-
}
145143
resourceTypes = append(resourceTypes, "global_rule", "ssl", "plugin_metadata")
146144
case *networkingv1.Ingress:
147145
result, err = d.translator.TranslateIngress(tctx, t.DeepCopy())
148-
if err != nil {
149-
return err
150-
}
151146
resourceTypes = append(resourceTypes, "service", "ssl")
152147
case *v1alpha1.Consumer:
153148
result, err = d.translator.TranslateConsumerV1alpha1(tctx, t.DeepCopy())
154-
if err != nil {
155-
return err
156-
}
157149
resourceTypes = append(resourceTypes, "consumer")
158150
}
159151
if err != nil {

internal/provider/provider.go

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@ type TranslateContext struct {
2222
GatewayTLSConfig []gatewayv1.GatewayTLSConfig
2323
GatewayProxies []v1alpha1.GatewayProxy
2424
Credentials []v1alpha1.Credential
25-
Gateways []gatewayv1.Gateway
2625
EndpointSlices map[types.NamespacedName][]discoveryv1.EndpointSlice
2726
Secrets map[types.NamespacedName]*corev1.Secret
2827
PluginConfigs map[types.NamespacedName]*v1alpha1.PluginConfig

0 commit comments

Comments
 (0)