kubernetes

Documentation

Overview

Package kubernetes provides functions to trace k8s.io/client-go (https://github.com/kubernetes/client-go).

Example

package main

import (
	"fmt"

	meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/rest"

	kubernetestrace "gopkg.in/DataDog/dd-trace-go.v1/contrib/k8s.io/client-go/kubernetes"
	_ "k8s.io/client-go/plugin/pkg/client/auth/oidc"
)

func main() {
	cfg, err := rest.InClusterConfig()
	if err != nil {
		panic(err.Error())
	}
	// Use this to trace all calls made to the Kubernetes API
	cfg.WrapTransport = kubernetestrace.WrapRoundTripper

	client, err := kubernetes.NewForConfig(cfg)
	if err != nil {
		panic(err.Error())
	}

	pods, err := client.CoreV1().Pods("default").List(meta_v1.ListOptions{})
	if err != nil {
		panic(err)
	}

	fmt.Println(pods.Items)
}

Index

• func RequestToResource(method, path string) string
• func WrapRoundTripper(rt http.RoundTripper) http.RoundTripper
• func WrapRoundTripperFunc(opts ...httptrace.RoundTripperOption) func(http.RoundTripper) http.RoundTripper

Examples

• Package

Functions

func RequestToResource

func RequestToResource(method, path string) string

RequestToResource parses a Kubernetes request and extracts a resource name from it.

func WrapRoundTripper

func WrapRoundTripper(rt http.RoundTripper) http.RoundTripper

WrapRoundTripper wraps a RoundTripper intended for interfacing with Kubernetes and traces all requests.

func WrapRoundTripperFunc

func WrapRoundTripperFunc(opts ...httptrace.RoundTripperOption) func(http.RoundTripper) http.RoundTripper

WrapRoundTripperFunc creates a new WrapTransport function using the given set of RountripperOption. It is useful when desiring to to enable Trace Analytics or setting up a RoundTripperAfterFunc.