ExESDBGater.Messages.MetricsMessages (ex_esdb_gater v0.8.0)

Message definitions and helpers for the :ex_esdb_metrics PubSub instance.

Handles performance metrics, measurements, and metric-related events.

Common Topics

  • "performance" - General performance metrics
  • "throughput" - Throughput and rate metrics
  • "latency" - Latency and response time metrics
  • "resource_usage" - CPU, memory, disk usage metrics

Summary

Functions

broadcast_latency_metric(topic, payload)

Broadcast a latency metric

broadcast_metric_alert(topic, payload)

Broadcast a metric alert

broadcast_performance_metric(topic, payload)

Broadcast a performance metric

broadcast_resource_usage(topic, payload)

Broadcast a resource usage metric

broadcast_throughput_metric(topic, payload)

Broadcast a throughput metric

latency_metric(operation, latency_ms, percentile, sample_count, opts \\ [])

Create a LatencyMetric payload with current timestamp

metric_alert(metric_name, current_value, threshold_value, threshold_type, severity, opts \\ [])

Create a MetricAlert payload with current timestamp

performance_metric(metric_name, value, unit, opts \\ [])

Create a PerformanceMetric payload with current timestamp

resource_usage(resource_type, usage_percent, total_available, current_used, opts \\ [])

Create a ResourceUsage payload with current timestamp

secure_broadcast(topic, message)
throughput_metric(operation, count, duration_ms, opts \\ [])

Create a ThroughputMetric payload with current timestamp

validate_secure_message(arg1)

Validate and extract a secure message

Functions

broadcast_latency_metric(topic, payload)

Broadcast a latency metric

broadcast_metric_alert(topic, payload)

Broadcast a metric alert

broadcast_performance_metric(topic, payload)

Broadcast a performance metric

broadcast_resource_usage(topic, payload)

Broadcast a resource usage metric

broadcast_throughput_metric(topic, payload)

Broadcast a throughput metric

latency_metric(operation, latency_ms, percentile, sample_count, opts \\ [])

Create a LatencyMetric payload with current timestamp

metric_alert(metric_name, current_value, threshold_value, threshold_type, severity, opts \\ [])

Create a MetricAlert payload with current timestamp

performance_metric(metric_name, value, unit, opts \\ [])

Create a PerformanceMetric payload with current timestamp

resource_usage(resource_type, usage_percent, total_available, current_used, opts \\ [])

Create a ResourceUsage payload with current timestamp

secure_broadcast(topic, message)

throughput_metric(operation, count, duration_ms, opts \\ [])

Create a ThroughputMetric payload with current timestamp

validate_secure_message(arg1)

Validate and extract a secure message