kubernetes

Documentation

Overview

: Copyright Verizon Media : Licensed under the terms of the Apache 2.0 License. See LICENSE file in the project root for terms.

: Copyright Verizon Media : Licensed under the terms of the Apache 2.0 License. See LICENSE file in the project root for terms.

: Copyright Verizon Media : Licensed under the terms of the Apache 2.0 License. See LICENSE file in the project root for terms.

Index

• func Connect(clientGetter genericclioptions.RESTClientGetter) (string, error)
• func DeleteProfilingJob(job *batchv1.Job, targetDetails *data.TargetDetails, ctx context.Context) error
• func GetContainerId(containerName string, pod *apiv1.Pod) (string, error)
• func GetLogsFromPod(pod *apiv1.Pod, handler DataHandler, ctx context.Context) (chan bool, error)
• func GetPodDetails(podName, namespace string, ctx context.Context) (*apiv1.Pod, error)
• func LaunchFlameJob(targetPod *v1.Pod, cfg *data.FlameConfig, ctx context.Context) (string, *batchv1.Job, error)
• func WaitForPodStart(target *data.TargetDetails, ctx context.Context) (*apiv1.Pod, error)
• type DataHandler

Functions

func Connect

func Connect(clientGetter genericclioptions.RESTClientGetter) (string, error)

func DeleteProfilingJob

func DeleteProfilingJob(job *batchv1.Job, targetDetails *data.TargetDetails, ctx context.Context) error

func GetContainerId

func GetContainerId(containerName string, pod *apiv1.Pod) (string, error)

func GetLogsFromPod

func GetLogsFromPod(pod *apiv1.Pod, handler DataHandler, ctx context.Context) (chan bool, error)

func GetPodDetails

func GetPodDetails(podName, namespace string, ctx context.Context) (*apiv1.Pod, error)

func LaunchFlameJob

func LaunchFlameJob(targetPod *v1.Pod, cfg *data.FlameConfig, ctx context.Context) (string, *batchv1.Job, error)

func WaitForPodStart

func WaitForPodStart(target *data.TargetDetails, ctx context.Context) (*apiv1.Pod, error)

Types

type DataHandler

type DataHandler interface {
	Handle(events chan string, done chan bool, ctx context.Context)
}