primal/traefik
1
0
Fork 0
mirror of https://github.com/traefik/traefik synced 2026-02-03 11:10:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Bump gopkg.in/DataDog/dd-trace-go.v1 to v1.74.6

Browse Source
This commit is contained in:
Hannah Kim
2025-10-03 04:44:04 -04:00
committed by GitHub
parent 4ff8eca572
commit 8441c476f1
6 changed files with 421 additions and 395 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/provider/kubernetes/gateway/client.go
+1 -1
View File
@@ -28,7 +28,7 @@ type resourceEventHandler struct {
ev chan<- interface{}
}
func (reh *resourceEventHandler) OnAdd(obj interface{}) {
func (reh *resourceEventHandler) OnAdd(obj interface{}, _ bool) {
eventHandlerFunc(reh.ev, obj)
}
pkg/provider/kubernetes/gateway/kubernetes.go
+4 -4
View File
@@ -28,7 +28,7 @@ import (
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/utils/pointer"
"k8s.io/utils/ptr"
"k8s.io/utils/strings/slices"
gatev1alpha2 "sigs.k8s.io/gateway-api/apis/v1alpha2"
)
@@ -1454,7 +1454,7 @@ func loadServices(client Client, namespace string, backendRefs []gatev1alpha2.HT
return nil, nil, fmt.Errorf("traefik internal service %s is not allowed in a WRR loadbalancer", backendRef.BackendRef.Name)
}
weight := int(pointer.Int32Deref(backendRef.Weight, 1))
weight := int(ptr.Deref(backendRef.Weight, 1))
if isTraefikService(backendRef.BackendRef) {
wrrSvc.Weighted.Services = append(wrrSvc.Weighted.Services, dynamic.WRRService{Name: string(backendRef.Name), Weight: &weight})
@@ -1467,7 +1467,7 @@ func loadServices(client Client, namespace string, backendRefs []gatev1alpha2.HT
svc := dynamic.Service{
LoadBalancer: &dynamic.ServersLoadBalancer{
PassHostHeader: pointer.Bool(true),
PassHostHeader: ptr.To(true),
},
}
@@ -1578,7 +1578,7 @@ func loadTCPServices(client Client, namespace string, backendRefs []gatev1alpha2
return nil, nil, fmt.Errorf("traefik internal service %s is not allowed in a WRR loadbalancer", backendRef.Name)
}
weight := int(pointer.Int32Deref(backendRef.Weight, 1))
weight := int(ptr.Deref(backendRef.Weight, 1))
if isTraefikService(backendRef) {
wrrSvc.Weighted.Services = append(wrrSvc.Weighted.Services, dynamic.TCPWRRService{Name: string(backendRef.Name), Weight: &weight})
pkg/provider/kubernetes/gateway/kubernetes_test.go
+199 -201
View File
File diff suppressed because it is too large Load Diff
pkg/provider/kubernetes/k8s/event_handler.go
+1 -1
View File
@@ -11,7 +11,7 @@ type ResourceEventHandler struct {
}
// OnAdd is called on Add Events.
func (reh *ResourceEventHandler) OnAdd(obj interface{}) {
func (reh *ResourceEventHandler) OnAdd(obj interface{}, _ bool) {
eventHandlerFunc(reh.Ev, obj)
}