(
&self,
database: &Database,
event: ToolUseEventBuilder,
)
| 360 | } |
| 361 | |
| 362 | pub async fn send_tool_use_suggested( |
| 363 | &self, |
| 364 | database: &Database, |
| 365 | event: ToolUseEventBuilder, |
| 366 | ) -> Result<(), TelemetryError> { |
| 367 | let mut telemetry_event = Event::new(EventType::ToolUseSuggested { |
| 368 | conversation_id: event.conversation_id, |
| 369 | utterance_id: event.utterance_id, |
| 370 | user_input_id: event.user_input_id, |
| 371 | tool_use_id: event.tool_use_id, |
| 372 | tool_name: event.tool_name, |
| 373 | is_accepted: event.is_accepted, |
| 374 | is_trusted: event.is_trusted, |
| 375 | is_success: event.is_success, |
| 376 | reason_desc: event.reason_desc, |
| 377 | is_valid: event.is_valid, |
| 378 | is_custom_tool: event.is_custom_tool, |
| 379 | input_token_size: event.input_token_size, |
| 380 | output_token_size: event.output_token_size, |
| 381 | custom_tool_call_latency: event.custom_tool_call_latency, |
| 382 | model: event.model, |
| 383 | execution_duration: event.execution_duration, |
| 384 | turn_duration: event.turn_duration, |
| 385 | aws_service_name: event.aws_service_name, |
| 386 | aws_operation_name: event.aws_operation_name, |
| 387 | }); |
| 388 | set_event_metadata(database, &mut telemetry_event).await; |
| 389 | |
| 390 | Ok(self.tx.send(telemetry_event)?) |
| 391 | } |
| 392 | |
| 393 | #[allow(clippy::too_many_arguments)] |
| 394 | pub async fn send_mcp_server_init( |
no test coverage detected