Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for getAttach (0.3 sec)

  1. pkg/kubelet/server/server.go

    		To(s.getAttach).
    		Operation("getAttach"))
    	ws.Route(ws.POST("/{podNamespace}/{podID}/{containerName}").
    		To(s.getAttach).
    		Operation("getAttach"))
    	ws.Route(ws.GET("/{podNamespace}/{podID}/{uid}/{containerName}").
    		To(s.getAttach).
    		Operation("getAttach"))
    	ws.Route(ws.POST("/{podNamespace}/{podID}/{uid}/{containerName}").
    		To(s.getAttach).
    		Operation("getAttach"))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 40.1K bytes
    - Viewed (0)
  2. pkg/kubelet/container/testing/runtime_mock.go

    	return m.recorder
    }
    
    // GetAttach mocks base method.
    func (m *MockStreamingRuntime) GetAttach(ctx context.Context, id container.ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error) {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "GetAttach", ctx, id, stdin, stdout, stderr, tty)
    	ret0, _ := ret[0].(*url.URL)
    	ret1, _ := ret[1].(error)
    	return ret0, ret1
    }
    
    // GetAttach indicates an expected call of GetAttach.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 27K bytes
    - Viewed (0)
  3. pkg/kubelet/container/testing/fake_runtime.go

    	return &url.URL{Host: FakeHost}, f.Err
    }
    
    func (f *FakeStreamingRuntime) GetAttach(_ context.Context, id kubecontainer.ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error) {
    	f.Lock()
    	defer f.Unlock()
    
    	f.CalledFunctions = append(f.CalledFunctions, "GetAttach")
    	return &url.URL{Host: FakeHost}, f.Err
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 00:23:50 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  4. pkg/kubelet/server/server_test.go

    	return url.Parse(resp.GetUrl())
    }
    
    func (fk *fakeKubelet) GetAttach(_ context.Context, podFullName string, podUID types.UID, containerName string, streamOpts remotecommandserver.Options) (*url.URL, error) {
    	if fk.getAttachCheck != nil {
    		fk.getAttachCheck(podFullName, podUID, containerName, streamOpts)
    	}
    	// Always use testContainerID
    	resp, err := fk.streamingRuntime.GetAttach(&runtimeapi.AttachRequest{
    		ContainerId: testContainerID,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  5. pkg/kubelet/kuberuntime/kuberuntime_container.go

    	}
    	resp, err := m.runtimeService.Exec(ctx, req)
    	if err != nil {
    		return nil, err
    	}
    
    	return url.Parse(resp.Url)
    }
    
    // GetAttach gets the endpoint the runtime will serve the attach request from.
    func (m *kubeGenericRuntimeManager) GetAttach(ctx context.Context, id kubecontainer.ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error) {
    	req := &runtimeapi.AttachRequest{
    		ContainerId: id.ID,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  6. pkg/kubelet/container/runtime.go

    // the runtime server.
    type StreamingRuntime interface {
    	GetExec(ctx context.Context, id ContainerID, cmd []string, stdin, stdout, stderr, tty bool) (*url.URL, error)
    	GetAttach(ctx context.Context, id ContainerID, stdin, stdout, stderr, tty bool) (*url.URL, error)
    	GetPortForward(ctx context.Context, podName, podNamespace string, podUID types.UID, ports []int32) (*url.URL, error)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_pods.go

    	}
    	return kl.streamingRuntime.GetExec(ctx, container.ID, cmd, streamOpts.Stdin, streamOpts.Stdout, streamOpts.Stderr, streamOpts.TTY)
    }
    
    // GetAttach gets the URL the attach will be served from, or nil if the Kubelet will serve it.
    func (kl *Kubelet) GetAttach(ctx context.Context, podFullName string, podUID types.UID, containerName string, streamOpts remotecommandserver.Options) (*url.URL, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top