kubernetes/pkg/kubelet/prober/prober.go

const maxProbeRetries …

type prober …

// NewProber creates a Prober, it takes a command runner and
// several container info managers.
func newProber(
	runner kubecontainer.CommandRunner,
	recorder record.EventRecorder) *prober { … }

// recordContainerEvent should be used by the prober for all container related events.
func (pb *prober) recordContainerEvent(pod *v1.Pod, container *v1.Container, eventType, reason, message string, args ...interface{ … }

// probe probes the container.
func (pb *prober) probe(ctx context.Context, probeType probeType, pod *v1.Pod, status v1.PodStatus, container v1.Container, containerID kubecontainer.ContainerID) (results.Result, error) { … }

// runProbeWithRetries tries to probe the container in a finite loop, it returns the last result
// if it never succeeds.
func (pb *prober) runProbeWithRetries(ctx context.Context, probeType probeType, p *v1.Probe, pod *v1.Pod, status v1.PodStatus, container v1.Container, containerID kubecontainer.ContainerID, retries int) (probe.Result, string, error) { … }

func (pb *prober) runProbe(ctx context.Context, probeType probeType, p *v1.Probe, pod *v1.Pod, status v1.PodStatus, container v1.Container, containerID kubecontainer.ContainerID) (probe.Result, string, error) { … }

type execInContainer …

func (pb *prober) newExecInContainer(ctx context.Context, container v1.Container, containerID kubecontainer.ContainerID, cmd []string, timeout time.Duration) exec.Cmd { … }

func (eic *execInContainer) Run() error { … }

func (eic *execInContainer) CombinedOutput() ([]byte, error) { … }

func (eic *execInContainer) Output() ([]byte, error) { … }

func (eic *execInContainer) SetDir(dir string) { … }

func (eic *execInContainer) SetStdin(in io.Reader) { … }

func (eic *execInContainer) SetStdout(out io.Writer) { … }

func (eic *execInContainer) SetStderr(out io.Writer) { … }

func (eic *execInContainer) SetEnv(env []string) { … }

func (eic *execInContainer) Stop() { … }

func (eic *execInContainer) Start() error { … }

func (eic *execInContainer) Wait() error { … }

func (eic *execInContainer) StdoutPipe() (io.ReadCloser, error) { … }

func (eic *execInContainer) StderrPipe() (io.ReadCloser, error) { … }