Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for RunInContainer (0.2 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/kubelet/kubelet_pods_test.go

    	fakeRuntime := testKubelet.fakeRuntime
    	fakeRuntime.PodList = []*containertest.FakePod{}
    
    	podName := "podFoo"
    	podNamespace := "nsFoo"
    	containerName := "containerFoo"
    	output, err := kubelet.RunInContainer(
    		ctx,
    		kubecontainer.GetPodFullName(&v1.Pod{ObjectMeta: metav1.ObjectMeta{Name: podName, Namespace: podNamespace}}),
    		"",
    		containerName,
    		[]string{"ls"})
    	assert.Error(t, err)
    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