149 references to SetTag
Aspire.Confluent.Kafka (32)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (9)
335activity.SetTag(SemanticConventions.AttributeErrorType, errorType); 363activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.KafkaMessagingSystem); 364activity.SetTag(SemanticConventions.AttributeMessagingClientId, this.Name); 365activity.SetTag(SemanticConventions.AttributeMessagingDestinationName, topicPartitionOffset?.Topic); 366activity.SetTag(SemanticConventions.AttributeMessagingKafkaDestinationPartition, topicPartitionOffset?.Partition.Value); 367activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageOffset, topicPartitionOffset?.Offset.Value); 368activity.SetTag(SemanticConventions.AttributeMessagingKafkaConsumerGroup, this.GroupId); 369activity.SetTag(SemanticConventions.AttributeMessagingOperation, ConfluentKafkaCommon.ReceiveOperationName); 372activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageKey, key);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedProducer.cs (14)
61activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatProduceException(produceException)); 68activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatArgumentException(argumentException)); 108activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatProduceException(produceException)); 115activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatArgumentException(argumentException)); 151activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatProduceException(produceException)); 158activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatArgumentException(argumentException)); 192activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatProduceException(produceException)); 199activity?.SetTag(SemanticConventions.AttributeErrorType, errorType = FormatArgumentException(argumentException)); 341activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.KafkaMessagingSystem); 342activity.SetTag(SemanticConventions.AttributeMessagingClientId, this.Name); 343activity.SetTag(SemanticConventions.AttributeMessagingDestinationName, topic); 344activity.SetTag(SemanticConventions.AttributeMessagingOperation, ConfluentKafkaCommon.PublishOperationName); 348activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageKey, message.Key); 353activity.SetTag(SemanticConventions.AttributeMessagingKafkaDestinationPartition, partition);
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\OpenTelemetryConsumeResultExtensions.cs (9)
135processActivity?.SetTag(SemanticConventions.AttributeErrorType, ex.GetType().FullName); 161activity.SetTag(SemanticConventions.AttributeMessagingSystem, ConfluentKafkaCommon.KafkaMessagingSystem); 162activity.SetTag(SemanticConventions.AttributeMessagingClientId, clientId); 163activity.SetTag(SemanticConventions.AttributeMessagingDestinationName, topicPartitionOffset?.Topic); 164activity.SetTag(SemanticConventions.AttributeMessagingKafkaDestinationPartition, topicPartitionOffset?.Partition.Value); 165activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageOffset, topicPartitionOffset?.Offset.Value); 166activity.SetTag(SemanticConventions.AttributeMessagingKafkaConsumerGroup, groupId); 167activity.SetTag(SemanticConventions.AttributeMessagingOperation, ConfluentKafkaCommon.ProcessOperationName); 170activity.SetTag(SemanticConventions.AttributeMessagingKafkaMessageKey, key);
Aspire.Microsoft.Data.SqlClient (8)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Implementation\SqlClientDiagnosticListener.cs (3)
104activity.SetTag(SemanticConventions.AttributeDbName, (string)database); 115activity.SetTag(SemanticConventions.AttributeDbStatement, (string)commandText); 123activity.SetTag(SemanticConventions.AttributeDbStatement, (string)commandText);
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\SqlClientTraceInstrumentationOptions.cs (5)
261sqlActivity.SetTag(SemanticConventions.AttributePeerService, dataSource); 273sqlActivity.SetTag(SemanticConventions.AttributeDbMsSqlInstanceName, connectionDetails.InstanceName); 278sqlActivity.SetTag(SemanticConventions.AttributeServerAddress, connectionDetails.ServerHostName); 282sqlActivity.SetTag(SemanticConventions.AttributeServerSocketAddress, connectionDetails.ServerIpAddress); 288sqlActivity.SetTag(SemanticConventions.AttributeServerPort, connectionDetails.Port);
Aspire.Microsoft.EntityFrameworkCore.SqlServer (8)
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\Implementation\SqlClientDiagnosticListener.cs (3)
104activity.SetTag(SemanticConventions.AttributeDbName, (string)database); 115activity.SetTag(SemanticConventions.AttributeDbStatement, (string)commandText); 123activity.SetTag(SemanticConventions.AttributeDbStatement, (string)commandText);
src\Vendoring\OpenTelemetry.Instrumentation.SqlClient\SqlClientTraceInstrumentationOptions.cs (5)
261sqlActivity.SetTag(SemanticConventions.AttributePeerService, dataSource); 273sqlActivity.SetTag(SemanticConventions.AttributeDbMsSqlInstanceName, connectionDetails.InstanceName); 278sqlActivity.SetTag(SemanticConventions.AttributeServerAddress, connectionDetails.ServerHostName); 282sqlActivity.SetTag(SemanticConventions.AttributeServerSocketAddress, connectionDetails.ServerIpAddress); 288sqlActivity.SetTag(SemanticConventions.AttributeServerPort, connectionDetails.Port);
Aspire.StackExchange.Redis (11)
src\Vendoring\OpenTelemetry.Instrumentation.StackExchangeRedis\Implementation\RedisProfilerEntryToActivityConverter.cs (11)
113activity.SetTag(StackExchangeRedisConnectionInstrumentation.RedisFlagsKeyName, command.Flags.ToString()); 121activity.SetTag(SemanticConventions.AttributeDbStatement, commandAndKey + " " + script); 125activity.SetTag(SemanticConventions.AttributeDbStatement, commandAndKey); 130activity.SetTag(SemanticConventions.AttributeDbStatement, command.Command); 136activity.SetTag(SemanticConventions.AttributeDbStatement, command.Command); 143activity.SetTag(SemanticConventions.AttributeNetPeerIp, ipEndPoint.Address.ToString()); 144activity.SetTag(SemanticConventions.AttributeNetPeerPort, ipEndPoint.Port); 148activity.SetTag(SemanticConventions.AttributeNetPeerName, dnsEndPoint.Host); 149activity.SetTag(SemanticConventions.AttributeNetPeerPort, dnsEndPoint.Port); 153activity.SetTag(SemanticConventions.AttributePeerService, command.EndPoint.ToString()); 157activity.SetTag(StackExchangeRedisConnectionInstrumentation.RedisDatabaseIndexKeyName, command.Db);
Microsoft.AspNetCore.Components (7)
ComponentsActivitySource.cs (6)
40activity.SetTag("aspnetcore.components.type", componentType); 44activity.SetTag("aspnetcore.components.route", route); 77activity.SetTag("aspnetcore.components.type", componentType); 81activity.SetTag("code.function.name", methodName); 85activity.SetTag("aspnetcore.components.attribute.name", attributeName); 119activity.SetTag("error.type", ex.GetType().FullName);
src\Shared\Components\ComponentsActivityLinkStore.cs (1)
58targetActivity.SetTag(tag.Value.Key, tag.Value.Value);
Microsoft.AspNetCore.Components.Endpoints (1)
src\Shared\Components\ComponentsActivityLinkStore.cs (1)
58targetActivity.SetTag(tag.Value.Key, tag.Value.Value);
Microsoft.AspNetCore.Components.Server (3)
Circuits\CircuitActivitySource.cs (2)
37activity.SetTag("aspnetcore.components.circuit.id", circuitId); 68activity.SetTag("error.type", ex.GetType().FullName);
src\Shared\Components\ComponentsActivityLinkStore.cs (1)
58targetActivity.SetTag(tag.Value.Key, tag.Value.Value);
Microsoft.AspNetCore.SignalR.Client.Core (11)
HubConnection.cs (7)
1062activity.SetTag("error.type", ex.GetType().FullName); 1073activity.SetTag("server.address", uri.Host); 1074activity.SetTag("server.port", uri.Port); 1121activity.SetTag("rpc.service", _serviceName); 1128activity.SetTag("rpc.system", "signalr"); 1129activity.SetTag("rpc.method", methodName); 1257activity.SetTag("error.type", ex.GetType().FullName);
Internal\InvocationRequest.cs (4)
128Activity.SetTag("error.type", exception.GetType().FullName); 159Activity.SetTag("error.type", typeof(OperationCanceledException).FullName); 203Activity.SetTag("error.type", exception.GetType().FullName); 224Activity.SetTag("error.type", typeof(OperationCanceledException).FullName);
Microsoft.AspNetCore.SignalR.Core (1)
Internal\DefaultHubDispatcher.cs (1)
894activity?.SetTag("error.type", ex.GetType().FullName);
Microsoft.Extensions.AI (3)
ChatCompletion\FunctionInvokingChatClient.cs (3)
1164_ = activity?.SetTag(OpenTelemetryConsts.GenAI.Tool.Call.Arguments, functionArguments); 1189_ = activity.SetTag(OpenTelemetryConsts.Error.Type, e.GetType().FullName) 1213_ = activity?.SetTag(OpenTelemetryConsts.GenAI.Tool.Call.Result, functionResult);
Microsoft.Extensions.DataIngestion (8)
IngestionPipeline.cs (8)
89rootActivity?.SetTag(ProcessDirectory.DirectoryPathTagName, directory.FullName) 90.SetTag(ProcessDirectory.SearchPatternTagName, searchPattern) 91.SetTag(ProcessDirectory.SearchOptionTagName, searchOption.ToString()); 124activity?.SetTag(ErrorTypeTagName, ex.GetType().FullName) 137rootActivity?.SetTag(ProcessFiles.FileCountTagName, count); 145processFileActivity?.SetTag(ProcessFile.FilePathTagName, fileInfo.FullName); 154processFileActivity?.SetTag(ProcessSource.DocumentIdTagName, document.Identifier); 180parentActivity?.SetTag(ProcessSource.DocumentIdTagName, document.Identifier);
Microsoft.Extensions.ServiceDiscovery.Dns (4)
Resolver\DnsResolver.Telemetry.cs (4)
70_activity.SetTag("dns.question.name", hostName); 71_activity.SetTag("dns.question.type", queryType.ToString()); 99_activity.SetTag("dns.answers", answersArray); 103_activity.SetTag("error.type", error.ToString());
Microsoft.Extensions.Telemetry.Tests (1)
Logging\ExtendedLoggerFactoryTests.cs (1)
371activity.SetTag("MyTagKey3", "4");
Seq.ApiService (1)
Program.cs (1)
26activity?.SetTag("Number", number);
Stress.ApiService (24)
Program.cs (24)
435activity.SetTag("gen_ai.system", "gpt"); 436activity.SetTag("gen_ai.input.messages", """ 528activity.SetTag("gen_ai.system", "gpt"); 529activity.SetTag("gen_ai.input.messages", "invalid"); 547activity.SetTag("gen_ai.system", "langchain"); 548activity.SetTag("gen_ai.provider.name", "openai"); 549activity.SetTag("gen_ai.response.model", "gpt-4"); 550activity.SetTag("gen_ai.usage.input_tokens", 150); 551activity.SetTag("gen_ai.usage.output_tokens", 75); 555activity.SetTag("gen_ai.prompt.0.role", "system"); 556activity.SetTag("gen_ai.prompt.0.content", "You are a helpful AI assistant that provides accurate and concise information."); 558activity.SetTag("gen_ai.prompt.1.role", "user"); 559activity.SetTag("gen_ai.prompt.1.content", "What is the capital of France?"); 561activity.SetTag("gen_ai.prompt.2.role", "assistant"); 562activity.SetTag("gen_ai.prompt.2.content", "The capital of France is Paris. It is located in the north-central part of the country and is known for its art, culture, and history."); 564activity.SetTag("gen_ai.prompt.3.message.role", "user"); 565activity.SetTag("gen_ai.prompt.3.message.content", "What about Germany?"); 567activity.SetTag("gen_ai.completion.1.message.role", "assistant"); 568activity.SetTag("gen_ai.completion.1.message.content", "The capital of Germany is Berlin. It is located in the northeastern part of the country and serves as the political and cultural center."); 586activity.SetTag("gen_ai.system", "gpt"); 587activity.SetTag("gen_ai.response.model", "gpt-4"); 588activity.SetTag("gen_ai.usage.input_tokens", 125); 589activity.SetTag("gen_ai.usage.output_tokens", 89); 590activity.SetTag("gen_ai.response.id", "chatcmpl-eval-123");
System.Net.Http (13)
System\Net\Http\DiagnosticsHandler.cs (8)
122activity.SetTag(methodTag.Key, methodTag.Value); 125activity.SetTag("http.request.method_original", request.Method.Method); 130activity.SetTag("server.address", DiagnosticsHelper.GetServerAddress(request, _proxy)); 131activity.SetTag("server.port", requestUri.Port); 132activity.SetTag("url.full", UriRedactionHelper.GetRedactedUriString(requestUri)); 204activity.SetTag("http.response.status_code", DiagnosticsHelper.GetBoxedInt32((int)response.StatusCode)); 205activity.SetTag("network.protocol.version", DiagnosticsHelper.GetProtocolVersionString(response.Version)); 210activity.SetTag("error.type", errorType);
System\Net\Http\SocketsHttpHandler\ConnectionPool\ConnectionSetupDistributedTracing.cs (5)
32activity.SetTag("server.address", serverAddress); 33activity.SetTag("server.port", port); 34activity.SetTag("url.scheme", isSecure ? "https" : "http"); 52activity.SetTag("network.peer.address", remoteEndPoint.Address.ToString()); 69activity.SetTag("error.type", errorType);
System.Net.NameResolution (3)
System\Net\NameResolutionTelemetry.cs (3)
179_activity.SetTag("dns.question.name", host); 204_activity.SetTag("dns.answers", answerValues); 210_activity.SetTag("error.type", errorType);
System.Net.Security (4)
System\Net\Security\NetSecurityTelemetry.cs (4)
324activity.SetTag("server.address", stream.TargetHostName); 341activity.SetTag("tls.protocol.name", protocolName); 342activity.SetTag("tls.protocol.version", protocolVersion); 348activity.SetTag("error.type", exception.GetType().FullName);
System.Net.Sockets (6)
System\Net\Sockets\SocketsTelemetry.cs (6)
113activity.SetTag("network.peer.address", ipEndPoint.Address.ToString()); 114activity.SetTag("network.peer.port", port); 115activity.SetTag("network.type", ipEndPoint.AddressFamily == AddressFamily.InterNetwork ? "ipv4" : "ipv6"); 133activity.SetTag("network.peer.address", peerAddress); 139static void SetNetworkTransport(Activity activity, string transportType) => activity.SetTag("network.transport", transportType); 155activity.SetTag("error.type", GetErrorType(error));