INNER CODE UNIT · Go

urls

SeldonIO/seldon-core · hodometer/cmd/hodometer/main.go:66

	urls := []*url.URL{args.publishUrl}
	urls = append(urls, args.extraPublishUrls...)
	jp, err := hodometer.NewJsonPublisher(logger, urls)
	if err != nil {
		logger.WithError(err).Fatal()
	}

	punctuator.Run(
		"collect metrics and publish",
		func() {
			ctx := context.Background()
			metrics := scc.Collect(ctx, args.metricsLevel)
			_ = jp.Publish(ctx, metrics)
		},
	)
}

View source record →