From aade51e20a1b76f7cc68a7bdb1e5d5ea1918cd76 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Charles-Edouard=20Br=C3=A9t=C3=A9ch=C3=A9?= Date: Thu, 8 Dec 2022 15:52:12 +0100 Subject: [PATCH] fix: don't create orphan spans in instrumented clients (#5624) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Charles-Edouard Brétéché Signed-off-by: Charles-Edouard Brétéché --- hack/main.go | 19 +-- .../kube/corev1/events/resource.generated.go | 64 +--------- .../kube/corev1/pods/resource.generated.go | 24 +--- .../corev1/services/resource.generated.go | 12 +- .../kube/discovery/resource.generated.go | 118 ++---------------- .../events/resource.generated.go | 39 +----- .../kyverno/discovery/resource.generated.go | 118 ++---------------- 7 files changed, 41 insertions(+), 353 deletions(-) diff --git a/hack/main.go b/hack/main.go index 15f6bf0671..c896d32e61 100644 --- a/hack/main.go +++ b/hack/main.go @@ -149,13 +149,19 @@ func (c *withTracing) {{ $operation.Method.Name }}( {{ GoType $return }}, {{- end -}} ) { - {{- if $operation.HasContext }} + {{- if not $operation.HasContext }} + return c.inner.{{ $operation.Method.Name }}( + {{- range $i, $arg := Args $operation.Method -}} + {{- if $arg.IsVariadic -}} + arg{{ $i }}..., + {{- else -}} + arg{{ $i }}, + {{- end -}} + {{- end -}} + ) + {{- else }} ctx, span := tracing.StartSpan( arg0, - {{- else }} - _, span := tracing.StartSpan( - context.TODO(), - {{- end }} "", fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, {{ Quote $operation.Method.Name }}), tracing.KubeClientGroupKey.String(c.client), @@ -163,9 +169,7 @@ func (c *withTracing) {{ $operation.Method.Name }}( tracing.KubeClientOperationKey.String({{ Quote $operation.Method.Name }}), ) defer span.End() - {{- if $operation.HasContext }} arg0 = ctx - {{- end }} {{ range $i, $ret := Returns $operation.Method }}ret{{ $i }}{{ if not $ret.IsLast -}},{{- end }} {{ end }} := c.inner.{{ $operation.Method.Name }}( {{- range $i, $arg := Args $operation.Method -}} {{- if $arg.IsVariadic -}} @@ -185,6 +189,7 @@ func (c *withTracing) {{ $operation.Method.Name }}( return {{ range $i, $ret := Returns $operation.Method -}} ret{{ $i }}{{ if not $ret.IsLast -}},{{- end }} {{- end }} + {{- end }} } {{- end }} ` diff --git a/pkg/clients/kube/corev1/events/resource.generated.go b/pkg/clients/kube/corev1/events/resource.generated.go index 6ce390bb48..f532cb9683 100644 --- a/pkg/clients/kube/corev1/events/resource.generated.go +++ b/pkg/clients/kube/corev1/events/resource.generated.go @@ -286,18 +286,7 @@ func (c *withTracing) Create(arg0 context.Context, arg1 *k8s_io_api_core_v1.Even return ret0, ret1 } func (c *withTracing) CreateWithEventNamespace(arg0 *k8s_io_api_core_v1.Event) (*k8s_io_api_core_v1.Event, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "CreateWithEventNamespace"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("CreateWithEventNamespace"), - ) - defer span.End() - ret0, ret1 := c.inner.CreateWithEventNamespace(arg0) - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.CreateWithEventNamespace(arg0) } func (c *withTracing) Delete(arg0 context.Context, arg1 string, arg2 k8s_io_apimachinery_pkg_apis_meta_v1.DeleteOptions) error { ctx, span := tracing.StartSpan( @@ -345,17 +334,7 @@ func (c *withTracing) Get(arg0 context.Context, arg1 string, arg2 k8s_io_apimach return ret0, ret1 } func (c *withTracing) GetFieldSelector(arg0 *string, arg1 *string, arg2 *string, arg3 *string) k8s_io_apimachinery_pkg_fields.Selector { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "GetFieldSelector"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("GetFieldSelector"), - ) - defer span.End() - ret0 := c.inner.GetFieldSelector(arg0, arg1, arg2, arg3) - return ret0 + return c.inner.GetFieldSelector(arg0, arg1, arg2, arg3) } func (c *withTracing) List(arg0 context.Context, arg1 k8s_io_apimachinery_pkg_apis_meta_v1.ListOptions) (*k8s_io_api_core_v1.EventList, error) { ctx, span := tracing.StartSpan( @@ -388,32 +367,10 @@ func (c *withTracing) Patch(arg0 context.Context, arg1 string, arg2 k8s_io_apima return ret0, ret1 } func (c *withTracing) PatchWithEventNamespace(arg0 *k8s_io_api_core_v1.Event, arg1 []uint8) (*k8s_io_api_core_v1.Event, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "PatchWithEventNamespace"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("PatchWithEventNamespace"), - ) - defer span.End() - ret0, ret1 := c.inner.PatchWithEventNamespace(arg0, arg1) - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.PatchWithEventNamespace(arg0, arg1) } func (c *withTracing) Search(arg0 *k8s_io_apimachinery_pkg_runtime.Scheme, arg1 k8s_io_apimachinery_pkg_runtime.Object) (*k8s_io_api_core_v1.EventList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "Search"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("Search"), - ) - defer span.End() - ret0, ret1 := c.inner.Search(arg0, arg1) - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.Search(arg0, arg1) } func (c *withTracing) Update(arg0 context.Context, arg1 *k8s_io_api_core_v1.Event, arg2 k8s_io_apimachinery_pkg_apis_meta_v1.UpdateOptions) (*k8s_io_api_core_v1.Event, error) { ctx, span := tracing.StartSpan( @@ -431,18 +388,7 @@ func (c *withTracing) Update(arg0 context.Context, arg1 *k8s_io_api_core_v1.Even return ret0, ret1 } func (c *withTracing) UpdateWithEventNamespace(arg0 *k8s_io_api_core_v1.Event) (*k8s_io_api_core_v1.Event, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "UpdateWithEventNamespace"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("UpdateWithEventNamespace"), - ) - defer span.End() - ret0, ret1 := c.inner.UpdateWithEventNamespace(arg0) - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.UpdateWithEventNamespace(arg0) } func (c *withTracing) Watch(arg0 context.Context, arg1 k8s_io_apimachinery_pkg_apis_meta_v1.ListOptions) (k8s_io_apimachinery_pkg_watch.Interface, error) { ctx, span := tracing.StartSpan( diff --git a/pkg/clients/kube/corev1/pods/resource.generated.go b/pkg/clients/kube/corev1/pods/resource.generated.go index 27c68435a5..72b8ceb340 100644 --- a/pkg/clients/kube/corev1/pods/resource.generated.go +++ b/pkg/clients/kube/corev1/pods/resource.generated.go @@ -463,17 +463,7 @@ func (c *withTracing) Get(arg0 context.Context, arg1 string, arg2 k8s_io_apimach return ret0, ret1 } func (c *withTracing) GetLogs(arg0 string, arg1 *k8s_io_api_core_v1.PodLogOptions) *k8s_io_client_go_rest.Request { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "GetLogs"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("GetLogs"), - ) - defer span.End() - ret0 := c.inner.GetLogs(arg0, arg1) - return ret0 + return c.inner.GetLogs(arg0, arg1) } func (c *withTracing) List(arg0 context.Context, arg1 k8s_io_apimachinery_pkg_apis_meta_v1.ListOptions) (*k8s_io_api_core_v1.PodList, error) { ctx, span := tracing.StartSpan( @@ -506,17 +496,7 @@ func (c *withTracing) Patch(arg0 context.Context, arg1 string, arg2 k8s_io_apima return ret0, ret1 } func (c *withTracing) ProxyGet(arg0 string, arg1 string, arg2 string, arg3 string, arg4 map[string]string) k8s_io_client_go_rest.ResponseWrapper { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ProxyGet"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ProxyGet"), - ) - defer span.End() - ret0 := c.inner.ProxyGet(arg0, arg1, arg2, arg3, arg4) - return ret0 + return c.inner.ProxyGet(arg0, arg1, arg2, arg3, arg4) } func (c *withTracing) Update(arg0 context.Context, arg1 *k8s_io_api_core_v1.Pod, arg2 k8s_io_apimachinery_pkg_apis_meta_v1.UpdateOptions) (*k8s_io_api_core_v1.Pod, error) { ctx, span := tracing.StartSpan( diff --git a/pkg/clients/kube/corev1/services/resource.generated.go b/pkg/clients/kube/corev1/services/resource.generated.go index 32736df52a..4f02e01b86 100644 --- a/pkg/clients/kube/corev1/services/resource.generated.go +++ b/pkg/clients/kube/corev1/services/resource.generated.go @@ -315,17 +315,7 @@ func (c *withTracing) Patch(arg0 context.Context, arg1 string, arg2 k8s_io_apima return ret0, ret1 } func (c *withTracing) ProxyGet(arg0 string, arg1 string, arg2 string, arg3 string, arg4 map[string]string) k8s_io_client_go_rest.ResponseWrapper { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ProxyGet"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ProxyGet"), - ) - defer span.End() - ret0 := c.inner.ProxyGet(arg0, arg1, arg2, arg3, arg4) - return ret0 + return c.inner.ProxyGet(arg0, arg1, arg2, arg3, arg4) } func (c *withTracing) Update(arg0 context.Context, arg1 *k8s_io_api_core_v1.Service, arg2 k8s_io_apimachinery_pkg_apis_meta_v1.UpdateOptions) (*k8s_io_api_core_v1.Service, error) { ctx, span := tracing.StartSpan( diff --git a/pkg/clients/kube/discovery/resource.generated.go b/pkg/clients/kube/discovery/resource.generated.go index 7038716f1c..95f17a290e 100644 --- a/pkg/clients/kube/discovery/resource.generated.go +++ b/pkg/clients/kube/discovery/resource.generated.go @@ -1,14 +1,11 @@ package resource import ( - "context" - "fmt" "time" "github.com/go-logr/logr" github_com_google_gnostic_openapiv2 "github.com/google/gnostic/openapiv2" "github.com/kyverno/kyverno/pkg/metrics" - "github.com/kyverno/kyverno/pkg/tracing" "go.uber.org/multierr" k8s_io_apimachinery_pkg_apis_meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1" k8s_io_apimachinery_pkg_version "k8s.io/apimachinery/pkg/version" @@ -175,126 +172,29 @@ type withTracing struct { } func (c *withTracing) OpenAPISchema() (*github_com_google_gnostic_openapiv2.Document, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "OpenAPISchema"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("OpenAPISchema"), - ) - defer span.End() - ret0, ret1 := c.inner.OpenAPISchema() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.OpenAPISchema() } func (c *withTracing) OpenAPIV3() k8s_io_client_go_openapi.Client { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "OpenAPIV3"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("OpenAPIV3"), - ) - defer span.End() - ret0 := c.inner.OpenAPIV3() - return ret0 + return c.inner.OpenAPIV3() } func (c *withTracing) RESTClient() k8s_io_client_go_rest.Interface { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "RESTClient"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("RESTClient"), - ) - defer span.End() - ret0 := c.inner.RESTClient() - return ret0 + return c.inner.RESTClient() } func (c *withTracing) ServerGroups() (*k8s_io_apimachinery_pkg_apis_meta_v1.APIGroupList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerGroups"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerGroups"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerGroups() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerGroups() } func (c *withTracing) ServerGroupsAndResources() ([]*k8s_io_apimachinery_pkg_apis_meta_v1.APIGroup, []*k8s_io_apimachinery_pkg_apis_meta_v1.APIResourceList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerGroupsAndResources"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerGroupsAndResources"), - ) - defer span.End() - ret0, ret1, ret2 := c.inner.ServerGroupsAndResources() - tracing.SetSpanStatus(span, ret2) - return ret0, ret1, ret2 + return c.inner.ServerGroupsAndResources() } func (c *withTracing) ServerPreferredNamespacedResources() ([]*k8s_io_apimachinery_pkg_apis_meta_v1.APIResourceList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerPreferredNamespacedResources"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerPreferredNamespacedResources"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerPreferredNamespacedResources() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerPreferredNamespacedResources() } func (c *withTracing) ServerPreferredResources() ([]*k8s_io_apimachinery_pkg_apis_meta_v1.APIResourceList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerPreferredResources"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerPreferredResources"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerPreferredResources() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerPreferredResources() } func (c *withTracing) ServerResourcesForGroupVersion(arg0 string) (*k8s_io_apimachinery_pkg_apis_meta_v1.APIResourceList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerResourcesForGroupVersion"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerResourcesForGroupVersion"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerResourcesForGroupVersion(arg0) - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerResourcesForGroupVersion(arg0) } func (c *withTracing) ServerVersion() (*k8s_io_apimachinery_pkg_version.Info, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerVersion"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerVersion"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerVersion() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerVersion() } diff --git a/pkg/clients/kube/eventsv1beta1/events/resource.generated.go b/pkg/clients/kube/eventsv1beta1/events/resource.generated.go index 8f603f8fea..9a810664ab 100644 --- a/pkg/clients/kube/eventsv1beta1/events/resource.generated.go +++ b/pkg/clients/kube/eventsv1beta1/events/resource.generated.go @@ -258,18 +258,7 @@ func (c *withTracing) Create(arg0 context.Context, arg1 *k8s_io_api_events_v1bet return ret0, ret1 } func (c *withTracing) CreateWithEventNamespace(arg0 *k8s_io_api_events_v1beta1.Event) (*k8s_io_api_events_v1beta1.Event, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "CreateWithEventNamespace"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("CreateWithEventNamespace"), - ) - defer span.End() - ret0, ret1 := c.inner.CreateWithEventNamespace(arg0) - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.CreateWithEventNamespace(arg0) } func (c *withTracing) Delete(arg0 context.Context, arg1 string, arg2 k8s_io_apimachinery_pkg_apis_meta_v1.DeleteOptions) error { ctx, span := tracing.StartSpan( @@ -347,18 +336,7 @@ func (c *withTracing) Patch(arg0 context.Context, arg1 string, arg2 k8s_io_apima return ret0, ret1 } func (c *withTracing) PatchWithEventNamespace(arg0 *k8s_io_api_events_v1beta1.Event, arg1 []uint8) (*k8s_io_api_events_v1beta1.Event, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "PatchWithEventNamespace"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("PatchWithEventNamespace"), - ) - defer span.End() - ret0, ret1 := c.inner.PatchWithEventNamespace(arg0, arg1) - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.PatchWithEventNamespace(arg0, arg1) } func (c *withTracing) Update(arg0 context.Context, arg1 *k8s_io_api_events_v1beta1.Event, arg2 k8s_io_apimachinery_pkg_apis_meta_v1.UpdateOptions) (*k8s_io_api_events_v1beta1.Event, error) { ctx, span := tracing.StartSpan( @@ -376,18 +354,7 @@ func (c *withTracing) Update(arg0 context.Context, arg1 *k8s_io_api_events_v1bet return ret0, ret1 } func (c *withTracing) UpdateWithEventNamespace(arg0 *k8s_io_api_events_v1beta1.Event) (*k8s_io_api_events_v1beta1.Event, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "UpdateWithEventNamespace"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("UpdateWithEventNamespace"), - ) - defer span.End() - ret0, ret1 := c.inner.UpdateWithEventNamespace(arg0) - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.UpdateWithEventNamespace(arg0) } func (c *withTracing) Watch(arg0 context.Context, arg1 k8s_io_apimachinery_pkg_apis_meta_v1.ListOptions) (k8s_io_apimachinery_pkg_watch.Interface, error) { ctx, span := tracing.StartSpan( diff --git a/pkg/clients/kyverno/discovery/resource.generated.go b/pkg/clients/kyverno/discovery/resource.generated.go index 7038716f1c..95f17a290e 100644 --- a/pkg/clients/kyverno/discovery/resource.generated.go +++ b/pkg/clients/kyverno/discovery/resource.generated.go @@ -1,14 +1,11 @@ package resource import ( - "context" - "fmt" "time" "github.com/go-logr/logr" github_com_google_gnostic_openapiv2 "github.com/google/gnostic/openapiv2" "github.com/kyverno/kyverno/pkg/metrics" - "github.com/kyverno/kyverno/pkg/tracing" "go.uber.org/multierr" k8s_io_apimachinery_pkg_apis_meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1" k8s_io_apimachinery_pkg_version "k8s.io/apimachinery/pkg/version" @@ -175,126 +172,29 @@ type withTracing struct { } func (c *withTracing) OpenAPISchema() (*github_com_google_gnostic_openapiv2.Document, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "OpenAPISchema"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("OpenAPISchema"), - ) - defer span.End() - ret0, ret1 := c.inner.OpenAPISchema() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.OpenAPISchema() } func (c *withTracing) OpenAPIV3() k8s_io_client_go_openapi.Client { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "OpenAPIV3"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("OpenAPIV3"), - ) - defer span.End() - ret0 := c.inner.OpenAPIV3() - return ret0 + return c.inner.OpenAPIV3() } func (c *withTracing) RESTClient() k8s_io_client_go_rest.Interface { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "RESTClient"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("RESTClient"), - ) - defer span.End() - ret0 := c.inner.RESTClient() - return ret0 + return c.inner.RESTClient() } func (c *withTracing) ServerGroups() (*k8s_io_apimachinery_pkg_apis_meta_v1.APIGroupList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerGroups"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerGroups"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerGroups() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerGroups() } func (c *withTracing) ServerGroupsAndResources() ([]*k8s_io_apimachinery_pkg_apis_meta_v1.APIGroup, []*k8s_io_apimachinery_pkg_apis_meta_v1.APIResourceList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerGroupsAndResources"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerGroupsAndResources"), - ) - defer span.End() - ret0, ret1, ret2 := c.inner.ServerGroupsAndResources() - tracing.SetSpanStatus(span, ret2) - return ret0, ret1, ret2 + return c.inner.ServerGroupsAndResources() } func (c *withTracing) ServerPreferredNamespacedResources() ([]*k8s_io_apimachinery_pkg_apis_meta_v1.APIResourceList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerPreferredNamespacedResources"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerPreferredNamespacedResources"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerPreferredNamespacedResources() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerPreferredNamespacedResources() } func (c *withTracing) ServerPreferredResources() ([]*k8s_io_apimachinery_pkg_apis_meta_v1.APIResourceList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerPreferredResources"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerPreferredResources"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerPreferredResources() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerPreferredResources() } func (c *withTracing) ServerResourcesForGroupVersion(arg0 string) (*k8s_io_apimachinery_pkg_apis_meta_v1.APIResourceList, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerResourcesForGroupVersion"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerResourcesForGroupVersion"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerResourcesForGroupVersion(arg0) - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerResourcesForGroupVersion(arg0) } func (c *withTracing) ServerVersion() (*k8s_io_apimachinery_pkg_version.Info, error) { - _, span := tracing.StartSpan( - context.TODO(), - "", - fmt.Sprintf("KUBE %s/%s/%s", c.client, c.kind, "ServerVersion"), - tracing.KubeClientGroupKey.String(c.client), - tracing.KubeClientKindKey.String(c.kind), - tracing.KubeClientOperationKey.String("ServerVersion"), - ) - defer span.End() - ret0, ret1 := c.inner.ServerVersion() - tracing.SetSpanStatus(span, ret1) - return ret0, ret1 + return c.inner.ServerVersion() }