- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for StreamOptions (0.2 sec)
-
pkg/registry/core/pod/rest/subresources.go
// for WebSocket/V5 upgrade requests. streamOptions := translator.Options{ Stdin: attachOpts.Stdin, Stdout: attachOpts.Stdout, Stderr: attachOpts.Stderr, Tty: attachOpts.TTY, } maxBytesPerSec := capabilities.Get().PerConnectionBandwidthLimitBytesPerSec streamtranslator := translator.NewStreamTranslatorHandler(location, transport, maxBytesPerSec, streamOptions)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtranslator_test.go
randomData := make([]byte, randomSize) if _, err := rand.Read(randomData); err != nil { t.Errorf("unexpected error reading random data: %v", err) } var stdout bytes.Buffer options := &remotecommand.StreamOptions{ Stdin: bytes.NewReader(randomData), Stdout: &stdout, } errorChan := make(chan error) go func() { // Start the streaming on the WebSocket "exec" client.
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
// the streams instead of the underlying connection *may* not perform the same if two streams // traveling the same direction (e.g. stdout, stderr) are being maxed out. opts := remotecommand.StreamOptions{} if h.Options.Stdin { stdin := websocketStreams.stdinStream if h.MaxBytesPerSec > 0 { stdin = flowrate.NewReader(stdin, h.MaxBytesPerSec) } opts.Stdin = stdin } if h.Options.Stdout {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Feb 27 23:21:55 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/client/tests/remotecommand_test.go
if err != nil { t.Fatalf("%s: unexpected error: %v", name, err) } err = e.StreamWithContext(context.Background(), remoteclient.StreamOptions{ Stdin: streamIn, Stdout: streamOut, Stderr: streamErr, Tty: testCase.Tty, }) hasErr := err != nil if len(testCase.Error) > 0 { if !hasErr {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 06:08:18 UTC 2023 - 10.2K bytes - Viewed (0) -
pkg/kube/client.go
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, }) stdout = stdoutBuf.String() stderr = stderrBuf.String() return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K bytes - Viewed (0) -
common-protos/k8s.io/api/core/v1/generated.proto
} // PodAttachOptions is the query options to a Pod's remote attach call. // --- // TODO: merge w/ PodExecOptions below for stdin, stdout, etc // and also when we cut V2, we should export a "StreamOptions" or somesuch that contains Stdin, Stdout, Stder and TTY message PodAttachOptions { // Stdin if true, redirects the standard input stream of the pod for this call. // Defaults to false. // +optional
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 255.8K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/generated.proto
} // PodAttachOptions is the query options to a Pod's remote attach call. // --- // TODO: merge w/ PodExecOptions below for stdin, stdout, etc // and also when we cut V2, we should export a "StreamOptions" or somesuch that contains Stdin, Stdout, Stder and TTY message PodAttachOptions { // Stdin if true, redirects the standard input stream of the pod for this call. // Defaults to false. // +optional
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 280.3K bytes - Viewed (0) -
staging/src/k8s.io/api/core/v1/types.go
// PodAttachOptions is the query options to a Pod's remote attach call. // --- // TODO: merge w/ PodExecOptions below for stdin, stdout, etc // and also when we cut V2, we should export a "StreamOptions" or somesuch that contains Stdin, Stdout, Stder and TTY type PodAttachOptions struct { metav1.TypeMeta `json:",inline"` // Stdin if true, redirects the standard input stream of the pod for this call.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 390.8K bytes - Viewed (0)