func main()

in container_images/concourse-metrics/cmd/publish-job-result/main.go [40:73]


func main() {
	ctx := context.Background()

	flag.Parse()

	c, err := monitoring.NewMetricClient(ctx)
	if err != nil {
		fmt.Printf("Error creating a new Cloud Monitoring metric client: %+v.\n", err)
		os.Exit(1)
	}
	defer c.Close()

	req, err := requests.BuildJobResultRequest(requests.JobResultArgs{
		EndTimestamp:   endTimestamp,
		Job:            *job,
		MetricPath:     *metricPath,
		Pipeline:       *pipeline,
		ProjectID:      *projectID,
		ResultState:    *resultState,
		StartTimestamp: *startTimestamp,
		Task:           *task,
		Zone:           *zone,
	})
	if err != nil {
		fmt.Printf("Error creating request: %+v.\n", err)
		os.Exit(1)
	}

	err = c.CreateTimeSeries(ctx, req)
	if err != nil {
		fmt.Printf("Failed to write time series data: %+v.\n", err)
		os.Exit(1)
	}
}