Function sendPing

cmd/root.go:128–263

(endpoint string, uniqueIdentifier string, message string, series string, timestamp float64, duration *float64, exitCode *int, metrics map[string]int, schedule string, group *sync.WaitGroup)

}

func sendPing(endpoint string, uniqueIdentifier string, message string, series string, timestamp float64, duration *float64, exitCode *int, metrics map[string]int, schedule string, group *sync.WaitGroup) {
	if group != nil {
		defer group.Done()
	}

	Client := &http.Client{
		Timeout: time.Second * 10,
	}

	hostname := effectiveHostname()
	pingApiAuthKey := viper.GetString(varPingApiKey)
	apiKey := viper.GetString(varApiKey)
	env := viper.GetString(varEnv)
	pingApiHost := ""
	authenticationKey := ""
	formattedStamp := ""
	formattedDuration := ""
	formattedStatusCode := ""
	formattedMetrics := ""
	formattedSchedule := ""

	if timestamp > 0 {
		formattedStamp = fmt.Sprintf("&stamp=%s", formatStamp(timestamp))
	}

	if len(message) > 0 {
		message = fmt.Sprintf("&msg=%s", url.QueryEscape(truncateString(message, 1000)))
	}

	if len(hostname) > 0 {
		hostname = fmt.Sprintf("&host=%s", url.QueryEscape(truncateString(hostname, 50)))
	}

	if len(env) > 0 {
		env = fmt.Sprintf("&env=%s", url.QueryEscape(truncateString(env, 50)))
	}

	// By passing duration up, we save the computation on the server side
	if duration != nil {
		formattedDuration = fmt.Sprintf("&duration=%s", formatStamp(*duration))
	}

	if schedule != "" {
		formattedSchedule = fmt.Sprintf("&schedule=%s", schedule)
	}

	// We aren't using exit code at time of writing, but we have the field available for healthcheck monitors.
	if exitCode != nil {
		formattedStatusCode = fmt.Sprintf("&status_code=%d", *exitCode)
	}

	// The `series` data is used to match run events with complete or fail. Useful if multiple instances of a job are running.
	if len(series) > 0 {
		series = fmt.Sprintf("&series=%s", series)
	}

	if metrics != nil && len(metrics) > 0 {
		values := url.Values{}