Bedrock.DataPlane.Resolver.Telemetry (bedrock v0.6.0)

View Source

Telemetry utilities for resolver operations.

Summary

Functions

emit_completed(transactions, aborted, next_version)
emit_processing(transactions, next_version)
emit_received(transactions, next_version)
emit_reply_sent(transactions, aborted, next_version)
emit_validation_error(transactions, reason)
emit_waiting_list(transactions, next_version)
emit_waiting_list_inserted(transactions, waiting_list, next_version)
emit_waiting_list_validation_error(transactions, reason)
emit_waiting_resolved(transactions, aborted, next_version)

Functions

emit_completed(transactions, aborted, next_version)

@spec emit_completed(list(), list(), Bedrock.DataPlane.Version.t()) :: :ok

emit_processing(transactions, next_version)

@spec emit_processing(list(), Bedrock.DataPlane.Version.t()) :: :ok

emit_received(transactions, next_version)

@spec emit_received(list(), Bedrock.DataPlane.Version.t()) :: :ok

emit_reply_sent(transactions, aborted, next_version)

@spec emit_reply_sent(list(), list(), Bedrock.DataPlane.Version.t()) :: :ok

emit_validation_error(transactions, reason)

@spec emit_validation_error(list(), term()) :: :ok

emit_waiting_list(transactions, next_version)

@spec emit_waiting_list(list(), Bedrock.DataPlane.Version.t()) :: :ok

emit_waiting_list_inserted(transactions, waiting_list, next_version)

@spec emit_waiting_list_inserted(list(), map(), Bedrock.DataPlane.Version.t()) :: :ok

emit_waiting_list_validation_error(transactions, reason)

@spec emit_waiting_list_validation_error(list(), term()) :: :ok

emit_waiting_resolved(transactions, aborted, next_version)

@spec emit_waiting_resolved(list(), list(), Bedrock.DataPlane.Version.t()) :: :ok