Bedrock.DataPlane.Materializer.Telemetry (bedrock v0.5.2)

View Source

Telemetry utilities for materializer operations.

Summary

Types

telemetry_metadata()

Functions

emit_materializer_operation(operation, measurements \\ %{}, metadata \\ %{})
trace_log_marked_as_failed(start_after, log_id)
trace_log_pull_circuit_breaker_reset(start_after)
trace_log_pull_circuit_breaker_tripped(start_after, ms_to_wait)
trace_log_pull_failed(start_after, reason)
trace_log_pull_start(start_after, start_after)
trace_log_pull_succeeded(start_after, count)
trace_metadata()
trace_metadata(metadata)
trace_read_operation_complete(operation, key, opts)
trace_shutdown_complete()
trace_shutdown_start(reason)
trace_shutdown_timeout(task_count)
trace_shutdown_waiting(task_count)
trace_startup_complete()
trace_startup_failed(reason)
trace_startup_start()
trace_transaction_processing_complete(batch_size, duration_microseconds)
trace_transaction_processing_complete(batch_size, duration_microseconds, batch_size_bytes)
trace_transaction_timeout_scheduled()
trace_transactions_queued(transaction_count, queue_size)

Types

telemetry_metadata()

@type telemetry_metadata() :: %{optional(atom()) => term()}

Functions

emit_materializer_operation(operation, measurements \\ %{}, metadata \\ %{})

@spec emit_materializer_operation(atom(), map(), map()) :: :ok

trace_log_marked_as_failed(start_after, log_id)

@spec trace_log_marked_as_failed(term(), String.t()) :: :ok

trace_log_pull_circuit_breaker_reset(start_after)

@spec trace_log_pull_circuit_breaker_reset(term()) :: :ok

trace_log_pull_circuit_breaker_tripped(start_after, ms_to_wait)

@spec trace_log_pull_circuit_breaker_tripped(term(), integer()) :: :ok

trace_log_pull_failed(start_after, reason)

@spec trace_log_pull_failed(term(), term()) :: :ok

trace_log_pull_start(start_after, start_after)

@spec trace_log_pull_start(term(), term()) :: :ok

trace_log_pull_succeeded(start_after, count)

@spec trace_log_pull_succeeded(term(), integer()) :: :ok

trace_metadata()

@spec trace_metadata() :: telemetry_metadata()

trace_metadata(metadata)

@spec trace_metadata(metadata :: telemetry_metadata()) :: telemetry_metadata()

trace_read_operation_complete(operation, key, opts)

@spec trace_read_operation_complete(term(), term(), keyword()) :: :ok

trace_shutdown_complete()

@spec trace_shutdown_complete() :: :ok

trace_shutdown_start(reason)

@spec trace_shutdown_start(term()) :: :ok

trace_shutdown_timeout(task_count)

@spec trace_shutdown_timeout(integer()) :: :ok

trace_shutdown_waiting(task_count)

@spec trace_shutdown_waiting(integer()) :: :ok

trace_startup_complete()

@spec trace_startup_complete() :: :ok

trace_startup_failed(reason)

@spec trace_startup_failed(term()) :: :ok

trace_startup_start()

@spec trace_startup_start() :: :ok

trace_transaction_processing_complete(batch_size, duration_microseconds)

@spec trace_transaction_processing_complete(integer(), integer()) :: :ok

trace_transaction_processing_complete(batch_size, duration_microseconds, batch_size_bytes)

@spec trace_transaction_processing_complete(integer(), integer(), integer()) :: :ok

trace_transaction_timeout_scheduled()

@spec trace_transaction_timeout_scheduled() :: :ok

trace_transactions_queued(transaction_count, queue_size)

@spec trace_transactions_queued(integer(), integer()) :: :ok