Skip to content

Commit 93e78d8

Browse files
authored
style: update policy function name (#7381)
Signed-off-by: kkk777-7 <[email protected]>
1 parent 5270456 commit 93e78d8

File tree

3 files changed

+23
-23
lines changed

3 files changed

+23
-23
lines changed

internal/gatewayapi/backendtrafficpolicy.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ func (t *Translator) ProcessBackendTrafficPolicies(resources *resource.Resources
104104
res = append(res, policy)
105105
}
106106

107-
t.processBTPolicyForRoute(resources, xdsIR,
107+
t.processBackendTrafficPolicyForRoute(resources, xdsIR,
108108
routeMap, gatewayRouteMap, gatewayPolicyMerged, gatewayPolicyMap, policy, currTarget)
109109
}
110110
}
@@ -124,7 +124,7 @@ func (t *Translator) ProcessBackendTrafficPolicies(resources *resource.Resources
124124
res = append(res, policy)
125125
}
126126

127-
t.processBTPolicyForRoute(resources, xdsIR,
127+
t.processBackendTrafficPolicyForRoute(resources, xdsIR,
128128
routeMap, gatewayRouteMap, gatewayPolicyMerged, gatewayPolicyMap, policy, currTarget)
129129
}
130130
}
@@ -143,7 +143,7 @@ func (t *Translator) ProcessBackendTrafficPolicies(resources *resource.Resources
143143
handledPolicies[policyName] = policy
144144
res = append(res, policy)
145145
}
146-
t.processBTPolicyForGateway(resources, xdsIR,
146+
t.processBackendTrafficPolicyForGateway(resources, xdsIR,
147147
gatewayMap, gatewayRouteMap, gatewayPolicyMerged, policy, currTarget)
148148
}
149149
}
@@ -162,7 +162,7 @@ func (t *Translator) ProcessBackendTrafficPolicies(resources *resource.Resources
162162
handledPolicies[policyName] = policy
163163
res = append(res, policy)
164164
}
165-
t.processBTPolicyForGateway(resources, xdsIR,
165+
t.processBackendTrafficPolicyForGateway(resources, xdsIR,
166166
gatewayMap, gatewayRouteMap, gatewayPolicyMerged, policy, currTarget)
167167
}
168168
}
@@ -221,7 +221,7 @@ func (t *Translator) buildGatewayPolicyMap(
221221
}
222222
}
223223

