Liudmila Molkova lmolkova

Note: New APIs are still work in progress and need polishing

Usage

// 1. Implement a ConfigurationSource
// 2. Build client-specific Configuration

SDKs expose IAzureClientBuilder<EventHubProducerClient, EventHubProducerClientOptions> AddEventHubProducerClient<TBuilder, TConfiguration>(this TBuilder builder, TConfiguration configuration) where TBuilder : IAzureClientFactoryBuilderWithConfiguration<TConfiguration>
- Configuration format and binding to options are not defined in Azure SDKs
Implementation lives in Microsoft.Extensions.Azure
- binding to options is done by microsoft.extensions.configuration through IConfiguration.Bind() and relies on *Options following microsoft.extensions.configuration conventions (i.e. properties)
- options sources are whatever microsoft.extensions.configuration supports:
  - appsettings.json
  - env var config (flat) is supported through ASP.NET Core conventions
Config

Azure SDK supports global configuration through Common environment variables
.NET allows to configure SDKs through appsettings.json or any other MS.Extensions.Configuration-compatible source using additional Microsoft.Extensions.Azure package.
- .NET configuration and examples
Java Azure Spring Cloud works on extensive list of configuration options
Cloud Configuration draft

P0 - Define span modelling conventions for HTTP client spans #1747
Replace http.target with http.path and http.query? #2056
Remove http.XX_content_length* semantic attributes #2028
P0 - Confirm that HTTP instrumentations can provide sampling-relevant attributes at creation time #2011
P? - required/optional #2114

Semantic convention around retry attempts? #1306
Adding semantic conventions for setting attributes to record retry behavior [#729](https://github.com/open-telemetry/opentelemetry-sp

	@Autowired
	ServiceBusSenderClient serviceBusClient;

	@PostMapping("/queues")
	public String send(@RequestParam("message") String message) {
	serviceBusClient.sendMessage(new ServiceBusMessage(message));
	return message;
	}

	public static class MessagingExtensions
	{
	// potential addition to event hubs SDK. service bus is similar
	// The only concern is availability of ActivityContext prior to .NET 5
	// there is a potential to update DiagnosticSource, but it's problematic because of
	// version conflict: binding redirects on .NET Fx and version conflicts with Functions load contexts
	public static ActivityContext ExtractTraceContext(this EventData @event)
	{
	if (@event.Properties.TryGetValue("Diagnostic-Id", out var tp) && tp is string traceparent)
	{

	package org.example.functions;

	import com.azure.core.models.CloudEvent;
	import com.azure.core.util.serializer.TypeReference;
	import com.azure.messaging.eventgrid.EventGridEvent;
	import com.fasterxml.jackson.core.JsonProcessingException;
	import com.fasterxml.jackson.databind.ObjectMapper;
	import com.microsoft.azure.functions.ExecutionContext;
	import com.microsoft.azure.functions.HttpMethod;
	import com.microsoft.azure.functions.HttpRequestMessage;

	public static void main(String[] args) {
	// first call in not instrumented...
	doSomething();

	doSomething().transform(t -> {
	Span s = GlobalOpenTelemetry.getTracer("test")
	.spanBuilder("span")
	.startSpan();

	return t.doFinally(signal -> s.end())

	private static final Method SET_REACTOR_CONTEXT_METHOD = getStoreContextMethod();
	static Method getStoreContextMethod() {
	try {
	Class<?> contextPropagationOperatorClass = Class.forName("io.opentelemetry.javaagent.shaded.instrumentation.reactor.ContextPropagationOperator");
	Class<?> oteContextShaded = Class.forName("io.opentelemetry.javaagent.shaded.io.opentelemetry.context.Context");
	if (contextPropagationOperatorClass != null && oteContextShaded != null) {
	Method storeMethod = contextPropagationOperatorClass.getDeclaredMethod("storeOpenTelemetryContext", reactor.util.context.Context.class, oteContextShaded);
	if (storeMethod.getReturnType() == reactor.util.context.Context.class) {
	return storeMethod;
	}