go.opentelemetry.io/otel/sdk/metric v1.37.0: MeterProvider

Clean-room public code sample — generation instructions

Write a brand-new, minimal, self-contained code sample in this clean-room directory.
Do not copy, paraphrase, or reference any existing project source. Work only from this spec.

A csx.json manifest scaffold already exists. Do not recreate it from memory. Preserve its case.goal, packages and symbols; fill its empty case.contract with exact assertions and correct its environment, commands and verifierAdapter for the files you generate.

Goal: verify go.opentelemetry.io/otel/sdk/metric.MeterProvider in pkg:golang/go.opentelemetry.io/otel/sdk/metric@v1.37.0
Kind: HOW

Use EXACTLY these public packages and versions:
  - pkg:golang/go.opentelemetry.io/otel/sdk/metric@v1.37.0
Demonstrate these symbols/APIs:
  - go.opentelemetry.io/otel/sdk/metric.MeterProvider

Rules:
  - One focused purpose; the smallest project that proves the goal.
  - Include a contract test (test/contract.*) that runs OFFLINE and exits 0 exactly when the goal behavior works.
  - Pin every dependency with a lockfile so resolution is reproducible.
  - No secrets, credentials, or tokens. No real URLs (only example.com or localhost). No absolute paths.
  - No personal names, emails, company names, or project identifiers of any kind.
  - No binaries and no generated output (node_modules, dist, target, venv, .git, .env).
  - Keep it under 200 files and 256KB packed.

{"case":{"caseId":"case:sha256:3fd0ebefc583ef059441a4b5b0c1d204127c46fc783a26d1cb3a7b51cca7b4a1","contract":["NewMeterProvider returns a configured non-nil MeterProvider implementing metric.MeterProvider","MeterProvider produces functional Meter instances that create metric instruments","Metric instruments record measurements collected via configured Reader","MeterProvider ForceFlush flushes active metric pipelines without error","MeterProvider Shutdown cleanly terminates metric pipelines"],"goal":"verify go.opentelemetry.io/otel/sdk/metric.MeterProvider in pkg:golang/go.opentelemetry.io/otel/sdk/metric@v1.37.0","kind":"HOW","packages":["pkg:golang/go.opentelemetry.io/otel/sdk/metric@v1.37.0"],"schemaVersion":1,"symbols":["go.opentelemetry.io/otel/sdk/metric.MeterProvider"]},"contractCommand":["go","run","./test"],"environment":{"arch":"x64","distro":"ubuntu","ecosystem":"golang","libc":"glibc","libcVersion":"2.39","os":"linux","osVersionBucket":"24","packageManager":"go","schemaVersion":1},"license":"MIT-0","packages":["pkg:golang/go.opentelemetry.io/otel/sdk/metric@v1.37.0"],"schemaVersion":1,"subject":"pkg:golang/go.opentelemetry.io/otel/sdk/metric@v1.37.0","symbols":["go.opentelemetry.io/otel/sdk/metric.MeterProvider"],"verifierAdapter":"golang@1"}

module sample

go 1.26.6

require (
	go.opentelemetry.io/otel/metric v1.37.0
	go.opentelemetry.io/otel/sdk/metric v1.37.0
)

require (
	github.com/go-logr/logr v1.4.3 // indirect
	github.com/go-logr/stdr v1.2.2 // indirect
	github.com/google/uuid v1.6.0 // indirect
	go.opentelemetry.io/auto/sdk v1.1.0 // indirect
	go.opentelemetry.io/otel v1.37.0 // indirect
	go.opentelemetry.io/otel/sdk v1.37.0 // indirect
	go.opentelemetry.io/otel/trace v1.37.0 // indirect
	golang.org/x/sys v0.33.0 // indirect
)

