- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for remotecommand (0.37 sec)
-
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
"k8s.io/apimachinery/pkg/util/httpstream" "k8s.io/apimachinery/pkg/util/httpstream/spdy" rcconstants "k8s.io/apimachinery/pkg/util/remotecommand" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/util/proxy/metrics" "k8s.io/client-go/rest" "k8s.io/client-go/tools/remotecommand" "k8s.io/client-go/transport" "k8s.io/component-base/metrics/legacyregistry" "k8s.io/component-base/metrics/testutil" )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 36.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator.go
apierrors "k8s.io/apimachinery/pkg/api/errors" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "k8s.io/apimachinery/pkg/util/httpstream/spdy" constants "k8s.io/apimachinery/pkg/util/remotecommand" "k8s.io/apiserver/pkg/util/proxy/metrics" "k8s.io/client-go/tools/remotecommand" "k8s.io/client-go/util/exec" ) // StreamTranslatorHandler is a handler which translates WebSocket stream data // to SPDY to proxy to kubelet (and ContainerRuntime).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/websocket.go
"io" "net/http" "time" apierrors "k8s.io/apimachinery/pkg/api/errors" "k8s.io/apimachinery/pkg/util/httpstream/wsstream" constants "k8s.io/apimachinery/pkg/util/remotecommand" "k8s.io/apimachinery/pkg/util/runtime" "k8s.io/client-go/tools/remotecommand" ) const ( // idleTimeout is the read/write deadline set for websocket server connection. Reading
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 6.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
return conn.closeNonThreadSafe() } // protocolSupportsStreamClose returns true if the passed protocol // supports the stream close signal (currently only V5 remotecommand); // false otherwise. func protocolSupportsStreamClose(protocol string) bool { return protocol == remotecommand.StreamProtocolV5Name } // protocolSupportsWebsocketTunneling returns true if the passed protocol // is a tunneled Kubernetes spdy protocol; false otherwise.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/metrics/metrics.go
&metrics.CounterOpts{ Subsystem: subsystem, Name: "stream_translator_requests_total", Help: "Total number of requests that were handled by the StreamTranslatorProxy, which processes streaming RemoteCommand/V5", StabilityLevel: metrics.ALPHA, }, []string{statuscode}, ) ) func Register() { registerMetricsOnce.Do(func() { legacyregistry.MustRegister(streamTranslatorRequestsTotal) }) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 1.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/doc.go
// stream proxies: streamtranslator.go and streamtunnel.go. Both of // these proxies allow the inter-connection of WebSocket and SPDY // streaming connections. // // The stream translator proxy is used for the RemoteCommand // subprotocol (e.g. kubectl exec, cp, and attach), and it connects // the output streams of a WebSocket connection (e.g. STDIN, STDOUT, // STDERR, TTY resize, and error streams) to the input streams of a // SPDY connection.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 17:56:46 UTC 2024 - 1.7K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
return nil, nil } type fakeRuntime struct { execFunc func(string, []string, io.Reader, io.WriteCloser, io.WriteCloser, bool, <-chan remotecommand.TerminalSize) error attachFunc func(string, io.Reader, io.WriteCloser, io.WriteCloser, bool, <-chan remotecommand.TerminalSize) error portForwardFunc func(string, int32, io.ReadWriteCloser) error }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
pkg/kubelet/container/testing/runtime_mock.go
import ( context "context" io "io" url "net/url" reflect "reflect" time "time" gomock "go.uber.org/mock/gomock" v1 "k8s.io/api/core/v1" types "k8s.io/apimachinery/pkg/types" remotecommand "k8s.io/client-go/tools/remotecommand" flowcontrol "k8s.io/client-go/util/flowcontrol" v10 "k8s.io/cri-api/pkg/apis/runtime/v1" container "k8s.io/kubernetes/pkg/kubelet/container" ) // MockVersion is a mock of Version interface.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 27K bytes - Viewed (0) -
staging/publishing/import-restrictions.yaml
- "./staging/src/k8s.io/client-go/tools/record" - "./staging/src/k8s.io/client-go/tools/events" - "./staging/src/k8s.io/client-go/tools/reference" - "./staging/src/k8s.io/client-go/tools/remotecommand" allowedImports: - k8s.io/apimachinery - k8s.io/client-go - k8s.io/klog - k8s.io/utils - baseImportPath: "./staging/src/k8s.io/apiserver" allowedImports: - k8s.io/api
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 13:13:22 UTC 2024 - 7.7K bytes - Viewed (0) -
pkg/kube/client.go
if err != nil { return "", "", err } exec, err := remotecommand.NewSPDYExecutorForTransports(wrapper, upgrader, "POST", req.URL()) if err != nil { return "", "", err } var stdoutBuf, stderrBuf bytes.Buffer err = exec.StreamWithContext(context.Background(), remotecommand.StreamOptions{ Stdin: nil, Stdout: &stdoutBuf, Stderr: &stderrBuf, Tty: false, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0)