Function SendLogData

lib/cronitor.go:415–454

(apiKey string, monitorKey string, seriesID string, outputLogs string)

}

func SendLogData(apiKey string, monitorKey string, seriesID string, outputLogs string) ([]byte, error) {
	gzippedLogs := gzipLogData(outputLogs)
	jsonBytes, err := json.Marshal(map[string]string{
		"job_key": monitorKey,
		"series":  seriesID,
	})
	if err != nil {
		return nil, errors.Wrap(err, "couldn't encode job and series IDs to JSON")
	}

	var responseJson struct {
		Url string `json:"url"`
	}
	response, err := getPresignedUrl(apiKey, jsonBytes)
	if err != nil {
		return nil, errors.Wrap(err, "error generating presign url for log uploading")
	}
	if err := json.Unmarshal(response, &responseJson); err != nil {
		return nil, err
	}

	s3LogPutUrl := responseJson.Url
	if len(s3LogPutUrl) == 0 {
		return nil, errors.New("no presigned S3 url returned. Something is wrong")
	}
	req, err := http.NewRequest("PUT", s3LogPutUrl, gzippedLogs)
	if err != nil {
		return nil, err
	}
	client := &http.Client{
		Timeout: 120 * time.Second,
	}
	resp, err := client.Do(req)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	return ioutil.ReadAll(resp.Body)
}

func (api CronitorApi) Signup(name string, email string, password string) (*SignupResponse, error) {
	payload := fmt.Sprintf("fullname=%s&email=%s&password=%s",