Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for getPortForward (0.41 sec)

  1. pkg/kubelet/server/server.go

    	ws.Route(ws.GET("/{podNamespace}/{podID}").
    		To(s.getPortForward).
    		Operation("getPortForward"))
    	ws.Route(ws.POST("/{podNamespace}/{podID}").
    		To(s.getPortForward).
    		Operation("getPortForward"))
    	ws.Route(ws.GET("/{podNamespace}/{podID}/{uid}").
    		To(s.getPortForward).
    		Operation("getPortForward"))
    	ws.Route(ws.POST("/{podNamespace}/{podID}/{uid}").
    		To(s.getPortForward).
    		Operation("getPortForward"))
    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

    }
    
    // GetPortForward indicates an expected call of GetPortForward.
    func (mr *MockStreamingRuntimeMockRecorder) GetPortForward(ctx, podName, podNamespace, podUID, ports any) *gomock.Call {
    	mr.mock.ctrl.T.Helper()
    	return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetPortForward", reflect.TypeOf((*MockStreamingRuntime)(nil).GetPortForward), ctx, podName, podNamespace, podUID, ports)
    }
    
    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) GetPortForward(_ context.Context, podName, podNamespace string, podUID types.UID, ports []int32) (*url.URL, error) {
    	f.Lock()
    	defer f.Unlock()
    
    	f.CalledFunctions = append(f.CalledFunctions, "GetPortForward")
    	return &url.URL{Host: FakeHost}, f.Err
    }
    
    type FakeContainerCommandRunner struct {
    	// what to return
    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/kuberuntime/kuberuntime_sandbox.go

    	sort.Sort(podSandboxByCreated(sandboxes))
    	for i, s := range sandboxes {
    		sandboxIDs[i] = s.Id
    	}
    
    	return sandboxIDs, nil
    }
    
    // GetPortForward gets the endpoint the runtime will serve the port-forward request from.
    func (m *kubeGenericRuntimeManager) GetPortForward(ctx context.Context, podName, podNamespace string, podUID kubetypes.UID, ports []int32) (*url.URL, error) {
    	sandboxIDs, err := m.getSandboxIDByPodUID(ctx, podUID, nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. pkg/kubelet/server/server_test.go

    }
    
    func (fk *fakeKubelet) GetPortForward(ctx context.Context, podName, podNamespace string, podUID types.UID, portForwardOpts portforward.V4Options) (*url.URL, error) {
    	if fk.getPortForwardCheck != nil {
    		fk.getPortForwardCheck(podName, podNamespace, podUID, portForwardOpts)
    	}
    	// Always use testPodSandboxID
    	resp, err := fk.streamingRuntime.GetPortForward(&runtimeapi.PortForwardRequest{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.5K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_pods.go

    	return kl.streamingRuntime.GetAttach(ctx, container.ID, streamOpts.Stdin, streamOpts.Stdout, streamOpts.Stderr, tty)
    }
    
    // GetPortForward gets the URL the port-forward will be served from, or nil if the Kubelet will serve it.
    func (kl *Kubelet) GetPortForward(ctx context.Context, podName, podNamespace string, podUID types.UID, portForwardOpts portforward.V4Options) (*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)
  7. pkg/kubelet/container/runtime.go

    	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)
    }
    
    // ImageService interfaces allows to work with image service.
    type ImageService interface {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  8. pkg/kubelet/kubelet_pods_test.go

    		fakeRuntime := &containertest.FakeStreamingRuntime{FakeRuntime: testKubelet.fakeRuntime}
    		kubelet.containerRuntime = fakeRuntime
    		kubelet.streamingRuntime = fakeRuntime
    
    		redirect, err := kubelet.GetPortForward(ctx, tc.podName, podNamespace, podUID, portforward.V4Options{})
    		if tc.expectError {
    			assert.Error(t, err, description)
    		} else {
    			assert.NoError(t, err, description)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
Back to top