feat: add provider_init_rate to telemetry

On the first telemetry flush after provider initialization, include
a ProviderInitRate entry with labels describing the SDK configuration
(e.g. encryption: true/false). This lets the backend track which
customers have adopted encryption without tagging every metric.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: nicklasl

confidence-resolver/protos/confidence/flags/resolver/v1/internal_api.proto

@@ -112,6 +112,8 @@ message WriteFlagAssignedResponse {
 // consumers everything needed to reconstruct bucket boundaries and resample
 // between different histogram configurations if needed.
 message TelemetryData {
+  reserved 1; // was: int64 dropped_events
+
   // Information about the SDK/provider
   Sdk sdk = 2 [
     (google.api.field_behavior) = OPTIONAL
@@ -128,6 +130,14 @@ message TelemetryData {
   // Set from the confidence-resolver crate version at build time.
   string resolver_version = 8;
 
+  repeated ProviderInitRate provider_init_rate = 9;
+
+  message ProviderInitRate {
+    uint32 count = 1;
+    reserved 2; // status — tbd
+    map<string, string> labels = 3;
+  }
+
   message ResolveLatency {
     // Delta sum of observed values since the last flush.
     uint32 sum = 1;

confidence-resolver/src/telemetry.rs

@@ -498,6 +498,7 @@ impl Telemetry {
             state_age,
             memory_bytes: (self.memory_provider)(),
             resolver_version: crate::version::VERSION.to_string(),
+            provider_init_rate: Vec::new(),
         }
     }
 }

openfeature-provider/go/confidence/internal/local_resolver/assets/confidence_resolver.wasm

@@ -44,7 +44,16 @@ type localResolverImpl struct {
 }
 
 func NewLocalResolverWithPoolSize(ctx context.Context, logSink LogSink, poolSize int) LocalResolver {
-	factory := NewWasmResolverFactory(logSink)
+	return NewLocalResolverWithLabels(ctx, logSink, poolSize, nil)
+}
+
+func NewLocalResolverWithLabels(ctx context.Context, logSink LogSink, poolSize int, initLabels map[string]string) LocalResolver {
+	var factory LocalResolverFactory
+	if len(initLabels) > 0 {
+		factory = NewWasmResolverFactoryWithLabels(logSink, initLabels)
+	} else {
+		factory = NewWasmResolverFactory(logSink)
+	}
 	factory = NewRecoveringResolverFactory(factory)
 	if poolSize <= 0 {
 		poolSize = DefaultPoolSize

openfeature-provider/go/confidence/internal/local_resolver/local_resolver.go

@@ -42,6 +42,8 @@ type WasmResolver struct {
 	mu         *sync.Mutex
 	instanceID string
 	fnCache    sync.Map
+	initLabels map[string]string
+	firstFlush bool
 }
 
 var _ LocalResolver = (*WasmResolver)(nil)
@@ -85,6 +87,16 @@ func (r *WasmResolver) ApplyFlags(request *resolver.ApplyFlagsRequest) error {
 func (r *WasmResolver) FlushAllLogs() error {
 	resp := &resolverv1.WriteFlagLogsRequest{}
 	err := r.call("wasm_msg_guest_bounded_flush_logs", nil, resp)
+	if err == nil && r.firstFlush {
+		r.firstFlush = false
+		if resp.TelemetryData == nil {
+			resp.TelemetryData = &resolverv1.TelemetryData{}
+		}
+		resp.TelemetryData.ProviderInitRate = append(
+			resp.TelemetryData.ProviderInitRate,
+			&resolverv1.TelemetryData_ProviderInitRate{Count: 1, Labels: r.initLabels},
+		)
+	}
 	if err == nil && proto.Size(resp) > 0 {
 		r.logSink(resp)
 	}
@@ -154,9 +166,10 @@ func (r *WasmResolver) call(fnName string, request proto.Message, response proto
 }
 
 type WasmResolverFactory struct {
-	runtime wazero.Runtime
-	module  wazero.CompiledModule
-	logSink LogSink
+	runtime    wazero.Runtime
+	module     wazero.CompiledModule
+	logSink    LogSink
+	initLabels map[string]string
 }
 
 var _ LocalResolverFactory = (*WasmResolverFactory)(nil)
@@ -208,6 +221,12 @@ func NewWasmResolverFactory(logSink LogSink) LocalResolverFactory {
 	}
 }
 
+func NewWasmResolverFactoryWithLabels(logSink LogSink, initLabels map[string]string) LocalResolverFactory {
+	factory := NewWasmResolverFactory(logSink).(*WasmResolverFactory)
+	factory.initLabels = initLabels
+	return factory
+}
+
 func (wrf *WasmResolverFactory) New() LocalResolver {
 	ctx := context.Background()
 	config := wazero.NewModuleConfig().WithName("")
@@ -221,6 +240,8 @@ func (wrf *WasmResolverFactory) New() LocalResolver {
 		logSink:    wrf.logSink,
 		mu:         &sync.Mutex{},
 		instanceID: fmt.Sprintf("%d", id),
+		initLabels: wrf.initLabels,
+		firstFlush: true,
 	}
 }