Function GetProbeSpec

pkg/workloads/helpers.go:34–76

(probe *userconfig.Probe)

}

func GetProbeSpec(probe *userconfig.Probe) *kcore.Probe {
	if probe == nil {
		return nil
	}

	var httpGetAction *kcore.HTTPGetAction
	var tcpSocketAction *kcore.TCPSocketAction
	var execAction *kcore.ExecAction

	if probe.HTTPGet != nil {
		httpGetAction = &kcore.HTTPGetAction{
			Path: probe.HTTPGet.Path,
			Port: intstr.IntOrString{
				IntVal: probe.HTTPGet.Port,
			},
		}
	}
	if probe.TCPSocket != nil {
		tcpSocketAction = &kcore.TCPSocketAction{
			Port: intstr.IntOrString{
				IntVal: probe.TCPSocket.Port,
			},
		}
	}
	if probe.Exec != nil {
		execAction = &kcore.ExecAction{
			Command: probe.Exec.Command,
		}
	}

	return &kcore.Probe{
		Handler: kcore.Handler{
			HTTPGet:   httpGetAction,
			TCPSocket: tcpSocketAction,
			Exec:      execAction,
		},
		InitialDelaySeconds: probe.InitialDelaySeconds,
		TimeoutSeconds:      probe.TimeoutSeconds,
		PeriodSeconds:       probe.PeriodSeconds,
		SuccessThreshold:    probe.SuccessThreshold,
		FailureThreshold:    probe.FailureThreshold,
	}
}

func GetLifecycleSpec(preStop *userconfig.PreStop) *kcore.Lifecycle {
	if preStop == nil {