Method StartProbing

pkg/probe/probe.go:84–122

()

}

func (p *Probe) StartProbing() chan struct{} {
	stop := make(chan struct{})

	time.AfterFunc(time.Duration(p.InitialDelaySeconds)*time.Second, func() {
		ticker := time.NewTicker(time.Duration(p.PeriodSeconds) * time.Second)

		successCount := int32(0)
		failureCount := int32(0)

		for {
			select {
			case <-stop:
				return
			case <-ticker.C:
				healthy := p.probeContainer()
				if healthy {
					successCount++
					failureCount = 0
				} else {
					failureCount++
					successCount = 0
				}

				p.Lock()

				if successCount >= p.SuccessThreshold {
					p.healthy = true
				} else if failureCount >= p.FailureThreshold {
					p.healthy = false
				}
				p.hasRunOnce = true

				p.Unlock()
			}
		}
	})

	return stop
}

func (p *Probe) IsHealthy() bool {
	p.RLock()