Module plugin
Generated from cargo doc --no-deps -p nemo-relay-builtins -p nemo-relay-diagnostics -p nemo-relay-logging -p nemo-relay-plugin-host -p nemo-relay-codecs -p nemo-relay -p nemo-relay-runtime -p nemo-relay-model-pricing -p nemo-relay-resource-metrics -p nemo-relay-observability -p nemo-relay-adaptive -p nemo-relay-pii-redaction -p nemo-relay-ffi -p nemo-relay-types -p nemo-relay-plugin -p nemo-relay-worker-proto -p nemo-relay-worker.
Built-in observability plugin configuration and lifecycle. Built-in observability plugin component.
This module packages NeMo Relay’s first-party observability exporters behind the shared plugin configuration system. Each exporter section is opt-in: omitted sections and sections with enabled = false validate but do not register subscribers or construct exporters.
The plugin intentionally infers subscriber names from the component namespace so configuration remains portable across bindings. Agent Trajectory Observability Format (ATOF) registers one global subscriber when enabled. Typed OpenTelemetry endpoints share one global fan-out subscriber. Agent Trajectory Interchange Format (ATIF) uses a global dispatcher that detects top-level agent or turn scopes and creates one scope-local exporter for each trajectory run. Coding-agent turns that need bounded traces carry role metadata; their declared scope type is preserved in the exported event stream.
Structs
- AtifCorrelation
- AtifDispatcher
- AtifFlushWork
- AtifOutputOptions
- AtifRemoteStorage: Remote storage handle for ATIF trajectory uploads.
- AtifSectionConfig: Per-trajectory ATIF exporter config.
- AtifUploadRequest
- AtofFileSinkSectionConfig: File sink settings for the ATOF plugin section.
- AtofSectionConfig: Multi-sink ATOF JSONL exporter config.
- AtofStreamSinkSectionConfig: Stream sink settings for the ATOF plugin section.
- AutomaticOtlpSignals
- ComponentSpec: Top-level observability component wrapper.
- HttpStorageConfig: HTTP endpoint settings for ATIF trajectory upload.
- HttpUploadConfig
- IndexedOpenTelemetryResource
- ManagedAtifExporter
- ObservabilityConfig: Canonical config document for the observability plugin component.
- ObservabilityPlugin: Built-in observability component.
- OpenTelemetryDestination
- OpenTelemetryDestinationCollision
- OpenTelemetryEndpointConfig: One typed OTLP destination.
- OpenTelemetryFileSinkConfig: One local file destination for projected OTLP spans.
- OpenTelemetryLogSectionConfig: OTLP log pipeline settings.
- OpenTelemetryMetricSectionConfig: OTLP metric pipeline settings.
- OpenTelemetrySectionConfig: Multi-endpoint OpenTelemetry export settings.
- OpenTelemetryShutdownIssue
- OpenTelemetrySignalEndpointConfig: Signal-common OTLP destination fields used by logs and metrics.
- OpenTelemetrySignalSubscribers
- PendingAtifExport
- PendingAtifWrite
- ResolvedSignalEndpoints
- S3BuilderOverrides
- S3StorageConfig: S3-compatible storage settings for ATIF trajectory upload.
- SkippedResource
Enums
- AtifStorageConfig: Remote storage destination for ATIF trajectory files.
- AtofSinkSectionConfig: One plugin-managed destination for raw ATOF events.
- OpenTelemetryDestinationKey
- OpenTelemetryResource
- OpenTelemetryShutdownFailure
- SinkLabel: Identifier for a single output sink.
Localis used whenstorageis empty (the legacy local-file path);Remote(i)indexes into the configured storage backends.
Constants
- AUTOMATIC_INSECURE_HTTP_HOSTS_VARIABLE
- OBSERVABILITY_PLUGIN_KIND: The plugin kind registered by the core crate.
Functions
- apply_otel_environment_headers
- apply_signal_common
- atif_dispatcher_subscriber
- atif_scope_subscriber
- atif_shutdown_cleanup
- atof_endpoint_transport_schema
- atof_mode_schema
- automatic_exporter_failure: Classify from typed evidence only; backend strings can contain credentials and flatten several causes, so they must neither be parsed nor copied into reports.
- automatic_otlp_signals
- automatic_plaintext_policy
- automatic_subscriber: Build one automatic subscriber without preventing healthy signals from activating.
- build_atif_storage
- build_atof_sink_config
- build_log_config
- build_metric_config
- build_opentelemetry_file_sink_subscribers
- build_opentelemetry_log_subscribers
- build_opentelemetry_metric_subscribers
- build_opentelemetry_signal_subscribers
- build_opentelemetry_subscribers
- build_otel_config
- build_otel_file_config
- canonical_opentelemetry_host
- canonicalize_opentelemetry_destination
- default_agent_name
- default_agent_version
- default_atif_filename_template
- default_atif_include_payloads
- default_atof_endpoint_field_name_policy
- default_atof_endpoint_transport
- default_atof_file_sink_editor_value
- default_atof_mode
- default_atof_stream_sink_editor_value
- default_completed_span_context_ttl_millis
- default_http_storage_editor_value
- default_model_name
- default_observability_config_version
- default_opentelemetry_endpoint_editor_value
- default_opentelemetry_file_sink_editor_value
- default_opentelemetry_signal_endpoint_editor_value
- default_otel_instrumentation_scope
- default_otel_log_max_export_batch_size
- default_otel_log_max_queue_size
- default_otel_log_minimum_severity
- default_otel_log_scheduled_delay_millis
- default_otel_metric_cardinality_limit
- default_otel_metric_export_interval_millis
- default_otel_metric_max_instruments
- default_otel_metric_temporality
- default_otel_service_name
- default_otlp_file_sink_mode
- default_otlp_transport
- default_output_directory
- default_s3_storage_editor_value
- default_timeout_millis
- deliver_opentelemetry_callbacks
- deliver_opentelemetry_event
- deliver_opentelemetry_metric_callbacks
- deregister_atif_shutdown_subscriber
- derive_http_signal_endpoint
- derive_signal_endpoint
- environment_has_nonblank_value
- environment_signal_enabled
- event_observation_key
- flush_atif_shutdown_work
- has_active_opentelemetry_resource
- is_safe_atif_metadata_path
- is_safe_atif_session_id
- is_top_level_trajectory_start
- is_valid_atif_metadata_selector
- is_valid_atof_stream_url
- log_opentelemetry_resource_access
- log_severity_schema
- mark_projection_schema
- metric_temporality_schema
- no_active_opentelemetry_destination_error
- normalize_opentelemetry_path
- normalize_storage_key_prefix
- observability_config_schema: Returns the JSON Schema for the observability component configuration.
- observability_registration_error
- omit_atif_llm_requests
- opentelemetry_destination
- opentelemetry_destination_collision_errors
- opentelemetry_section_is_empty
- opentelemetry_type_name
- otel_editor_field
- otel_list_editor_field
- otel_sdk_disabled
- otel_tls_editor_field
- otlp_file_format_schema
- otlp_file_sink_mode_schema: A trace file sink defaults to
overwrite, unlike the ATOF event sink: a run that reuses a filename should not read as one trajectory appended to another. - otlp_transport_schema
- parse_atif_metadata_expression
- parse_observability_config
- parse_signal_transport
- post_atif_http
- prepare_atif_file
- prepare_atif_payload
- prepare_atif_shutdown_file
- push_otel_signal_diagnostic
- push_plaintext_preflight_diagnostic
- push_policy_diag
- push_skipped_opentelemetry_endpoint_diagnostic
- raw_opentelemetry_destination
- record_invalid_automatic_insecure_hosts
- register_atif_dispatcher
- register_atof_exporter
- register_automatic_opentelemetry
- register_full_payload_policy
- register_observability
- register_opentelemetry
- register_opentelemetry_resources
- reject_opentelemetry_metric_mark
- render_atif_filename
- resolve_env_var_field
- resolve_signal_endpoints
- resolve_signal_headers
- sanitize_atif_metadata_fragment
- shutdown_all_opentelemetry_subscribers
- shutdown_failure_from_errors
- shutdown_indexed_opentelemetry_providers
- signal_destination
- signal_shutdown_issue
- skipped_opentelemetry_endpoints
- string_enum_schema
- validate_atif_file_export_support
- validate_atif_filename_template
- validate_atif_http_endpoint
- validate_atif_http_header
- validate_atif_http_header_name
- validate_atif_section
- validate_atif_storage_env_var
- validate_atif_storage_values
- validate_atif_values
- validate_atof_section
- validate_atof_sink
- validate_atof_stream_header
- validate_atof_stream_header_env
- validate_atof_stream_header_name
- validate_atof_stream_sink_name
- validate_atof_stream_sink_values
- validate_atof_values
- validate_automatic_plaintext_destinations
- validate_case_insensitive_header_duplicates
- validate_case_insensitive_signal_header_duplicates
- validate_distinct_opentelemetry_destinations
- validate_distinct_opentelemetry_file_sinks: Rejects two file sinks writing the same path.
- validate_distinct_signal_destinations
- validate_explicit_signal_endpoint
- validate_http_headers
- validate_observability_plaintext_destinations
- validate_observability_plugin_config
- validate_observability_plugin_config_with_policy
- validate_observability_section_fields
- validate_observability_section_values
- validate_opentelemetry_batch_config
- validate_opentelemetry_endpoint_fields
- validate_opentelemetry_feature_support
- validate_opentelemetry_file_sink_fields: Reports unknown keys inside each
file_sinksentry. - validate_opentelemetry_file_sinks: Reports the file-sink settings that would otherwise fail only at activation.
- validate_opentelemetry_header_env
- validate_opentelemetry_header_name
- validate_opentelemetry_header_value
- validate_opentelemetry_headers
- validate_opentelemetry_log_section
- validate_opentelemetry_metric_section
- validate_opentelemetry_plaintext_destinations
- validate_opentelemetry_section
- validate_opentelemetry_signal_endpoint_values
- validate_opentelemetry_signal_endpoints
- validate_opentelemetry_signal_fields
- validate_otel_batch_config
- validate_otel_file_sink_batch_config: Returns the offending field alongside the error, so a static diagnostic can name the setting that failed rather than always naming
max_queue_size. - validate_otel_file_sink_filename: Rejects a filename that would escape
output_directory. - validate_otel_header_env
- validate_policy_fields
- validate_section_fields
- validate_top_level_observability_fields
- validate_unknown_fields
- validate_version
- warn_skipped_signal_endpoints
- write_atif
- write_atif_local
- write_atif_remote
- write_atif_shutdown_export
- write_atif_shutdown_exports