Method PushV2

integration/e2ecortex/client.go:201–207

PushV2 the input timeseries to the remote endpoint

(symbols []string, timeseries []writev2.TimeSeries)

// PushV2 the input timeseries to the remote endpoint
func (c *Client) PushV2(symbols []string, timeseries []writev2.TimeSeries) (remoteapi.WriteResponseStats, error) {
	// Create write request
	ctx, cancel := context.WithTimeout(context.Background(), c.timeout)
	defer cancel()

	return c.remoteWriteAPI.Write(ctx, remoteapi.WriteV2MessageType, &writev2.Request{Symbols: symbols, Timeseries: timeseries})
}

func getNameAndAttributes(ts prompb.TimeSeries) (string, map[string]any) {
	var metricName string