2 Commits

Author SHA1 Message Date
4ffaabd6e6 added log on failure to attach
Some checks failed
Build and Push Docker Image / Build image (push) Has been cancelled
2025-04-09 16:45:18 +03:00
c647f76894 removed container attach thingy 2025-04-09 16:20:34 +03:00

View File

@@ -3,6 +3,7 @@ package kubernetes
import ( import (
"context" "context"
"io" "io"
"log"
"os" "os"
"path/filepath" "path/filepath"
"strings" "strings"
@@ -250,22 +251,24 @@ 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{
Container: "server", Stdin: true,
Stdin: true, Stdout: true,
Stdout: true, Stderr: true,
Stderr: true, TTY: true,
TTY: true,
}, clientgoscheme.ParameterCodec) }, clientgoscheme.ParameterCodec)
executor, err := remotecommand.NewSPDYExecutor(i.restCfg, "POST", req.URL()) executor, err := remotecommand.NewSPDYExecutor(i.restCfg, "POST", req.URL())
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 {