AshScylla.Telemetry (AshScylla v0.3.0)

Telemetry integration for AshScylla.

Emits standard :telemetry events for query execution, enabling integration with LiveDashboard, Datadog, OpenTelemetry, and other observability tools.

Events

[:ash_scylla, :query, :start] - Emitted when a query begins execution. Measurements: %{system_time: integer()} Metadata: %{resource: module(), operation: atom(), query: String.t()}
[:ash_scylla, :query, :stop] - Emitted when a query finishes. Measurements: %{duration: integer()} Metadata: %{resource: module(), operation: atom(), query: String.t()}
[:ash_scylla, :query, :exception] - Emitted when a query raises. Measurements: %{duration: integer()} Metadata: %{resource: module(), operation: atom(), query: String.t(), kind: atom(), reason: term()}
[:ash_scylla, :batch, :start] - Emitted when a batch operation begins. Measurements: %{system_time: integer()} Metadata: %{resource: module(), operation: atom(), batch_size: integer()}
[:ash_scylla, :batch, :stop] - Emitted when a batch operation finishes. Measurements: %{duration: integer()} Metadata: %{resource: module(), operation: atom(), batch_size: integer()}

Attaching a Handler

:telemetry.attach(
  "ash_scylla-logger",
  [:ash_scylla, :query, :stop],
  &MyApp.Telemetry.handle_event/4,
  nil
)

Summary

Functions

batch_span(resource, operation, batch_size, fun)

Executes a batch operation within a telemetry span.

format_duration(nanoseconds)

Formats a duration in nanoseconds to a human-readable string.

span(resource, operation, query, fun)

Executes a function within a telemetry span.