server-manager/backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added log on failure to attach
Some checks failed
Build and Push Docker Image / Build image (push) Has been cancelled
Details

Browse Source
This commit is contained in:
ACoolName 2025-04-09 16:45:18 +03:00
parent c647f76894
commit 4ffaabd6e6
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
instancemanager/kubernetes/instance_manager.go
View File

@ -3,6 +3,7 @@ package kubernetes
import ( import (
"context" "context"
"io" "io"
"log"
"os" "os"
"path/filepath" "path/filepath"
"strings" "strings"
@ -250,8 +251,8 @@ func (i *InstanceManager) InteractiveTerminal(ctx context.Context, serverId stri
req := i.coreV1Cli.CoreV1().RESTClient(). req := i.coreV1Cli.CoreV1().RESTClient().
Post(). Post().
Resource("pods"). Resource("pods").
Namespace(i.Config.Namespace).
Name(serverId). Name(serverId).
Namespace(i.Config.Namespace).
SubResource("attach"). SubResource("attach").
VersionedParams(&corev1.PodAttachOptions{ VersionedParams(&corev1.PodAttachOptions{
Stdin: true, Stdin: true,
@ -264,7 +265,10 @@ func (i *InstanceManager) InteractiveTerminal(ctx context.Context, serverId stri
go func() { go func() {
defer stdoutWriter.Close() defer stdoutWriter.Close()
defer stdinReader.Close() defer stdinReader.Close()
_ = executor.StreamWithContext(ctx, remotecommand.StreamOptions{Stdin: stdinReader, Stdout: stdoutWriter, Stderr: stdoutWriter, Tty: true, TerminalSizeQueue: queue}) err := executor.StreamWithContext(ctx, remotecommand.StreamOptions{Stdin: stdinReader, Stdout: stdoutWriter, Stderr: stdoutWriter, Tty: true, TerminalSizeQueue: queue})
if err != nil {
log.Printf("Failed to attach %e", err)
}
}() }()
if err != nil { if err != nil {