tracing

Documentation

Index

• func NewK8sClient(inner client.Client, traceProvider trace.TracerProvider) client.Client
• func SetSpanErr(span trace.Span, err error)
• type K8sClient
  • func (k *K8sClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error
  • func (k *K8sClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error
  • func (k *K8sClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error
  • func (k *K8sClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object, ...) error
  • func (k *K8sClient) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)
  • func (k *K8sClient) IsObjectNamespaced(obj runtime.Object) (bool, error)
  • func (k *K8sClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
  • func (k *K8sClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (k *K8sClient) RESTMapper() meta.RESTMapper
  • func (k *K8sClient) Scheme() *runtime.Scheme
  • func (k *K8sClient) Status() client.SubResourceWriter
  • func (k *K8sClient) SubResource(subResource string) client.SubResourceClient
  • func (k *K8sClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error
• type K8sSubresourceClient
  • func (k *K8sSubresourceClient) Create(ctx context.Context, obj, subResource client.Object, ...) error
  • func (k *K8sSubresourceClient) Get(ctx context.Context, obj, subResource client.Object, ...) error
  • func (k *K8sSubresourceClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, ...) error
  • func (k *K8sSubresourceClient) Update(ctx context.Context, obj client.Object, opts ...client.SubResourceUpdateOption) error

Functions

func NewK8sClient

func NewK8sClient(inner client.Client, traceProvider trace.TracerProvider) client.Client

func SetSpanErr

func SetSpanErr(span trace.Span, err error)

Types

type K8sClient

type K8sClient struct {
	// contains filtered or unexported fields
}

func (*K8sClient) Create

func (k *K8sClient) Create(ctx context.Context, obj client.Object, opts ...client.CreateOption) error

func (*K8sClient) Delete

func (k *K8sClient) Delete(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error

func (*K8sClient) DeleteAllOf

func (k *K8sClient) DeleteAllOf(ctx context.Context, obj client.Object, opts ...client.DeleteAllOfOption) error

func (*K8sClient) Get

func (k *K8sClient) Get(ctx context.Context, key client.ObjectKey, obj client.Object, opts ...client.GetOption) error

func (*K8sClient) GroupVersionKindFor

func (k *K8sClient) GroupVersionKindFor(obj runtime.Object) (schema.GroupVersionKind, error)

func (*K8sClient) IsObjectNamespaced

func (k *K8sClient) IsObjectNamespaced(obj runtime.Object) (bool, error)

func (*K8sClient) List

func (k *K8sClient) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error

func (*K8sClient) Patch

func (k *K8sClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.PatchOption) error

func (*K8sClient) RESTMapper

func (k *K8sClient) RESTMapper() meta.RESTMapper

func (*K8sClient) Scheme

func (k *K8sClient) Scheme() *runtime.Scheme

func (*K8sClient) Status

func (k *K8sClient) Status() client.SubResourceWriter

func (*K8sClient) SubResource

func (k *K8sClient) SubResource(subResource string) client.SubResourceClient

func (*K8sClient) Update

func (k *K8sClient) Update(ctx context.Context, obj client.Object, opts ...client.UpdateOption) error

type K8sSubresourceClient

type K8sSubresourceClient struct {
	// contains filtered or unexported fields
}

func (*K8sSubresourceClient) Create

func (k *K8sSubresourceClient) Create(ctx context.Context, obj, subResource client.Object, opts ...client.SubResourceCreateOption) error

func (*K8sSubresourceClient) Get

func (k *K8sSubresourceClient) Get(ctx context.Context, obj, subResource client.Object, opts ...client.SubResourceGetOption) error

func (*K8sSubresourceClient) Patch

func (k *K8sSubresourceClient) Patch(ctx context.Context, obj client.Object, patch client.Patch, opts ...client.SubResourcePatchOption) error

func (*K8sSubresourceClient) Update

func (k *K8sSubresourceClient) Update(ctx context.Context, obj client.Object, opts ...client.SubResourceUpdateOption) error