ConsumeResult

6 instantiations of ConsumeResult

Aspire.Confluent.Kafka (6)

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (6)

267null => new ConsumeResult(null, null), 268{ Message: null } => new ConsumeResult(result.TopicPartitionOffset, null), 269_ => new ConsumeResult(result.TopicPartitionOffset, result.Message.Headers, result.Message.Key), 274{ ConsumerRecord: null } => (new ConsumeResult(null, null), FormatConsumeException(exception)), 275{ ConsumerRecord.Message: null } => (new ConsumeResult(exception.ConsumerRecord.TopicPartitionOffset, null), FormatConsumeException(exception)), 276_ => (new ConsumeResult(exception.ConsumerRecord.TopicPartitionOffset, exception.ConsumerRecord.Message.Headers, exception.ConsumerRecord.Message.Key), FormatConsumeException(exception)),

6 references to ConsumeResult

Aspire.Confluent.Kafka (6)

src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (6)

55ConsumeResult consumeResult = default; 82ConsumeResult consumeResult = default; 109ConsumeResult consumeResult = default; 265private static ConsumeResult ExtractConsumeResult(ConsumeResult<TKey, TValue> result) => result switch 272private static (ConsumeResult ConsumeResult, string ErrorType) ExtractConsumeResult(ConsumeException exception) => exception switch 319private void InstrumentConsumption(DateTimeOffset startTime, DateTimeOffset endTime, ConsumeResult consumeResult, string? errorType)