Method Start

pkg/app/master/inspectors/probes/http/custom_probe.go:239–589

Start starts the HTTP probe instance execution

()

// Start starts the HTTP probe instance execution
func (p *CustomProbe) Start() {
	if p.printState {
		p.xc.Out.State("http.probe.starting",
			ovars{
				"message": "WAIT FOR HTTP PROBE TO FINISH",
			})
	}

	go func() {
		//TODO: need to do a better job figuring out if the target app is ready to accept connections
		time.Sleep(9 * time.Second) //base start wait time
		if p.opts.StartWait > 0 {
			if p.printState {
				p.xc.Out.State("http.probe.start.wait", ovars{"time": p.opts.StartWait})
			}

			//additional wait time
			time.Sleep(time.Duration(p.opts.StartWait) * time.Second)

			if p.printState {
				p.xc.Out.State("http.probe.start.wait.done")
			}
		}

		if p.printState {
			p.xc.Out.State("http.probe.running")
		}

		log.Info("HTTP probe started...")

		findIdx := func(ports []string, target string) int {
			for idx, val := range ports {
				if val == target {
					return idx
				}
			}
			return -1
		}

		httpIdx := findIdx(p.ports, defaultHTTPPortStr)
		httpsIdx := findIdx(p.ports, defaultHTTPSPortStr)
		if httpIdx != -1 && httpsIdx != -1 && httpsIdx < httpIdx {
			//want to probe http first
			log.Debugf("http.probe - swapping http and https ports (http=%v <-> https=%v)",
				httpIdx, httpsIdx)

			p.ports[httpIdx], p.ports[httpsIdx] = p.ports[httpsIdx], p.ports[httpIdx]
		}

		if p.printState {
			p.xc.Out.Info("http.probe.ports",
				ovars{
					"count":   len(p.ports),
					"targets": strings.Join(p.ports, ","),
				})

			var cmdListPreview []string
			var cmdListTail string