Update example tests

Author: MrAlias

processors/minsev/example_test.go

@@ -5,36 +5,28 @@ package minsev_test
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
 	"os"
-	"strings"
-	"sync"
 
 	"go.opentelemetry.io/otel/log"
 	logsdk "go.opentelemetry.io/otel/sdk/log"
 
 	"go.opentelemetry.io/contrib/processors/minsev"
 )
 
-const key = "OTEL_LOG_LEVEL"
-
-var getSeverity = sync.OnceValue(func() log.Severity {
-	conv := map[string]log.Severity{
-		"":      log.SeverityInfo, // Default to SeverityInfo for unset.
-		"debug": log.SeverityDebug,
-		"info":  log.SeverityInfo,
-		"warn":  log.SeverityWarn,
-		"error": log.SeverityError,
-	}
-	// log.SeverityUndefined for unknown values.
-	return conv[strings.ToLower(os.Getenv(key))]
-})
-
-type EnvSeverity struct{}
+type EnvSeverity struct {
+	Var string
+}
 
-func (EnvSeverity) Severity() log.Severity { return getSeverity() }
+func (s EnvSeverity) Severity() log.Severity {
+	var sev minsev.Severity
+	_ = sev.UnmarshalText([]byte(os.Getenv(s.Var)))
+	return sev.Severity() // Default to SeverityInfo if not set or error.
+}
 
-func ExampleSeveritier() {
+func ExampleSeveritier_environment() {
+	const key = "LOG_LEVEL"
 	// Mock an environmental variable setup that would be done externally.
 	_ = os.Setenv(key, "error")
 
@@ -43,7 +35,7 @@ func ExampleSeveritier() {
 
 	// Wrap the processor so that it filters by severity level defined
 	// via environmental variable.
-	processor = minsev.NewLogProcessor(processor, EnvSeverity{})
+	processor = minsev.NewLogProcessor(processor, EnvSeverity{key})
 	lp := logsdk.NewLoggerProvider(
 		logsdk.WithProcessor(processor),
 	)
@@ -62,3 +54,42 @@ func ExampleSeveritier() {
 	// false
 	// true
 }
+
+func ExampleSeveritier_json() {
+	// Demonstrates how to use a Severitier that reads from a JSON
+	// configuration.
+
+	// Example JSON configuration that specifies the minimum severity level.
+	// This would be provided by the application user.
+	const jsonConfig = `{"log_level":"error"}`
+
+	var config struct {
+		Severity minsev.Severity `json:"log_level"`
+	}
+	if err := json.Unmarshal([]byte(jsonConfig), &config); err != nil {
+		panic(err)
+	}
+
+	// Existing processor that emits telemetry.
+	var processor logsdk.Processor = logsdk.NewBatchProcessor(nil)
+
+	// Wrap the processor so that it filters by severity level defined
+	// in the JSON configuration. Note that the severity level itself is a
+	// Severitier implementation.
+	processor = minsev.NewLogProcessor(processor, config.Severity)
+	lp := logsdk.NewLoggerProvider(logsdk.WithProcessor(processor))
+
+	// Show that Logs API respects the minimum severity level processor.
+	l := lp.Logger("ExampleSeveritier")
+
+	ctx := context.Background()
+	params := log.EnabledParameters{Severity: log.SeverityDebug}
+	fmt.Println(l.Enabled(ctx, params))
+
+	params.Severity = log.SeverityError
+	fmt.Println(l.Enabled(ctx, params))
+
+	// Output:
+	// false
+	// true
+}