224-
func (t *Translator) processBTPolicyForRoute(
224+
func (t *Translator) processBackendTrafficPolicyForRoute(
225225
resources *resource.Resources,
226226
xdsIR resource.XdsIRMap,
227227
routeMap map[policyTargetRouteKey]*policyRouteTargetContext,
@@ -236,7 +236,7 @@ func (t *Translator) processBTPolicyForRoute(
236236
resolveErr *status.PolicyResolveError
237237
)
238238

239-
targetedRoute, resolveErr = resolveBTPolicyRouteTargetRef(policy, currTarget, routeMap)
239+
targetedRoute, resolveErr = resolveBackendTrafficPolicyRouteTargetRef(policy, currTarget, routeMap)
240240
// Skip if the route is not found
241241
// It's not necessarily an error because the BackendTrafficPolicy may be
242242
// reconciled by multiple controllers. And the other controller may
@@ -412,7 +412,7 @@ func (t *Translator) processBTPolicyForRoute(
412412
}
413413
}
414414

415-
func (t *Translator) processBTPolicyForGateway(
415+
func (t *Translator) processBackendTrafficPolicyForGateway(
416416
resources *resource.Resources,
417417
xdsIR resource.XdsIRMap,
418418
gatewayMap map[types.NamespacedName]*policyGatewayTargetContext,
@@ -427,7 +427,7 @@ func (t *Translator) processBTPolicyForGateway(
427427
)
428428

429429
// Negative statuses have already been assigned so it's safe to skip
430-
targetedGateway, resolveErr = resolveBTPolicyGatewayTargetRef(policy, currTarget, gatewayMap)
430+
targetedGateway, resolveErr = resolveBackendTrafficPolicyGatewayTargetRef(policy, currTarget, gatewayMap)
431431
if targetedGateway == nil {
432432
return
433433
}
@@ -487,7 +487,7 @@ func (t *Translator) processBTPolicyForGateway(
487487
}
488488
}
489489

490-
func resolveBTPolicyGatewayTargetRef(
490+
func resolveBackendTrafficPolicyGatewayTargetRef(
491491
policy *egv1a1.BackendTrafficPolicy,
492492
target gwapiv1.LocalPolicyTargetReferenceWithSectionName,
493493
gateways map[types.NamespacedName]*policyGatewayTargetContext,
@@ -551,7 +551,7 @@ func resolveBTPolicyGatewayTargetRef(
551551
return gateway.GatewayContext, nil
552552
}
553553

554-
func resolveBTPolicyRouteTargetRef(
554+
func resolveBackendTrafficPolicyRouteTargetRef(
555555
policy *egv1a1.BackendTrafficPolicy,
556556
target gwapiv1.LocalPolicyTargetReferenceWithSectionName,
557557
routes map[policyTargetRouteKey]*policyRouteTargetContext,

internal/gatewayapi/clienttrafficpolicy.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ func (t *Translator) ProcessClientTrafficPolicies(
7777
res = append(res, policy)
7878
}
7979

80-
gateway, resolveErr := resolveCTPolicyTargetRef(policy, &currTarget, gatewayMap)
80+
gateway, resolveErr := resolveClientTrafficPolicyTargetRef(policy, &currTarget, gatewayMap)
8181

8282
// Negative statuses have already been assigned so its safe to skip
8383
if gateway == nil {
@@ -172,7 +172,7 @@ func (t *Translator) ProcessClientTrafficPolicies(
172172
handledPolicies[policyName] = policy
173173
}
174174

175-
gateway, resolveErr := resolveCTPolicyTargetRef(policy, &currTarget, gatewayMap)
175+
gateway, resolveErr := resolveClientTrafficPolicyTargetRef(policy, &currTarget, gatewayMap)
176176

177177
// Negative statuses have already been assigned so its safe to skip
178178
if gateway == nil {
@@ -283,7 +283,7 @@ func (t *Translator) ProcessClientTrafficPolicies(
283283
return res
284284
}
285285

286-
func resolveCTPolicyTargetRef(
286+
func resolveClientTrafficPolicyTargetRef(
287287
policy *egv1a1.ClientTrafficPolicy,
288288
targetRef *gwapiv1.LocalPolicyTargetReferenceWithSectionName,
289289
gateways map[types.NamespacedName]*policyGatewayTargetContext,

internal/gatewayapi/envoyextensionpolicy.go

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ func (t *Translator) ProcessEnvoyExtensionPolicies(envoyExtensionPolicies []*egv
8585
handledPolicies[policyName] = policy
8686
}
8787

88-
t.processEEPolicyForRoute(resources, xdsIR,
88+
t.processEnvoyExtensionPolicyForRoute(resources, xdsIR,
8989
routeMap, gatewayRouteMap, policy, currTarget)
9090
}
9191
}
@@ -105,7 +105,7 @@ func (t *Translator) ProcessEnvoyExtensionPolicies(envoyExtensionPolicies []*egv
105105
handledPolicies[policyName] = policy
106106
}
107107

108-
t.processEEPolicyForRoute(resources, xdsIR,
108+
t.processEnvoyExtensionPolicyForRoute(resources, xdsIR,
109109
routeMap, gatewayRouteMap, policy, currTarget)
110110
}
111111
}
@@ -125,7 +125,7 @@ func (t *Translator) ProcessEnvoyExtensionPolicies(envoyExtensionPolicies []*egv
125125
handledPolicies[policyName] = policy
126126
}
127127

128-
t.processEEPolicyForGateway(resources, xdsIR,
128+
t.processEnvoyExtensionPolicyForGateway(resources, xdsIR,
129129
gatewayMap, gatewayRouteMap, policy, currTarget)
130130
}
131131
}
@@ -145,7 +145,7 @@ func (t *Translator) ProcessEnvoyExtensionPolicies(envoyExtensionPolicies []*egv
145145
handledPolicies[policyName] = policy
146146
}
147147

148-
t.processEEPolicyForGateway(resources, xdsIR,
148+
t.processEnvoyExtensionPolicyForGateway(resources, xdsIR,
149149
gatewayMap, gatewayRouteMap, policy, currTarget)
150150
}
151151
}
@@ -160,7 +160,7 @@ func (t *Translator) ProcessEnvoyExtensionPolicies(envoyExtensionPolicies []*egv
160160
return res
161161
}
162162

163-
func (t *Translator) processEEPolicyForRoute(
163+
func (t *Translator) processEnvoyExtensionPolicyForRoute(
164164
resources *resource.Resources,
165165
xdsIR resource.XdsIRMap,
166166
routeMap map[policyTargetRouteKey]*policyRouteTargetContext,
@@ -174,7 +174,7 @@ func (t *Translator) processEEPolicyForRoute(
174174
resolveErr *status.PolicyResolveError
175175
)
176176

177-
targetedRoute, resolveErr = resolveEEPolicyRouteTargetRef(policy, currTarget, routeMap)
177+
targetedRoute, resolveErr = resolveEnvoyExtensionPolicyRouteTargetRef(policy, currTarget, routeMap)
178178
// Skip if the route is not found
179179
// It's not necessarily an error because the EnvoyExtensionPolicy may be
180180
// reconciled by multiple controllers. And the other controller may
@@ -262,7 +262,7 @@ func (t *Translator) processEEPolicyForRoute(
262262
}
263263
}
264264

265-
func (t *Translator) processEEPolicyForGateway(
265+
func (t *Translator) processEnvoyExtensionPolicyForGateway(
266266
resources *resource.Resources,
267267
xdsIR resource.XdsIRMap,
268268
gatewayMap map[types.NamespacedName]*policyGatewayTargetContext,
@@ -275,7 +275,7 @@ func (t *Translator) processEEPolicyForGateway(
275275
resolveErr *status.PolicyResolveError
276276
)
277277

278-
targetedGateway, resolveErr = resolveEEPolicyGatewayTargetRef(policy, currTarget, gatewayMap)
278+
targetedGateway, resolveErr = resolveEnvoyExtensionPolicyGatewayTargetRef(policy, currTarget, gatewayMap)
279279
// Skip if the gateway is not found
280280
// It's not necessarily an error because the EnvoyExtensionPolicy may be
281281
// reconciled by multiple controllers. And the other controller may
@@ -329,7 +329,7 @@ func (t *Translator) processEEPolicyForGateway(
329329
}
330330
}
331331

332-
func resolveEEPolicyGatewayTargetRef(
332+
func resolveEnvoyExtensionPolicyGatewayTargetRef(
333333
policy *egv1a1.EnvoyExtensionPolicy,
334334
target gwapiv1.LocalPolicyTargetReferenceWithSectionName,
335335
gateways map[types.NamespacedName]*policyGatewayTargetContext,
@@ -391,7 +391,7 @@ func resolveEEPolicyGatewayTargetRef(
391391
return gateway.GatewayContext, nil
392392
}
393393

394-
func resolveEEPolicyRouteTargetRef(
394+
func resolveEnvoyExtensionPolicyRouteTargetRef(
395395
policy *egv1a1.EnvoyExtensionPolicy,
396396
target gwapiv1.LocalPolicyTargetReferenceWithSectionName,
397397
routes map[policyTargetRouteKey]*policyRouteTargetContext,

0 commit comments

Comments
 (0)