diff --git a/pkg/provider/kubernetes/crd/client.go b/pkg/provider/kubernetes/crd/client.go index 5154c1f94..aa9d61d6f 100644 --- a/pkg/provider/kubernetes/crd/client.go +++ b/pkg/provider/kubernetes/crd/client.go @@ -4,12 +4,16 @@ import ( "errors" "fmt" "io/ioutil" + "os" + "path/filepath" + "runtime" "time" "github.com/traefik/traefik/v2/pkg/log" "github.com/traefik/traefik/v2/pkg/provider/kubernetes/crd/generated/clientset/versioned" "github.com/traefik/traefik/v2/pkg/provider/kubernetes/crd/generated/informers/externalversions" "github.com/traefik/traefik/v2/pkg/provider/kubernetes/crd/traefik/v1alpha1" + "github.com/traefik/traefik/v2/pkg/version" corev1 "k8s.io/api/core/v1" kubeerror "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" @@ -75,6 +79,14 @@ type clientWrapper struct { } func createClientFromConfig(c *rest.Config) (*clientWrapper, error) { + c.UserAgent = fmt.Sprintf( + "%s/%s (%s/%s) kubernetes/crd", + filepath.Base(os.Args[0]), + version.Version, + runtime.GOOS, + runtime.GOARCH, + ) + csCrd, err := versioned.NewForConfig(c) if err != nil { return nil, err diff --git a/pkg/provider/kubernetes/ingress/client.go b/pkg/provider/kubernetes/ingress/client.go index 6090af3a1..479e130c4 100644 --- a/pkg/provider/kubernetes/ingress/client.go +++ b/pkg/provider/kubernetes/ingress/client.go @@ -5,10 +5,14 @@ import ( "errors" "fmt" "io/ioutil" + "os" + "path/filepath" + "runtime" "time" "github.com/hashicorp/go-version" "github.com/traefik/traefik/v2/pkg/log" + traefikversion "github.com/traefik/traefik/v2/pkg/version" corev1 "k8s.io/api/core/v1" extensionsv1beta1 "k8s.io/api/extensions/v1beta1" networkingv1beta1 "k8s.io/api/networking/v1beta1" @@ -118,6 +122,14 @@ func newExternalClusterClient(endpoint, token, caFilePath string) (*clientWrappe } func createClientFromConfig(c *rest.Config) (*clientWrapper, error) { + c.UserAgent = fmt.Sprintf( + "%s/%s (%s/%s) kubernetes/ingress", + filepath.Base(os.Args[0]), + traefikversion.Version, + runtime.GOOS, + runtime.GOARCH, + ) + clientset, err := kubernetes.NewForConfig(c) if err != nil { return nil, err