- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for RunInContainer (0.61 sec)
-
pkg/kubelet/container/testing/runtime_mock.go
// RunInContainer indicates an expected call of RunInContainer. func (mr *MockCommandRunnerMockRecorder) RunInContainer(ctx, id, cmd, timeout any) *gomock.Call { mr.mock.ctrl.T.Helper() return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "RunInContainer", reflect.TypeOf((*MockCommandRunner)(nil).RunInContainer), ctx, id, cmd, timeout)
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/lifecycle/handlers.go
switch { case handler.Exec != nil: var msg string // TODO(tallclair): Pass a proper timeout value. output, err := hr.commandRunner.RunInContainer(ctx, containerID, handler.Exec.Command, 0) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 19 11:40:52 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/kubelet/prober/prober.go
return &execInContainer{run: func() ([]byte, error) { return pb.runner.RunInContainer(ctx, containerID, cmd, timeout) }} } func (eic *execInContainer) Run() error { return nil } func (eic *execInContainer) CombinedOutput() ([]byte, error) { return eic.run() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 16 10:50:13 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/kubelet/container/runtime.go
} // CommandRunner interface allows to run command in a container. type CommandRunner interface { // RunInContainer synchronously executes the command in the container, and returns the output. // If the command completes with a non-0 exit code, a k8s.io/utils/exec.ExitError will be returned. RunInContainer(ctx context.Context, id ContainerID, cmd []string, timeout time.Duration) ([]byte, 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/container/testing/fake_runtime.go
// actual values when invoked ContainerID kubecontainer.ContainerID Cmd []string } var _ kubecontainer.CommandRunner = &FakeContainerCommandRunner{} func (f *FakeContainerCommandRunner) RunInContainer(_ context.Context, containerID kubecontainer.ContainerID, cmd []string, timeout time.Duration) ([]byte, error) { // record invoked values f.ContainerID = containerID f.Cmd = cmd return []byte(f.Stdout), 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.go
type HostInterface interface { stats.Provider GetVersionInfo() (*cadvisorapi.VersionInfo, error) GetCachedMachineInfo() (*cadvisorapi.MachineInfo, error) GetRunningPods(ctx context.Context) ([]*v1.Pod, error) RunInContainer(ctx context.Context, name string, uid types.UID, container string, cmd []string) ([]byte, error)
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/lifecycle/handlers_test.go
} } } type fakeContainerCommandRunner struct { Cmd []string ID kubecontainer.ContainerID Err error Msg string } func (f *fakeContainerCommandRunner) RunInContainer(_ context.Context, id kubecontainer.ContainerID, cmd []string, timeout time.Duration) ([]byte, error) { f.Cmd = cmd f.ID = id return []byte(f.Msg), f.Err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 24.4K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_container.go
} resp, err := m.runtimeService.Attach(ctx, req) if err != nil { return nil, err } return url.Parse(resp.Url) } // RunInContainer synchronously executes the command in the container, and returns the output. func (m *kubeGenericRuntimeManager) RunInContainer(ctx context.Context, id kubecontainer.ContainerID, cmd []string, timeout time.Duration) ([]byte, error) {
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/kubelet_pods.go
pod := kubecontainer.Pods(pods).FindPod(podFullName, podUID) return pod.FindContainerByName(containerName), nil } // RunInContainer runs a command in a container, returns the combined stdout, stderr as an array of bytes func (kl *Kubelet) RunInContainer(ctx context.Context, podFullName string, podUID types.UID, containerName string, cmd []string) ([]byte, 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/server/server_test.go
return fk.containerLogsFunc(ctx, podFullName, containerName, logOptions, stdout, stderr) } func (fk *fakeKubelet) GetHostname() string { return fk.hostnameFunc() } func (fk *fakeKubelet) RunInContainer(_ context.Context, podFullName string, uid types.UID, containerName string, cmd []string) ([]byte, error) { return fk.runFunc(podFullName, uid, containerName, cmd) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0)