Versions in this module Expand all Collapse all v1 v1.0.1 Feb 17, 2023 v1.0.0 Nov 16, 2022 Changes in this version + func NewConnector() *connector + func ToContainerId(containerName string, pod *apiv1.Pod) (string, error) + type ConnectionContext struct + Namespace string + type Connector interface + Connect func(clientGetter genericclioptions.RESTClientGetter) (kubernetes.Interface, string, error) + type Creator interface + CreateProfilingJob func(*v1.Pod, *config.ProfilerConfig, context.Context) (string, *batchv1.Job, error) + type Deleter interface + DeleteProfilingJob func(*batchv1.Job, context.Context) error + func NewDeleter(clientSet kubernetes.Interface) Deleter + type EventHandler interface + Handle func(events chan string, done chan bool, resultFile chan result.File) + type Getter interface + GetPod func(podName, namespace string, ctx context.Context) (*apiv1.Pod, error) + GetPodLogs func(pod *apiv1.Pod, handler EventHandler, ctx context.Context) (chan bool, chan result.File, error) + GetProfilingPod func(cfg *config.ProfilerConfig, ctx context.Context) (*apiv1.Pod, error) + GetRemoteFile func(pod *apiv1.Pod, remoteFile result.File, localFileName string, ...) (string, error) + func NewGetter(kubeContext KubeContext) Getter + type JobCreator struct + func NewJobCreator(clientSet kubernetes.Interface) *JobCreator + func (c JobCreator) CreateProfilingJob(targetPod *v1.Pod, cfg *config.ProfilerConfig, ctx context.Context) (string, *batchv1.Job, error) + type KubeContext struct + ClientSet kubernetes.Interface + RestConfig *rest.Config
Go to main page