SetTag

100 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.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)

896activity?.SetTag("error.type", ex.GetType().FullName);

Microsoft.Extensions.AI (1)

ChatCompletion\FunctionInvokingChatClient.cs (1)

686_ = activity.SetTag("error.type", e.GetType().FullName)

Microsoft.Extensions.Telemetry.Tests (1)

Logging\ExtendedLoggerFactoryTests.cs (1)

370activity.SetTag("MyTagKey3", "4");

Seq.ApiService (1)

Program.cs (1)

26activity?.SetTag("Number", number);

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", requestUri.Host); 131activity.SetTag("server.port", requestUri.Port); 132activity.SetTag("url.full", DiagnosticsHelper.GetRedactedUriString(requestUri)); 203activity.SetTag("http.response.status_code", DiagnosticsHelper.GetBoxedInt32((int)response.StatusCode)); 204activity.SetTag("network.protocol.version", DiagnosticsHelper.GetProtocolVersionString(response.Version)); 209activity.SetTag("error.type", errorType);

System\Net\Http\SocketsHttpHandler\ConnectionPool\ConnectionSetupDistributedTracing.cs (5)

31activity.SetTag("server.address", authority.HostValue); 32activity.SetTag("server.port", authority.Port); 33activity.SetTag("url.scheme", isSecure ? "https" : "http"); 51activity.SetTag("network.peer.address", remoteEndPoint.Address.ToString()); 68activity.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));