- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for getPortForward (0.76 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)