add support for periodic reader interval/timeout (#8096)

This adds support for configuring `timeout` and `interval` options for
the periodic metric exporter.

Linked issue: #7641

Signed-off-by: Alex Boten <aboten@lightstep.com>

.chloggen/codeboten_add-periodic-internal-timeout.yaml

@@ -0,0 +1,16 @@
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. otlpreceiver)
+component: service
+
+# A brief description of the change.  Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: "Add support for `interval` and `timeout` configuration in periodic reader"
+
+# One or more tracking issues or pull requests related to the change
+issues: [7641]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:

service/internal/proctelemetry/config.go

@@ -10,6 +10,7 @@ import (
 	"fmt"
 	"net/http"
 	"os"
+	"time"
 
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
@@ -56,7 +57,15 @@ func InitMetricReader(ctx context.Context, reader telemetry.MetricReader, asyncE
 		return initPullExporter(reader.Pull.Exporter, asyncErrorChannel)
 	}
 	if reader.Periodic != nil {
-		return initPeriodicExporter(ctx, reader.Periodic.Exporter)
+		opts := []sdkmetric.PeriodicReaderOption{}
+		if reader.Periodic.Interval != nil {
+			opts = append(opts, sdkmetric.WithInterval(time.Duration(*reader.Periodic.Interval)*time.Millisecond))
+		}
+
+		if reader.Periodic.Timeout != nil {
+			opts = append(opts, sdkmetric.WithTimeout(time.Duration(*reader.Periodic.Timeout)*time.Millisecond))
+		}
+		return initPeriodicExporter(ctx, reader.Periodic.Exporter, opts...)
 	}
 	return nil, nil, fmt.Errorf("unsupported metric reader type %v", reader)
 }
@@ -160,7 +169,7 @@ func initPullExporter(exporter telemetry.MetricExporter, asyncErrorChannel chan
 	}
 	return nil, nil, fmt.Errorf("no valid exporter")
 }
-func initPeriodicExporter(_ context.Context, exporter telemetry.MetricExporter) (sdkmetric.Reader, *http.Server, error) {
+func initPeriodicExporter(_ context.Context, exporter telemetry.MetricExporter, opts ...sdkmetric.PeriodicReaderOption) (sdkmetric.Reader, *http.Server, error) {
 	if exporter.Console != nil {
 		enc := json.NewEncoder(os.Stdout)
 		enc.SetIndent("", "  ")
@@ -171,7 +180,7 @@ func initPeriodicExporter(_ context.Context, exporter telemetry.MetricExporter)
 		if err != nil {
 			return nil, nil, err
 		}
-		return sdkmetric.NewPeriodicReader(exp), nil, nil
+		return sdkmetric.NewPeriodicReader(exp, opts...), nil, nil
 	}
 	return nil, nil, fmt.Errorf("no valid exporter")
 }

service/internal/proctelemetry/config_test.go

@@ -111,6 +111,18 @@ func TestMetricReader(t *testing.T) {
 				},
 			},
 		},
+		{
+			name: "periodic/console-exporter-with-timeout-interval",
+			reader: telemetry.MetricReader{
+				Periodic: &telemetry.PeriodicMetricReader{
+					Interval: intPtr(10),
+					Timeout:  intPtr(5),
+					Exporter: telemetry.MetricExporter{
+						Console: telemetry.Console{},
+					},
+				},
+			},
+		},
 	}
 	for _, tt := range testCases {
 		t.Run(tt.name, func(t *testing.T) {