- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for remotecommand (0.34 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/doc.go
// // "v3.channel.k8s.io" // // The third version of the Websocket RemoteCommand subprotocol adds another channel // for terminal resizing events. This channel is prepended with the byte '3', and it // transmits two window sizes (encoding TerminalSize struct) with integers in the range // (0,65536]. // // "v4.channel.k8s.io" // // The fourth version of the Websocket RemoteCommand subprotocol adds a channel for
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 18:37:18 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/client/tests/remotecommand_test.go
"k8s.io/apimachinery/pkg/types" "k8s.io/apimachinery/pkg/util/httpstream" remotecommandconsts "k8s.io/apimachinery/pkg/util/remotecommand" restclient "k8s.io/client-go/rest" remoteclient "k8s.io/client-go/tools/remotecommand" "k8s.io/client-go/transport/spdy" "k8s.io/kubelet/pkg/cri/streaming/remotecommand" "k8s.io/kubernetes/pkg/api/legacyscheme" api "k8s.io/kubernetes/pkg/apis/core" ) type fakeExecutor struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 06:08:18 UTC 2023 - 10.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/remotecommand/constants.go
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ package remotecommand import ( "time" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" ) const ( DefaultStreamCreationTimeout = 30 * time.Second // The SPDY subprotocol "channel.k8s.io" is used for remote command
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 05 18:37:18 UTC 2023 - 2.4K 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)