github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
github.com/go-logr/logr v1.4.3 h1:CjnDlHq8ikf6E492q6eKboGOC0T8CDaOvkHCIg8idEI=
github.com/go-logr/logr v1.4.3/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
github.com/google/go-cmp v0.7.0 h1:wk8382ETsv4JYUZwIsn6YpYiWiBsYLSJiTsyBybVuN8=
github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX3N/iU=
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/stretchr/testify v1.10.0 h1:Xv5erBjTwe/5IxqUQTdXv5kgmIvbHo3QQyRwhJsOfJA=
github.com/stretchr/testify v1.10.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
go.opentelemetry.io/auto/sdk v1.1.0 h1:cH53jehLUN6UFLY71z+NDOiNJqDdPRaXzTel0sJySYA=
go.opentelemetry.io/auto/sdk v1.1.0/go.mod h1:3wSPjt5PWp2RhlCcmmOial7AvC4DQqZb7a7wCow3W8A=
go.opentelemetry.io/otel v1.37.0 h1:9zhNfelUvx0KBfu/gb+ZgeAfAgtWrfHJZcAqFC228wQ=
go.opentelemetry.io/otel v1.37.0/go.mod h1:ehE/umFRLnuLa/vSccNq9oS1ErUlkkK71gMcN34UG8I=
go.opentelemetry.io/otel/metric v1.37.0 h1:mvwbQS5m0tbmqML4NqK+e3aDiO02vsf/WgbsdpcPoZE=
go.opentelemetry.io/otel/metric v1.37.0/go.mod h1:04wGrZurHYKOc+RKeye86GwKiTb9FKm1WHtO+4EVr2E=
go.opentelemetry.io/otel/sdk v1.37.0 h1:ItB0QUqnjesGRvNcmAcU0LyvkVyGJ2xftD29bWdDvKI=
go.opentelemetry.io/otel/sdk v1.37.0/go.mod h1:VredYzxUvuo2q3WRcDnKDjbdvmO0sCzOvVAiY+yUkAg=
go.opentelemetry.io/otel/sdk/metric v1.37.0 h1:90lI228XrB9jCMuSdA0673aubgRobVZFhbjxHHspCPc=
go.opentelemetry.io/otel/sdk/metric v1.37.0/go.mod h1:cNen4ZWfiD37l5NhS+Keb5RXVWZWpRE+9WyVCpbo5ps=
go.opentelemetry.io/otel/trace v1.37.0 h1:HLdcFNbRQBE2imdSEgm/kwqmQj1Or1l/7bW6mxVK7z4=
go.opentelemetry.io/otel/trace v1.37.0/go.mod h1:TlgrlQ+PtQO5XFerSPUYG0JSgGyryXewPGyayAWSBS0=
golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

package sample

import (
	"context"

	"go.opentelemetry.io/otel/metric"
	sdkmetric "go.opentelemetry.io/otel/sdk/metric"
	"go.opentelemetry.io/otel/sdk/metric/metricdata"
)

// Pipeline manages metrics collection using an SDK MeterProvider.
type Pipeline struct {
	reader *sdkmetric.ManualReader
	mp     *sdkmetric.MeterProvider
	meter  metric.Meter
}

// NewPipeline creates a Pipeline with a configured MeterProvider and ManualReader.
func NewPipeline() *Pipeline {
	reader := sdkmetric.NewManualReader()
	mp := sdkmetric.NewMeterProvider(sdkmetric.WithReader(reader))
	meter := mp.Meter("sample-pipeline")

	return &Pipeline{
		reader: reader,
		mp:     mp,
		meter:  meter,
	}
}

// MeterProvider returns the underlying SDK MeterProvider.
func (p *Pipeline) MeterProvider() *sdkmetric.MeterProvider {
	return p.mp
}

// Meter returns the Meter created by the MeterProvider.
func (p *Pipeline) Meter() metric.Meter {
	return p.meter
}

// Collect reads collected metrics into rm.
func (p *Pipeline) Collect(ctx context.Context, rm *metricdata.ResourceMetrics) error {
	return p.reader.Collect(ctx, rm)
}

// ForceFlush flushes metrics through the MeterProvider.
func (p *Pipeline) ForceFlush(ctx context.Context) error {
	return p.mp.ForceFlush(ctx)
}

// Shutdown shuts down the MeterProvider.
func (p *Pipeline) Shutdown(ctx context.Context) error {
	return p.mp.Shutdown(ctx)
}

{
  "schemaVersion": 1,
  "goal": "verify go.opentelemetry.io/otel/sdk/metric.MeterProvider in pkg:golang/go.opentelemetry.io/otel/sdk/metric@v1.37.0",
  "kind": "HOW",
  "packages": [
    "pkg:golang/go.opentelemetry.io/otel/sdk/metric@v1.37.0"
  ],
  "symbols": [
    "go.opentelemetry.io/otel/sdk/metric.MeterProvider"
  ]
}

package main

