k8s

Documentation

Index

• func AddConfig(config *config.Config, outputPath string, kind string, namespace string, ...)
• func AddDescription(config *config.Config, outputPath string, kind string, namespace string, ...)
• func AddHttpConnectionTest(config *config.Config, outputPath string, namespace string, name string, ...)
• func AddKubernetesNodesInformation(cfg *config.Config)
• func AddLogs(cfg *config.Config, path string, namespace string, name string)
• func AddPodHttpEndpointOutput(options AddPodHttpEndpointOutputOptions)
• func AddPodHttpMultipleEndpointOutput(options AddPodHttpEndpointsOutputOptions)
• func AddPreviousLogs(cfg *config.Config, path string, namespace string, name string)
• func AddResourceUsage(cfg *config.Config, path string, namespace string, name string, executions int)
• func AddTracerouteConnectionTest(config *config.Config, outputPath string, namespace string, name string, ...)
• func AddWebsocketCurlHttp1ConnectionTest(config *config.Config, outputPath string, namespace string, name string, ...)
• func AddWebsocketCurlHttp2ConnectionTest(config *config.Config, outputPath string, namespace string, name string, ...)
• func AddWebsocketWebsocatConnectionTest(config *config.Config, outputPath string, namespace string, name string, ...)
• func DownloadFromPod(options AddDownloadOutputOptions)
• func FindDeployment(cfg *config.Config, namespace string, name string) (*appsv1.Deployment, error)
• func FindStatefulSet(cfg *config.Config, namespace string, name string) (*appsv1.StatefulSet, error)
• func ForEachNode(cfg *config.Config, fn func(node *v1.Node))
• func ForEachPod(cfg *config.Config, namespace string, selector *metav1.LabelSelector, ...)
• func ForEachPodViaMapSelector(cfg *config.Config, namespace string, selectorMap map[string]string, ...)
• func KillProcess(cmd *exec.Cmd, options PodConfig)
• func PreparePortforwarding(options PodConfig, port int) (string, *exec.Cmd, error)
• type AddDownloadOutputOptions
• type AddPodHttpEndpointOutputOptions
• type AddPodHttpEndpointsOutputOptions
• type Connection
  • func GetExtensionConnections(sharedPort int, podConfig PodConfig, cfg *config.Config) []Connection
• type EndpointsOutputOptions
• type PodConfig

Functions

func AddConfig

func AddConfig(config *config.Config, outputPath string, kind string, namespace string, name string)

func AddDescription

func AddDescription(config *config.Config, outputPath string, kind string, namespace string, name string)

func AddHttpConnectionTest

func AddHttpConnectionTest(config *config.Config, outputPath string, namespace string, name string, containerName string, url string)

func AddKubernetesNodesInformation

func AddKubernetesNodesInformation(cfg *config.Config)

func AddLogs

func AddLogs(cfg *config.Config, path string, namespace string, name string)

func AddPodHttpEndpointOutput

func AddPodHttpEndpointOutput(options AddPodHttpEndpointOutputOptions)

func AddPodHttpMultipleEndpointOutput

func AddPodHttpMultipleEndpointOutput(options AddPodHttpEndpointsOutputOptions)

func AddPreviousLogs

func AddPreviousLogs(cfg *config.Config, path string, namespace string, name string)

func AddResourceUsage

func AddResourceUsage(cfg *config.Config, path string, namespace string, name string, executions int)

AddResourceUsage path must include '%d' to replace the execution number within the file path

func AddTracerouteConnectionTest

func AddTracerouteConnectionTest(config *config.Config, outputPath string, namespace string, name string, containerName string, host string)

func AddWebsocketCurlHttp1ConnectionTest

func AddWebsocketCurlHttp1ConnectionTest(config *config.Config, outputPath string, namespace string, name string, containerName string, url string)

func AddWebsocketCurlHttp2ConnectionTest

func AddWebsocketCurlHttp2ConnectionTest(config *config.Config, outputPath string, namespace string, name string, containerName string, url string)

func AddWebsocketWebsocatConnectionTest

func AddWebsocketWebsocatConnectionTest(config *config.Config, outputPath string, namespace string, name string, containerName string, url string)

func DownloadFromPod

func DownloadFromPod(options AddDownloadOutputOptions)

func FindDeployment

func FindDeployment(cfg *config.Config, namespace string, name string) (*appsv1.Deployment, error)

func FindStatefulSet

func FindStatefulSet(cfg *config.Config, namespace string, name string) (*appsv1.StatefulSet, error)

func ForEachNode

func ForEachNode(cfg *config.Config, fn func(node *v1.Node))

ForEachNode note that the function fn will be executed in parallel for each node

func ForEachPod

func ForEachPod(cfg *config.Config, namespace string, selector *metav1.LabelSelector, fn func(pod *v1.Pod, idx int))

ForEachPod note that the function fn will be executed in parallel for each pod

func ForEachPodViaMapSelector

func ForEachPodViaMapSelector(cfg *config.Config, namespace string, selectorMap map[string]string, fn func(pod *v1.Pod, idx int))

ForEachPodViaMapSelector note that the function fn will be executed in parallel for each pod

func KillProcess

func KillProcess(cmd *exec.Cmd, options PodConfig)

func PreparePortforwarding

func PreparePortforwarding(options PodConfig, port int) (string, *exec.Cmd, error)

Types

type AddDownloadOutputOptions

type AddDownloadOutputOptions struct {
	Config       *config.Config
	OutputPath   string
	PodNamespace string
	PodName      string
	Url          string
	Method       string
}

type AddPodHttpEndpointOutputOptions

type AddPodHttpEndpointOutputOptions struct {
	Config                 *config.Config
	OutputPath             string
	PodNamespace           string
	PodName                string
	Url                    string
	Executions             int
	DelayBetweenExecutions *time.Duration
}

type AddPodHttpEndpointsOutputOptions

type AddPodHttpEndpointsOutputOptions struct {
	SharedPort      int
	PodConfig       PodConfig
	EndpointOptions []EndpointsOutputOptions
}

type Connection

type Connection struct {
	Url    string
	Auth   bool
	Method string
}

func GetExtensionConnections

func GetExtensionConnections(sharedPort int, podConfig PodConfig, cfg *config.Config) []Connection

type EndpointsOutputOptions

type EndpointsOutputOptions struct {
	OutputPath             string
	Url                    string
	Executions             int
	DelayBetweenExecutions *time.Duration
}

type PodConfig

type PodConfig struct {
	PodNamespace string
	PodName      string
	Config       *config.Config
}