mirrors/kyverno
mirrors/kyverno
1
0
Fork 0
mirror of https://github.com/kyverno/kyverno.git synced 2025-03-13 19:28:55 +00:00
Code Activity

fix: don't create orphan spans in instrumented clients (#5624)

Browse source 
Signed-off-by: Charles-Edouard Brétéché <charles.edouard@nirmata.com>

Signed-off-by: Charles-Edouard Brétéché <charles.edouard@nirmata.com>
This commit is contained in:
Charles-Edouard Brétéché 2022-12-08 15:52:12 +01:00 • committed by GitHub
parent 87ce4b85de
commit aade51e20a
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
7 changed files with 41 additions and 353 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
hack/main.go
View file

@ -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 }}
`

64
pkg/clients/kube/corev1/events/resource.generated.go
View file

@ -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(

24
pkg/clients/kube/corev1/pods/resource.generated.go
View file

@ -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(

12
pkg/clients/kube/corev1/services/resource.generated.go
View file

@ -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(

118
pkg/clients/kube/discovery/resource.generated.go
View file

@ -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()
}

39
pkg/clients/kube/eventsv1beta1/events/resource.generated.go
View file

@ -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(

118
pkg/clients/kyverno/discovery/resource.generated.go
View file

@ -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()
}