import (
	"context"
	"fmt"
	"os"

	"go.opentelemetry.io/otel/metric"
	sdkmetric "go.opentelemetry.io/otel/sdk/metric"
	"go.opentelemetry.io/otel/sdk/metric/metricdata"

	"sample"
)

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

	// 1. NewMeterProvider returns a configured non-nil MeterProvider instance
	reader := sdkmetric.NewManualReader()
	mp := sdkmetric.NewMeterProvider(sdkmetric.WithReader(reader))
	if mp == nil {
		fmt.Fprintf(os.Stderr, "NewMeterProvider returned nil\n")
		os.Exit(1)
	}

	var iface metric.MeterProvider = mp
	if iface == nil {
		fmt.Fprintf(os.Stderr, "MeterProvider does not satisfy metric.MeterProvider\n")
		os.Exit(1)
	}

	// 2. MeterProvider produces functional Meter instances that create metric instruments
	meter := mp.Meter("contract-meter", metric.WithInstrumentationVersion("1.0.0"))
	if meter == nil {
		fmt.Fprintf(os.Stderr, "Meter() returned nil\n")
		os.Exit(1)
	}

	counter, err := meter.Int64Counter("contract.counter", metric.WithDescription("contract counter"))
	if err != nil || counter == nil {
		fmt.Fprintf(os.Stderr, "Int64Counter failed: %v\n", err)
		os.Exit(1)
	}

	hist, err := meter.Float64Histogram("contract.histogram", metric.WithDescription("contract histogram"))
	if err != nil || hist == nil {
		fmt.Fprintf(os.Stderr, "Float64Histogram failed: %v\n", err)
		os.Exit(1)
	}

	upDown, err := meter.Int64UpDownCounter("contract.updown", metric.WithDescription("contract updown"))
	if err != nil || upDown == nil {
		fmt.Fprintf(os.Stderr, "Int64UpDownCounter failed: %v\n", err)
		os.Exit(1)
	}

	// 3. Instruments record metric data collected via configured Reader
	counter.Add(ctx, 42)
	hist.Record(ctx, 3.14)
	upDown.Add(ctx, 7)

	var rm metricdata.ResourceMetrics
	if err := reader.Collect(ctx, &rm); err != nil {
		fmt.Fprintf(os.Stderr, "reader.Collect failed: %v\n", err)
		os.Exit(1)
	}

	if len(rm.ScopeMetrics) == 0 {
		fmt.Fprintf(os.Stderr, "expected ScopeMetrics, got none\n")
		os.Exit(1)
	}

	foundMetrics := 0
	for _, sm := range rm.ScopeMetrics {
		foundMetrics += len(sm.Metrics)
	}
	if foundMetrics == 0 {
		fmt.Fprintf(os.Stderr, "expected recorded metrics, got none\n")
		os.Exit(1)
	}

	// 4. MeterProvider ForceFlush flushes active metric pipelines without error
	if err := mp.ForceFlush(ctx); err != nil {
		fmt.Fprintf(os.Stderr, "mp.ForceFlush failed: %v\n", err)
		os.Exit(1)
	}

	// 5. MeterProvider Shutdown cleanly terminates metric pipelines
	if err := mp.Shutdown(ctx); err != nil {
		fmt.Fprintf(os.Stderr, "mp.Shutdown failed: %v\n", err)
		os.Exit(1)
	}

	// 6. Integrates with sample package pipeline
	pipeline := sample.NewPipeline()
	if pipeline == nil || pipeline.MeterProvider() == nil {
		fmt.Fprintf(os.Stderr, "sample.NewPipeline failed\n")
		os.Exit(1)
	}

	pMeter := pipeline.Meter()
	pCounter, err := pMeter.Int64Counter("sample.counter")
	if err != nil {
		fmt.Fprintf(os.Stderr, "pipeline Int64Counter failed: %v\n", err)
		os.Exit(1)
	}
	pCounter.Add(ctx, 1)

	var prm metricdata.ResourceMetrics
	if err := pipeline.Collect(ctx, &prm); err != nil {
		fmt.Fprintf(os.Stderr, "pipeline.Collect failed: %v\n", err)
		os.Exit(1)
	}

	if err := pipeline.ForceFlush(ctx); err != nil {
		fmt.Fprintf(os.Stderr, "pipeline.ForceFlush failed: %v\n", err)
		os.Exit(1)
	}

	if err := pipeline.Shutdown(ctx); err != nil {
		fmt.Fprintf(os.Stderr, "pipeline.Shutdown failed: %v\n", err)
		os.Exit(1)
	}

	fmt.Println("All go.opentelemetry.io/otel/sdk/metric.MeterProvider contract assertions passed.")
}