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