prober

Documentation

Index

• type ContainerCommandRunner
• type FakeProber
  • func (fp *FakeProber) Probe(pod *api.Pod, status api.PodStatus, container api.Container, ...) (probe.Result, error)
• type Prober
  • func New(runner ContainerCommandRunner, ...) Prober
  • func NewTestProber(exec execprobe.ExecProber, readinessManager *kubecontainer.ReadinessManager, ...) Prober

Types

type ContainerCommandRunner

type ContainerCommandRunner interface {
	RunInContainer(containerID string, cmd []string) ([]byte, error)
	ExecInContainer(containerID string, cmd []string, in io.Reader, out, err io.WriteCloser, tty bool) error
	PortForward(pod *kubecontainer.Pod, port uint16, stream io.ReadWriteCloser) error
}

type FakeProber

type FakeProber struct {
}

func (*FakeProber) Probe

func (fp *FakeProber) Probe(pod *api.Pod, status api.PodStatus, container api.Container, containerID string, createdAt int64) (probe.Result, error)

type Prober

type Prober interface {
	Probe(pod *api.Pod, status api.PodStatus, container api.Container, containerID string, createdAt int64) (probe.Result, error)
}

Prober checks the healthiness of a container.

func New

func New(
	runner ContainerCommandRunner,
	readinessManager *kubecontainer.ReadinessManager,
	refManager *kubecontainer.RefManager,
	recorder record.EventRecorder) Prober

NewProber creates a Prober, it takes a command runner and several container info managers.

func NewTestProber

func NewTestProber(
	exec execprobe.ExecProber,
	readinessManager *kubecontainer.ReadinessManager,
	refManager *kubecontainer.RefManager,
	recorder record.EventRecorder) Prober

New prober for use in tests.