- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newExecInContainer (0.16 sec)
-
pkg/kubelet/prober/prober.go
command := kubecontainer.ExpandContainerCommandOnlyStatic(p.Exec.Command, container.Env) return pb.exec.Probe(pb.newExecInContainer(ctx, container, containerID, command, timeout)) case p.HTTPGet != nil: req, err := httpprobe.NewRequestForHTTPGetAction(p.HTTPGet, &container, status.PodIP, "probe") if err != nil {
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/prober/prober_test.go
prober := &prober{ runner: runner, } container := v1.Container{} containerID := kubecontainer.ContainerID{Type: "docker", ID: "containerID"} cmd := []string{"/foo", "bar"} exec := prober.newExecInContainer(ctx, container, containerID, cmd, 0) var dataBuffer bytes.Buffer writer := ioutils.LimitWriter(&dataBuffer, int64(limit)) exec.SetStderr(writer) exec.SetStdout(writer) err := exec.Start()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 01 07:17:35 UTC 2023 - 9.7K bytes - Viewed (0)