diff --git a/plugins/common/ssh.go b/plugins/common/ssh.go index 33e477b668a..c23f63bc92f 100644 --- a/plugins/common/ssh.go +++ b/plugins/common/ssh.go @@ -65,7 +65,7 @@ func CallSshCommand(input SshCommandInput) (SshResult, error) { return CallSshCommandWithContext(context.Background(), input) } -// CallSshCommand executes a command on a remote host via ssh with the given context +// CallSshCommandWithContext executes a command on a remote host via ssh with the given context func CallSshCommandWithContext(ctx context.Context, input SshCommandInput) (SshResult, error) { signals := make(chan os.Signal, 1) signal.Notify(signals, os.Interrupt, syscall.SIGHUP, diff --git a/plugins/scheduler-k3s/k8s.go b/plugins/scheduler-k3s/k8s.go index 8ad39e4540f..2cb7a8095fb 100644 --- a/plugins/scheduler-k3s/k8s.go +++ b/plugins/scheduler-k3s/k8s.go @@ -449,7 +449,7 @@ type GetPodInput struct { Namespace string } -// GetJob gets a Kubernetes job +// GetPod gets a Kubernetes pod func (k KubernetesClient) GetPod(ctx context.Context, input GetPodInput) (corev1.Pod, error) { pod, err := k.Client.CoreV1().Pods(input.Namespace).Get(ctx, input.Name, metav1.GetOptions{}) if err != nil {