Add telemetry endpoint and serve if defined

For customers who have an agreement to disable telemetry,
they can "GET" the data and send it in another way.

Signed-off-by: Alex Ellis (OpenFaaS Ltd) <[email protected]>

serve.go

@@ -54,6 +54,10 @@ func Serve(ctx context.Context, handlers *types.FaaSHandlers, config *types.FaaS
 		handlers.Info = auth.DecorateWithBasicAuth(handlers.Info, credentials)
 		handlers.Secrets = auth.DecorateWithBasicAuth(handlers.Secrets, credentials)
 		handlers.Logs = auth.DecorateWithBasicAuth(handlers.Logs, credentials)
+
+		if handlers.Telemetry != nil {
+			handlers.Telemetry = auth.DecorateWithBasicAuth(handlers.Telemetry, credentials)
+		}
 	}
 
 	hm := newHttpMetrics()
@@ -102,6 +106,10 @@ func Serve(ctx context.Context, handlers *types.FaaSHandlers, config *types.FaaS
 		r.HandleFunc("/healthz", handlers.Health).Methods(http.MethodGet)
 	}
 
+	if handlers.Telemetry != nil {
+		r.HandleFunc("/system/telemetry", hm.InstrumentHandler(handlers.Telemetry, "")).Methods(http.MethodGet)
+	}
+
 	r.HandleFunc("/metrics", promhttp.Handler().ServeHTTP)
 
 	readTimeout := config.ReadTimeout

types/config.go

@@ -48,6 +48,8 @@ type FaaSHandlers struct {
 	Health http.HandlerFunc
 
 	Info http.HandlerFunc
+
+	Telemetry http.HandlerFunc
 }
 
 // FaaSConfig set config for HTTP handlers

types/function_deployment.go

@@ -48,4 +48,8 @@ type FunctionDeployment struct {
 type FunctionResources struct {
 	Memory string `json:"memory,omitempty"`
 	CPU    string `json:"cpu,omitempty"`
+
+	NvidiaGPU string `json:"nvidia.com/gpu,omitempty"`
+	AmdGPU    string `json:"amd.com/gpu,omitempty"`
+	IntelGPU  string `json:"intel.com/gpu,omitempty"`
 }