Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for StreamOptions (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to top