From 9e2836fe7f75ccc19b7dfaf79d0577b9ec6f2c3d Mon Sep 17 00:00:00 2001 From: closeobserve Date: Sun, 13 Apr 2025 17:46:06 +0800 Subject: [PATCH] chore: fix some comments Signed-off-by: closeobserve --- plugins/common/ssh.go | 2 +- plugins/scheduler-k3s/k8s.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/plugins/common/ssh.go b/plugins/common/ssh.go index 33e477b66..c23f63bc9 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 8ad39e454..2cb7a8095 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 {