Function sendTEventsBatch

pkg/wcloud/wcloud.go:150–180

returns (done, num-sent, error)

(clientId string)

// returns (done, num-sent, error)
func sendTEventsBatch(clientId string) (bool, int, error) {
	ctx, cancelFn := context.WithTimeout(context.Background(), WCloudDefaultTimeout)
	defer cancelFn()
	events, err := telemetry.GetNonUploadedTEvents(ctx, TEventsBatchSize)
	if err != nil {
		return true, 0, fmt.Errorf("cannot get events: %v", err)
	}
	if len(events) == 0 {
		return true, 0, nil
	}
	input := TEventsInputType{
		ClientId: clientId,
		Events:   events,
	}
	req, err := makeAnonPostReq(ctx, TEventsUrl, input)
	if err != nil {
		return true, 0, err
	}
	startTime := time.Now()
	_, err = doRequest(req, nil, true)
	latency := time.Since(startTime)
	log.Printf("[wcloud] sent %d tevents (latency: %v)\n", len(events), latency)
	if err != nil {
		return true, 0, err
	}
	err = telemetry.MarkTEventsAsUploaded(ctx, events)
	if err != nil {
		return true, 0, fmt.Errorf("error marking activity as uploaded: %v", err)
	}
	return len(events) < TEventsBatchSize, len(events), nil
}

func sendTEvents(clientId string) (int, error) {
	numIters := 0