nat.plugins.data_flywheel.observability.register

Attributes

logger

Classes

DFWElasticsearchTelemetryExporter

A telemetry exporter to transmit traces to NVIDIA Data Flywheel via Elasticsearch.

Functions

dfw_elasticsearch_telemetry_exporter(config, _builder)

Module Contents

logger

class DFWElasticsearchTelemetryExporter(/, **data: Any)

Bases: nat.data_models.telemetry_exporter.TelemetryExporterBaseConfig, nat.observability.mixin.batch_config_mixin.BatchConfigMixin

A telemetry exporter to transmit traces to NVIDIA Data Flywheel via Elasticsearch.

Create a new model by parsing and validating input data from keyword arguments.

Raises [ValidationError][pydantic_core.ValidationError] if the input data cannot be validated to form a valid model.

self is explicitly positional-only to allow self as a field name.

client_id: str = None

index: str = None

endpoint: str = None

contract_version: nat.plugins.data_flywheel.observability.schema.sink.elasticsearch.ContractVersion = None

username: str | None = None

password: str | None = None

headers: dict | None = None

async dfw_elasticsearch_telemetry_exporter(

config: DFWElasticsearchTelemetryExporter,

_builder: nat.builder.builder.Builder,

)