in src/Azure.IIoT.OpcUa.Publisher/src/Services/WriterGroupDataSource.cs [422:580]
private void InitializeMetrics()
{
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_metadata_changes",
() => new Measurement<int>(_metadataChanges, _metrics.TagList),
description: "Number of metadata changes.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_good_metadata",
() => new Measurement<int>(_metadataLoadSuccess, _metrics.TagList),
description: "Number of successful metadata load operations.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_bad_metadata",
() => new Measurement<int>(_metadataLoadFailures, _metrics.TagList),
description: "Number of failed metadata load operations.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_messages_without_metadata",
() => new Measurement<int>(_messagesWithoutMetadata, _metrics.TagList),
description: "Number of messages dropped because metadata was missing in time.");
// --- collected by publisher collector:
_meter.CreateObservableCounter("iiot_edge_publisher_heartbeats",
() => new Measurement<long>(_heartbeats.Count, _metrics.TagList),
description: "Total Heartbeats delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_heartbeats_per_second",
() => new Measurement<double>(_heartbeats.Count / UpTime, _metrics.TagList),
description: "Opc Cyclic reads/second delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_heartbeats_per_second_last_min",
() => new Measurement<long>(_heartbeats.LastMinute, _metrics.TagList),
description: "Opc Cyclic reads/second delivered for processing in last 60s.");
_meter.CreateObservableCounter("iiot_edge_publisher_sampledvalues",
() => new Measurement<long>(_sampledValues.Count, _metrics.TagList),
description: "Total sampled values delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_sampledvalues_per_second",
() => new Measurement<double>(_sampledValues.Count / UpTime, _metrics.TagList),
description: "Opc sampled values/second delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_sampledvalues_per_second_last_min",
() => new Measurement<long>(_sampledValues.LastMinute, _metrics.TagList),
description: "Opc sampled values/second delivered for processing in last 60s.");
_meter.CreateObservableCounter("iiot_edge_publisher_modelchanges",
() => new Measurement<long>(_modelChanges.Count, _metrics.TagList),
description: "Total Number of changes found in the address spaces of the connected servers.");
_meter.CreateObservableGauge("iiot_edge_publisher_modelchanges_per_second",
() => new Measurement<double>(_modelChanges.Count / UpTime, _metrics.TagList),
description: "Address space Model changes/second delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_modelchanges_per_second_last_min",
() => new Measurement<long>(_modelChanges.LastMinute, _metrics.TagList),
description: "Address space Model changes/second delivered for processing in last 60s.");
_meter.CreateObservableCounter("iiot_edge_publisher_value_changes",
() => new Measurement<long>(_valueChanges.Count, _metrics.TagList),
description: "Total Opc Value changes delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_value_changes_per_second",
() => new Measurement<double>(_valueChanges.Count / UpTime, _metrics.TagList),
description: "Opc Value changes/second delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_value_changes_per_second_last_min",
() => new Measurement<long>(_valueChanges.LastMinute, _metrics.TagList),
description: "Opc Value changes/second delivered for processing in last 60s.");
_meter.CreateObservableCounter("iiot_edge_publisher_events",
() => new Measurement<long>(_events.Count, _metrics.TagList),
description: "Total Opc Events delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_events_per_second",
() => new Measurement<double>(_events.Count / UpTime, _metrics.TagList),
description: "Opc Events/second delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_events_per_second_last_min",
() => new Measurement<long>(_events.LastMinute, _metrics.TagList),
description: "Opc Events/second delivered for processing in last 60s.");
_meter.CreateObservableCounter("iiot_edge_publisher_event_notifications",
() => new Measurement<long>(_eventNotification.Count, _metrics.TagList),
description: "Total Opc Event notifications delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_event_notifications_per_second",
() => new Measurement<double>(_eventNotification.Count / UpTime, _metrics.TagList),
description: "Opc Event notifications/second delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_event_notifications_per_second_last_min",
() => new Measurement<long>(_eventNotification.LastMinute, _metrics.TagList),
description: "Opc Event notifications/second delivered for processing in last 60s.");
_meter.CreateObservableCounter("iiot_edge_publisher_data_changes",
() => new Measurement<long>(_dataChanges.Count, _metrics.TagList),
description: "Total Opc Data change notifications delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_data_changes_per_second",
() => new Measurement<double>(_dataChanges.Count / UpTime, _metrics.TagList),
description: "Opc Data change notifications/second delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_data_changes_per_second_last_min",
() => new Measurement<long>(_dataChanges.LastMinute, _metrics.TagList),
description: "Opc Data change notifications/second delivered for processing in last 60s.");
_meter.CreateObservableCounter("iiot_edge_publisher_cyclicreads",
() => new Measurement<long>(_cyclicReads.Count, _metrics.TagList),
description: "Total Cyclic reads delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_cyclicreads_per_second",
() => new Measurement<double>(_cyclicReads.Count / UpTime, _metrics.TagList),
description: "Opc Cyclic reads/second delivered for processing.");
_meter.CreateObservableGauge("iiot_edge_publisher_cyclicreads_per_second_last_min",
() => new Measurement<long>(_cyclicReads.LastMinute, _metrics.TagList),
description: "Opc Cyclic reads/second delivered for processing in last 60s.");
_meter.CreateObservableCounter("iiot_edge_publisher_queue_overflows",
() => new Measurement<long>(_overflows.Count, _metrics.TagList),
description: "Total values received with a queue overflow indicator.");
_meter.CreateObservableGauge("iiot_edge_publisher_queue_overflows_per_second",
() => new Measurement<double>(_overflows.Count / UpTime, _metrics.TagList),
description: "Values with overflow indicator/second received.");
_meter.CreateObservableGauge("iiot_edge_publisher_queue_overflows_per_second_last_min",
() => new Measurement<long>(_overflows.LastMinute, _metrics.TagList),
description: "Values with overflow indicator/second received in last 60s.");
_meter.CreateObservableCounter("iiot_edge_publisher_keep_alive_notifications",
() => new Measurement<long>(_keepAliveCount, _metrics.TagList),
description: "Total Opc keep alive notifications delivered for processing.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_connection_retries",
() => new Measurement<long>(ReconnectCount, _metrics.TagList),
description: "OPC UA total connect retries.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_connections",
() => new Measurement<long>(ConnectCount, _metrics.TagList),
description: "OPC UA total connection success count.");
_meter.CreateObservableGauge("iiot_edge_publisher_is_connection_ok",
() => new Measurement<int>(ConnectedClients, _metrics.TagList),
description: "OPC UA endpoints that are successfully connected.");
_meter.CreateObservableGauge("iiot_edge_publisher_is_disconnected",
() => new Measurement<int>(DisconnectedClients, _metrics.TagList),
description: "OPC UA endpoints that are disconnected.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_writer_count",
() => new Measurement<int>(_writers.Count, _metrics.TagList),
description: "Number of writers in the writer group.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_writer_nodes",
() => new Measurement<int>(TotalItems, _metrics.TagList),
description: "Total monitored item count.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_writer_good_nodes",
() => new Measurement<int>(GoodMonitoredItems, _metrics.TagList),
description: "Monitored items successfully created.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_writer_bad_nodes",
() => new Measurement<int>(BadMonitoredItems, _metrics.TagList),
description: "Monitored items that were not successfully created.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_writer_late_nodes",
() => new Measurement<int>(LateMonitoredItems, _metrics.TagList),
description: "Monitored items that are late reporting.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_writer_heartbeat_enabled_nodes",
() => new Measurement<int>(HeartbeatsEnabled, _metrics.TagList),
description: "Monitored items with heartbeats enabled.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_writer_condition_enabled_nodes",
() => new Measurement<int>(ConditionsEnabled, _metrics.TagList),
description: "Monitored items with condition monitoring enabled.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_publish_requests_client_totals",
() => new Measurement<int>(OutstandingRequestCount, _metrics.TagList),
description: "Total good publish requests used by all clients used by the writer group.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_good_publish_requests_client_totals",
() => new Measurement<int>(GoodPublishRequestCount, _metrics.TagList),
description: "Total good publish requests used by all clients used by the writer group.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_bad_publish_requests_client_totals",
() => new Measurement<int>(BadPublishRequestCount, _metrics.TagList),
description: "Total bad publish requests used by all clients used by the writer group.");
_meter.CreateObservableUpDownCounter("iiot_edge_publisher_min_publish_requests_client_totals",
() => new Measurement<int>(MinPublishRequestCount, _metrics.TagList),
description: "Total min publish requests queued by all clients used by the writer group.");
}