src/go/collectors/go.d.plugin/modules/envoy/charts.go
// SPDX-License-Identifier: GPL-3.0-or-later
package envoy
import (
"fmt"
"strings"
"github.com/netdata/netdata/go/go.d.plugin/agent/module"
"github.com/prometheus/prometheus/model/labels"
)
const (
prioServerState = module.Priority + iota
prioServerMemoryAllocatedSize
prioServerMemoryHeapSize
prioServerMemoryPhysicalSize
prioServerConnectionsCount
prioServerParentConnectionsCount
prioClusterManagerClustersCount
prioClusterManagerClusterChangesRate
prioClusterManagerClusterUpdatesRate
prioClusterManagerClusterUpdatesVieMergeRate
prioClusterManagerClusterUpdatesMergeCancelledRate
prioClusterManagerClusterUpdatesOufOfMergeWindowsRate
prioClusterMembershipEndpointsCount
prioClusterMembershipChangesRate
prioClusterMembershipUpdatesRate
prioClusterUpstreamActiveConnectionsCount
prioClusterUpstreamConnectionsRate
prioClusterUpstreamHTTPConnectionsRate
prioClusterUpstreamDestroyedConnectionsRate
prioClusterUpstreamFailedConnectionsRate
prioClusterUpstreamTimedOutConnectionsRate
prioClusterUpstreamTrafficRate
prioClusterUpstreamBufferedSize
prioClusterUpstreamActiveRequestsCount
prioClusterUpstreamRequestsRate
prioClusterUpstreamFailedRequestsRate
prioClusterUpstreamActivePendingRequestsCount
prioClusterUpstreamPendingRequestsRate
prioClusterUpstreamPendingFailedRequestsRate
prioClusterUpstreamRequestRetriesRate
prioClusterUpstreamRequestSuccessRetriesRate
prioClusterUpstreamRequestBackoffRetriesRate
prioListenerManagerListenerCount
prioListenerManagerListenerChangesRate
prioListenerManagerListenerObjectEventsRate
prioListenerAdminDownstreamActiveConnectionsCount
prioListenerAdminDownstreamConnectionsRate
prioListenerAdminDownstreamDestroyedConnectionsRate
prioListenerAdminDownstreamTimedOutConnectionsRate
prioListenerAdminDownstreamRejectedConnectionsRate
prioListenerAdminDownstreamFilterClosedByRemoteConnectionsRate
prioListenerAdminDownstreamFilterReadErrorsRate
prioListenerAdminDownstreamActiveSocketsCount
prioListenerAdminDownstreamTimedOutSocketsRate
prioListenerDownstreamActiveConnectionsCount
prioListenerDownstreamConnectionsRate
prioListenerDownstreamDestroyedConnectionsRate
prioListenerDownstreamTimedOutConnectionsRate
prioListenerDownstreamRejectedConnectionsRate
prioListenerDownstreamFilterClosedByRemoteConnectionsRate
prioListenerDownstreamFilterReadErrorsRate
prioListenerDownstreamActiveSocketsCount
prioListenerDownstreamTimedOutSocketsRate
prioServerUptime
)
var (
serverChartsTmpl = module.Charts{
serverStateChartTmpl.Copy(),
serverMemoryAllocatedSizeChartTmpl.Copy(),
serverMemoryHeapSizeChartTmpl.Copy(),
serverMemoryPhysicalSizeChartTmpl.Copy(),
serverConnectionsCountChartTmpl.Copy(),
serverParentConnectionsCountChartTmpl.Copy(),
serverUptimeChartTmpl.Copy(),
}
serverStateChartTmpl = module.Chart{
ID: "server_state_%s",
Title: "Server current state",
Units: "state",
Fam: "server",
Ctx: "envoy.server_state",
Priority: prioServerState,
Dims: module.Dims{
{ID: "envoy_server_state_live_%s", Name: "live"},
{ID: "envoy_server_state_draining_%s", Name: "draining"},
{ID: "envoy_server_state_pre_initializing_%s", Name: "pre_initializing"},
{ID: "envoy_server_state_initializing_%s", Name: "initializing"},
},
}
serverConnectionsCountChartTmpl = module.Chart{
ID: "server_connections_%s",
Title: "Server current connections",
Units: "connections",
Fam: "server",
Ctx: "envoy.server_connections_count",
Priority: prioServerConnectionsCount,
Dims: module.Dims{
{ID: "envoy_server_total_connections_%s", Name: "connections"},
},
}
serverParentConnectionsCountChartTmpl = module.Chart{
ID: "server_parent_connections_%s",
Title: "Server current parent connections",
Units: "connections",
Fam: "server",
Ctx: "envoy.server_parent_connections_count",
Priority: prioServerParentConnectionsCount,
Dims: module.Dims{
{ID: "envoy_server_parent_connections_%s", Name: "connections"},
},
}
serverMemoryAllocatedSizeChartTmpl = module.Chart{
ID: "server_memory_allocated_size_%s",
Title: "Server memory allocated size",
Units: "bytes",
Fam: "server",
Ctx: "envoy.server_memory_allocated_size",
Priority: prioServerMemoryAllocatedSize,
Dims: module.Dims{
{ID: "envoy_server_memory_allocated_%s", Name: "allocated"},
},
}
serverMemoryHeapSizeChartTmpl = module.Chart{
ID: "server_memory_heap_size_%s",
Title: "Server memory heap size",
Units: "bytes",
Fam: "server",
Ctx: "envoy.server_memory_heap_size",
Priority: prioServerMemoryHeapSize,
Dims: module.Dims{
{ID: "envoy_server_memory_heap_size_%s", Name: "heap"},
},
}
serverMemoryPhysicalSizeChartTmpl = module.Chart{
ID: "server_memory_physical_size_%s",
Title: "Server memory physical size",
Units: "bytes",
Fam: "server",
Ctx: "envoy.server_memory_physical_size",
Priority: prioServerMemoryPhysicalSize,
Dims: module.Dims{
{ID: "envoy_server_memory_physical_size_%s", Name: "physical"},
},
}
serverUptimeChartTmpl = module.Chart{
ID: "server_uptime_%s",
Title: "Server uptime",
Units: "seconds",
Fam: "uptime",
Ctx: "envoy.server_uptime",
Priority: prioServerUptime,
Dims: module.Dims{
{ID: "envoy_server_uptime_%s", Name: "uptime"},
},
}
)
var (
clusterManagerChartsTmpl = module.Charts{
clusterManagerClusterCountChartTmpl.Copy(),
clusterManagerClusterChangesRateChartTmpl.Copy(),
clusterManagerClusterUpdatesRateChartTmpl.Copy(),
clusterManagerClusterUpdatesViaMergeRateChartTmpl.Copy(),
clusterManagerClusterUpdatesMergeCancelledRateChartTmpl.Copy(),
clusterManagerClusterUpdatesOutOfMergeWindowRateChartTmpl.Copy(),
}
clusterManagerClusterCountChartTmpl = module.Chart{
ID: "cluster_manager_cluster_count_%s",
Title: "Cluster manager current clusters",
Units: "clusters",
Fam: "cluster mgr",
Ctx: "envoy.cluster_manager_cluster_count",
Priority: prioClusterManagerClustersCount,
Dims: module.Dims{
{ID: "envoy_cluster_manager_active_clusters_%s", Name: "active"},
{ID: "envoy_cluster_manager_warming_clusters_%s", Name: "not_active"},
},
}
clusterManagerClusterChangesRateChartTmpl = module.Chart{
ID: "cluster_manager_cluster_changes_%s",
Title: "Cluster manager cluster changes",
Units: "clusters/s",
Fam: "cluster mgr",
Ctx: "envoy.cluster_manager_cluster_changes_rate",
Priority: prioClusterManagerClusterChangesRate,
Dims: module.Dims{
{ID: "envoy_cluster_manager_cluster_added_%s", Name: "added", Algo: module.Incremental},
{ID: "envoy_cluster_manager_cluster_modified_%s", Name: "modified", Algo: module.Incremental},
{ID: "envoy_cluster_manager_cluster_removed_%s", Name: "removed", Algo: module.Incremental},
},
}
clusterManagerClusterUpdatesRateChartTmpl = module.Chart{
ID: "cluster_manager_cluster_updates_%s",
Title: "Cluster manager updates",
Units: "updates/s",
Fam: "cluster mgr",
Ctx: "envoy.cluster_manager_cluster_updates_rate",
Priority: prioClusterManagerClusterUpdatesRate,
Dims: module.Dims{
{ID: "envoy_cluster_manager_cluster_updated_%s", Name: "cluster", Algo: module.Incremental},
},
}
clusterManagerClusterUpdatesViaMergeRateChartTmpl = module.Chart{
ID: "cluster_manager_cluster_updated_via_merge_%s",
Title: "Cluster manager updates applied as merged updates",
Units: "updates/s",
Fam: "cluster mgr",
Ctx: "envoy.cluster_manager_cluster_updated_via_merge_rate",
Priority: prioClusterManagerClusterUpdatesVieMergeRate,
Dims: module.Dims{
{ID: "envoy_cluster_manager_cluster_updated_via_merge_%s", Name: "via_merge", Algo: module.Incremental},
},
}
clusterManagerClusterUpdatesMergeCancelledRateChartTmpl = module.Chart{
ID: "cluster_manager_update_merge_cancelled_%s",
Title: "Cluster manager cancelled merged updates",
Units: "updates/s",
Fam: "cluster mgr",
Ctx: "envoy.cluster_manager_update_merge_cancelled_rate",
Priority: prioClusterManagerClusterUpdatesMergeCancelledRate,
Dims: module.Dims{
{ID: "envoy_cluster_manager_update_merge_cancelled_%s", Name: "merge_cancelled", Algo: module.Incremental},
},
}
clusterManagerClusterUpdatesOutOfMergeWindowRateChartTmpl = module.Chart{
ID: "cluster_manager_update_out_of_merge_window_%s",
Title: "Cluster manager out of a merge window updates",
Units: "updates/s",
Fam: "cluster mgr",
Ctx: "envoy.cluster_manager_update_out_of_merge_window_rate",
Priority: prioClusterManagerClusterUpdatesOufOfMergeWindowsRate,
Dims: module.Dims{
{ID: "envoy_cluster_manager_update_out_of_merge_window_%s", Name: "out_of_merge_window", Algo: module.Incremental},
},
}
)
var (
clusterUpstreamChartsTmpl = module.Charts{
clusterUpstreamActiveConnectionsCountChartTmpl.Copy(),
clusterUpstreamConnectionsRateChartTmpl.Copy(),
clusterUpstreamHTTPConnectionsRateChartTmpl.Copy(),
clusterUpstreamDestroyedConnectionsRateChartTmpl.Copy(),
clusterUpstreamFailedConnectionsRateChartTmpl.Copy(),
clusterUpstreamTimedOutConnectionsRateChartTmpl.Copy(),
clusterUpstreamTrafficRateChartTmpl.Copy(),
clusterUpstreamBufferedSizeChartTmpl.Copy(),
clusterUpstreamActiveRequestsCountChartTmpl.Copy(),
clusterUpstreamRequestsRateChartTmpl.Copy(),
clusterUpstreamFailedRequestsRateChartTmpl.Copy(),
clusterUpstreamActivePendingRequestsCountChartTmpl.Copy(),
clusterUpstreamPendingRequestsRateChartTmpl.Copy(),
clusterUpstreamPendingFailedRequestsRateChartTmpl.Copy(),
clusterUpstreamRequestRetriesRateChartTmpl.Copy(),
clusterUpstreamRequestSuccessRetriesRateChartTmpl.Copy(),
clusterUpstreamRequestRetriesBackoffRateChartTmpl.Copy(),
clusterMembershipEndpointsCountChartTmpl.Copy(),
clusterMembershipChangesRateChartTmpl.Copy(),
clusterMembershipUpdatesRateChartTmpl.Copy(),
}
clusterUpstreamActiveConnectionsCountChartTmpl = module.Chart{
ID: "cluster_upstream_cx_active_%s",
Title: "Cluster upstream current active connections",
Units: "connections",
Fam: "upstream conns",
Ctx: "envoy.cluster_upstream_cx_active_count",
Priority: prioClusterUpstreamActiveConnectionsCount,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_cx_active_%s", Name: "active"},
},
}
clusterUpstreamConnectionsRateChartTmpl = module.Chart{
ID: "cluster_upstream_cx_total_%s",
Title: "Cluster upstream connections",
Units: "connections/s",
Fam: "upstream conns",
Ctx: "envoy.cluster_upstream_cx_rate",
Priority: prioClusterUpstreamConnectionsRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_cx_total_%s", Name: "created", Algo: module.Incremental},
},
}
clusterUpstreamHTTPConnectionsRateChartTmpl = module.Chart{
ID: "cluster_upstream_cx_http_total_%s",
Title: "Cluster upstream connections by HTTP version",
Units: "connections/s",
Fam: "upstream conns",
Ctx: "envoy.cluster_upstream_cx_http_rate",
Priority: prioClusterUpstreamHTTPConnectionsRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_cx_http1_total_%s", Name: "http1", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_cx_http2_total_%s", Name: "http2", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_cx_http3_total_%s", Name: "http3", Algo: module.Incremental},
},
}
clusterUpstreamDestroyedConnectionsRateChartTmpl = module.Chart{
ID: "cluster_upstream_cx_destroy_%s",
Title: "Cluster upstream destroyed connections",
Units: "connections/s",
Fam: "upstream conns",
Ctx: "envoy.cluster_upstream_cx_destroy_rate",
Priority: prioClusterUpstreamDestroyedConnectionsRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_cx_destroy_local_%s", Name: "local", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_cx_destroy_remote_%s", Name: "remote", Algo: module.Incremental},
},
}
clusterUpstreamFailedConnectionsRateChartTmpl = module.Chart{
ID: "cluster_upstream_cx_connect_fail_%s",
Title: "Cluster upstream failed connections",
Units: "connections/s",
Fam: "upstream conns",
Ctx: "envoy.cluster_upstream_cx_connect_fail_rate",
Priority: prioClusterUpstreamFailedConnectionsRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_cx_connect_fail_%s", Name: "failed", Algo: module.Incremental},
},
}
clusterUpstreamTimedOutConnectionsRateChartTmpl = module.Chart{
ID: "cluster_upstream_cx_connect_timeout_%s",
Title: "Cluster upstream timed out connections",
Units: "connections/s",
Fam: "upstream conns",
Ctx: "envoy.cluster_upstream_cx_connect_timeout_rate",
Priority: prioClusterUpstreamTimedOutConnectionsRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_cx_connect_timeout_%s", Name: "timeout", Algo: module.Incremental},
},
}
clusterUpstreamTrafficRateChartTmpl = module.Chart{
ID: "cluster_upstream_cx_bytes_total_%s",
Title: "Cluster upstream connection traffic",
Units: "bytes/s",
Fam: "upstream traffic",
Ctx: "envoy.cluster_upstream_cx_bytes_rate",
Priority: prioClusterUpstreamTrafficRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_cx_rx_bytes_total_%s", Name: "received", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_cx_tx_bytes_total_%s", Name: "sent", Algo: module.Incremental},
},
}
clusterUpstreamBufferedSizeChartTmpl = module.Chart{
ID: "cluster_upstream_cx_bytes_buffered_%s",
Title: "Cluster upstream current connection buffered size",
Units: "bytes",
Fam: "upstream traffic",
Ctx: "envoy.cluster_upstream_cx_bytes_buffered_size",
Priority: prioClusterUpstreamBufferedSize,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_cx_rx_bytes_buffered_%s", Name: "received"},
{ID: "envoy_cluster_upstream_cx_tx_bytes_buffered_%s", Name: "send"},
},
}
clusterUpstreamActiveRequestsCountChartTmpl = module.Chart{
ID: "cluster_upstream_rq_active_%s",
Title: "Cluster upstream current active requests",
Units: "requests",
Fam: "upstream requests",
Ctx: "envoy.cluster_upstream_rq_active_count",
Priority: prioClusterUpstreamActiveRequestsCount,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_rq_active_%s", Name: "active"},
},
}
clusterUpstreamRequestsRateChartTmpl = module.Chart{
ID: "cluster_upstream_rq_total_%s",
Title: "Cluster upstream requests",
Units: "requests/s",
Fam: "upstream requests",
Ctx: "envoy.cluster_upstream_rq_rate",
Priority: prioClusterUpstreamRequestsRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_rq_total_%s", Name: "requests", Algo: module.Incremental},
},
}
clusterUpstreamFailedRequestsRateChartTmpl = module.Chart{
ID: "cluster_upstream_rq_failed_total_%s",
Title: "Cluster upstream failed requests",
Units: "requests/s",
Fam: "upstream requests",
Ctx: "envoy.cluster_upstream_rq_failed_rate",
Priority: prioClusterUpstreamFailedRequestsRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_rq_cancelled_%s", Name: "cancelled", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_rq_maintenance_mode_%s", Name: "maintenance_mode", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_rq_timeout_%s", Name: "timeout", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_rq_max_duration_reached_%s", Name: "max_duration_reached", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_rq_per_try_timeout_%s", Name: "per_try_timeout", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_rq_rx_reset_%s", Name: "reset_local", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_rq_tx_reset_%s", Name: "reset_remote", Algo: module.Incremental},
},
}
clusterUpstreamActivePendingRequestsCountChartTmpl = module.Chart{
ID: "cluster_upstream_rq_pending_active_%s",
Title: "Cluster upstream current active pending requests",
Units: "requests",
Fam: "upstream requests",
Ctx: "envoy.cluster_upstream_rq_pending_active_count",
Priority: prioClusterUpstreamActivePendingRequestsCount,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_rq_pending_active_%s", Name: "active_pending"},
},
}
clusterUpstreamPendingRequestsRateChartTmpl = module.Chart{
ID: "cluster_upstream_rq_pending_total_%s",
Title: "Cluster upstream pending requests",
Units: "requests/s",
Fam: "upstream requests",
Ctx: "envoy.cluster_upstream_rq_pending_rate",
Priority: prioClusterUpstreamPendingRequestsRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_rq_pending_total_%s", Name: "pending", Algo: module.Incremental},
},
}
clusterUpstreamPendingFailedRequestsRateChartTmpl = module.Chart{
ID: "cluster_upstream_rq_pending_failed_total_%s",
Title: "Cluster upstream failed pending requests",
Units: "requests/s",
Fam: "upstream requests",
Ctx: "envoy.cluster_upstream_rq_pending_failed_rate",
Priority: prioClusterUpstreamPendingFailedRequestsRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_rq_pending_overflow_%s", Name: "overflow", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_rq_pending_failure_eject_%s", Name: "failure_eject", Algo: module.Incremental},
},
}
clusterUpstreamRequestRetriesRateChartTmpl = module.Chart{
ID: "cluster_upstream_rq_retry_%s",
Title: "Cluster upstream request retries",
Units: "retries/s",
Fam: "upstream requests",
Ctx: "envoy.cluster_upstream_rq_retry_rate",
Priority: prioClusterUpstreamRequestRetriesRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_rq_retry_%s", Name: "request", Algo: module.Incremental},
},
}
clusterUpstreamRequestSuccessRetriesRateChartTmpl = module.Chart{
ID: "cluster_upstream_rq_retry_success_%s",
Title: "Cluster upstream request successful retries",
Units: "retries/s",
Fam: "upstream requests",
Ctx: "envoy.cluster_upstream_rq_retry_success_rate",
Priority: prioClusterUpstreamRequestSuccessRetriesRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_rq_retry_success_%s", Name: "success", Algo: module.Incremental},
},
}
clusterUpstreamRequestRetriesBackoffRateChartTmpl = module.Chart{
ID: "cluster_upstream_rq_retry_backoff_%s",
Title: "Cluster upstream request backoff retries",
Units: "retries/s",
Fam: "upstream requests",
Ctx: "envoy.cluster_upstream_rq_retry_backoff_rate",
Priority: prioClusterUpstreamRequestBackoffRetriesRate,
Dims: module.Dims{
{ID: "envoy_cluster_upstream_rq_retry_backoff_exponential_%s", Name: "exponential", Algo: module.Incremental},
{ID: "envoy_cluster_upstream_rq_retry_backoff_ratelimited_%s", Name: "ratelimited", Algo: module.Incremental},
},
}
clusterMembershipEndpointsCountChartTmpl = module.Chart{
ID: "cluster_membership_endpoints_count_%s",
Title: "Cluster membership current endpoints",
Units: "endpoints",
Fam: "cluster membership",
Ctx: "envoy.cluster_membership_endpoints_count",
Priority: prioClusterMembershipEndpointsCount,
Dims: module.Dims{
{ID: "envoy_cluster_membership_healthy_%s", Name: "healthy"},
{ID: "envoy_cluster_membership_degraded_%s", Name: "degraded"},
{ID: "envoy_cluster_membership_excluded_%s", Name: "excluded"},
},
}
clusterMembershipChangesRateChartTmpl = module.Chart{
ID: "cluster_membership_change_%s",
Title: "Cluster membership changes",
Units: "changes/s",
Fam: "cluster membership",
Ctx: "envoy.cluster_membership_changes_rate",
Priority: prioClusterMembershipChangesRate,
Dims: module.Dims{
{ID: "envoy_cluster_membership_change_%s", Name: "membership", Algo: module.Incremental},
},
}
clusterMembershipUpdatesRateChartTmpl = module.Chart{
ID: "cluster_membership_updates_%s",
Title: "Cluster membership updates",
Units: "updates/s",
Fam: "cluster membership",
Ctx: "envoy.cluster_membership_updates_rate",
Priority: prioClusterMembershipUpdatesRate,
Dims: module.Dims{
{ID: "envoy_cluster_update_success_%s", Name: "success", Algo: module.Incremental},
{ID: "envoy_cluster_update_failure_%s", Name: "failure", Algo: module.Incremental},
{ID: "envoy_cluster_update_empty_%s", Name: "empty", Algo: module.Incremental},
{ID: "envoy_cluster_update_no_rebuild_%s", Name: "no_rebuild", Algo: module.Incremental},
},
}
)
var (
listenerManagerChartsTmpl = module.Charts{
listenerManagerListenersByStateCountChartTmpl.Copy(),
listenerManagerListenerChangesRateChartTmpl.Copy(),
listenerManagerListenerObjectEventsRateChartTmpl.Copy(),
}
listenerManagerListenersByStateCountChartTmpl = module.Chart{
ID: "listener_manager_listeners_count_%s",
Title: "Listener manager current listeners",
Units: "listeners",
Fam: "downstream mgr",
Ctx: "envoy.listener_manager_listeners_count",
Priority: prioListenerManagerListenerCount,
Dims: module.Dims{
{ID: "envoy_listener_manager_total_listeners_active_%s", Name: "active"},
{ID: "envoy_listener_manager_total_listeners_warming_%s", Name: "warming"},
{ID: "envoy_listener_manager_total_listeners_draining_%s", Name: "draining"},
},
}
listenerManagerListenerChangesRateChartTmpl = module.Chart{
ID: "listener_manager_listener_changes_%s",
Title: "Listener manager listener changes",
Units: "listeners/s",
Fam: "downstream mgr",
Ctx: "envoy.listener_manager_listener_changes_rate",
Priority: prioListenerManagerListenerChangesRate,
Dims: module.Dims{
{ID: "envoy_listener_manager_listener_added_%s", Name: "added", Algo: module.Incremental},
{ID: "envoy_listener_manager_listener_modified_%s", Name: "modified", Algo: module.Incremental},
{ID: "envoy_listener_manager_listener_removed_%s", Name: "removed", Algo: module.Incremental},
{ID: "envoy_listener_manager_listener_stopped_%s", Name: "stopped", Algo: module.Incremental},
},
}
listenerManagerListenerObjectEventsRateChartTmpl = module.Chart{
ID: "listener_manager_listener_object_events_%s",
Title: "Listener manager listener object events",
Units: "objects/s",
Fam: "downstream mgr",
Ctx: "envoy.listener_manager_listener_object_events_rate",
Priority: prioListenerManagerListenerObjectEventsRate,
Dims: module.Dims{
{ID: "envoy_listener_manager_listener_create_success_%s", Name: "create_success", Algo: module.Incremental},
{ID: "envoy_listener_manager_listener_create_failure_%s", Name: "create_failure", Algo: module.Incremental},
{ID: "envoy_listener_manager_listener_in_place_updated_%s", Name: "in_place_updated", Algo: module.Incremental},
},
}
)
var (
listenerAdminDownstreamChartsTmpl = module.Charts{
listenerAdminDownstreamActiveConnectionsCountChartTmpl.Copy(),
listenerAdminDownstreamConnectionsRateChartTmpl.Copy(),
listenerAdminDownstreamDestroyedConnectionsRateChartTmpl.Copy(),
listenerAdminDownstreamTimedOutConnectionsRateChartTmpl.Copy(),
listenerAdminDownstreamRejectedConnectionsRateChartTmpl.Copy(),
listenerAdminDownstreamFilterClosedByRemoteConnectionsRateChartTmpl.Copy(),
listenerAdminDownstreamFilterReadErrorsRateChartTmpl.Copy(),
listenerAdminDownstreamActiveSocketsCountChartTmpl.Copy(),
listenerAdminDownstreamTimedOutSocketsRateChartTmpl.Copy(),
}
listenerAdminDownstreamActiveConnectionsCountChartTmpl = module.Chart{
ID: "listener_admin_downstream_cx_active_%s",
Title: "Listener admin downstream current active connections",
Units: "connections",
Fam: "downstream adm conns",
Ctx: "envoy.listener_admin_downstream_cx_active_count",
Priority: prioListenerAdminDownstreamActiveConnectionsCount,
Dims: module.Dims{
{ID: "envoy_listener_admin_downstream_cx_active_%s", Name: "active"},
},
}
listenerAdminDownstreamConnectionsRateChartTmpl = module.Chart{
ID: "listener_admin_downstream_cx_total_%s",
Title: "Listener admin downstream connections",
Units: "connections/s",
Fam: "downstream adm conns",
Ctx: "envoy.listener_admin_downstream_cx_rate",
Priority: prioListenerAdminDownstreamConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_admin_downstream_cx_total_%s", Name: "created", Algo: module.Incremental},
},
}
listenerAdminDownstreamDestroyedConnectionsRateChartTmpl = module.Chart{
ID: "listener_admin_downstream_cx_destroy_%s",
Title: "Listener admin downstream destroyed connections",
Units: "connections/s",
Fam: "downstream adm conns",
Ctx: "envoy.listener_admin_downstream_cx_destroy_rate",
Priority: prioListenerAdminDownstreamDestroyedConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_admin_downstream_cx_destroy_%s", Name: "destroyed", Algo: module.Incremental},
},
}
listenerAdminDownstreamTimedOutConnectionsRateChartTmpl = module.Chart{
ID: "listener_admin_downstream_cx_transport_socket_connect_timeout_%s",
Title: "Listener admin downstream timed out connections",
Units: "connections/s",
Fam: "downstream adm conns",
Ctx: "envoy.listener_admin_downstream_cx_transport_socket_connect_timeout_rate",
Priority: prioListenerAdminDownstreamTimedOutConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_admin_downstream_cx_transport_socket_connect_timeout_%s", Name: "timeout", Algo: module.Incremental},
},
}
listenerAdminDownstreamRejectedConnectionsRateChartTmpl = module.Chart{
ID: "listener_admin_downstream_cx_rejected_%s",
Title: "Listener admin downstream rejected connections",
Units: "connections/s",
Fam: "downstream adm conns",
Ctx: "envoy.listener_admin_downstream_cx_rejected_rate",
Priority: prioListenerAdminDownstreamRejectedConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_admin_downstream_cx_overflow_%s", Name: "overflow", Algo: module.Incremental},
{ID: "envoy_listener_admin_downstream_cx_overload_reject_%s", Name: "overload", Algo: module.Incremental},
{ID: "envoy_listener_admin_downstream_global_cx_overflow_%s", Name: "global_overflow", Algo: module.Incremental},
},
}
listenerAdminDownstreamFilterClosedByRemoteConnectionsRateChartTmpl = module.Chart{
ID: "listener_admin_downstream_listener_filter_remote_close_%s",
Title: "Listener admin downstream connections closed by remote when peek data for listener filters",
Units: "connections/s",
Fam: "downstream adm conns",
Ctx: "envoy.listener_admin_downstream_listener_filter_remote_close_rate",
Priority: prioListenerAdminDownstreamFilterClosedByRemoteConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_admin_downstream_listener_filter_remote_close_%s", Name: "closed", Algo: module.Incremental},
},
}
listenerAdminDownstreamFilterReadErrorsRateChartTmpl = module.Chart{
ID: "listener_admin_downstream_listener_filter_error_%s",
Title: "Listener admin downstream read errors when peeking data for listener filters",
Units: "errors/s",
Fam: "downstream adm conns",
Ctx: "envoy.listener_admin_downstream_listener_filter_error_rate",
Priority: prioListenerAdminDownstreamFilterReadErrorsRate,
Dims: module.Dims{
{ID: "envoy_listener_admin_downstream_listener_filter_error_%s", Name: "read", Algo: module.Incremental},
},
}
listenerAdminDownstreamActiveSocketsCountChartTmpl = module.Chart{
ID: "listener_admin_downstream_pre_cx_active_%s",
Title: "Listener admin downstream current active sockets",
Units: "sockets",
Fam: "downstream adm sockets",
Ctx: "envoy.listener_admin_downstream_pre_cx_active_count",
Priority: prioListenerAdminDownstreamActiveSocketsCount,
Dims: module.Dims{
{ID: "envoy_listener_admin_downstream_pre_cx_active_%s", Name: "active"},
},
}
listenerAdminDownstreamTimedOutSocketsRateChartTmpl = module.Chart{
ID: "listener_admin_downstream_pre_cx_timeout_%s",
Title: "Listener admin downstream timed out sockets",
Units: "sockets/s",
Fam: "downstream adm sockets",
Ctx: "envoy.listener_admin_downstream_pre_cx_timeout_rate",
Priority: prioListenerAdminDownstreamTimedOutSocketsRate,
Dims: module.Dims{
{ID: "envoy_listener_admin_downstream_pre_cx_timeout_%s", Name: "timeout", Algo: module.Incremental},
},
}
)
var (
listenerDownstreamChartsTmpl = module.Charts{
listenerDownstreamActiveConnectionsCountChartTmpl.Copy(),
listenerDownstreamConnectionsRateChartTmpl.Copy(),
listenerDownstreamDestroyedConnectionsRateChartTmpl.Copy(),
listenerDownstreamTimedOutConnectionsRateChartTmpl.Copy(),
listenerDownstreamRejectedConnectionsRateChartTmpl.Copy(),
listenerDownstreamFilterClosedByRemoteConnectionsRateChartTmpl.Copy(),
listenerDownstreamFilterReadErrorsRateChartTmpl.Copy(),
listenerDownstreamActiveSocketsCountChartTmpl.Copy(),
listenerDownstreamTimedOutSocketsRateChartTmpl.Copy(),
}
listenerDownstreamActiveConnectionsCountChartTmpl = module.Chart{
ID: "listener_downstream_cx_active_%s",
Title: "Listener downstream current active connections",
Units: "connections",
Fam: "downstream conns",
Ctx: "envoy.listener_downstream_cx_active_count",
Priority: prioListenerDownstreamActiveConnectionsCount,
Dims: module.Dims{
{ID: "envoy_listener_downstream_cx_active_%s", Name: "active"},
},
}
listenerDownstreamConnectionsRateChartTmpl = module.Chart{
ID: "listener_downstream_cx_total_%s",
Title: "Listener downstream connections",
Units: "connections/s",
Fam: "downstream conns",
Ctx: "envoy.listener_downstream_cx_rate",
Priority: prioListenerDownstreamConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_downstream_cx_total_%s", Name: "created", Algo: module.Incremental},
},
}
listenerDownstreamDestroyedConnectionsRateChartTmpl = module.Chart{
ID: "listener_downstream_cx_destroy_%s",
Title: "Listener downstream destroyed connections",
Units: "connections/s",
Fam: "downstream conns",
Ctx: "envoy.listener_downstream_cx_destroy_rate",
Priority: prioListenerDownstreamDestroyedConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_downstream_cx_destroy_%s", Name: "destroyed", Algo: module.Incremental},
},
}
listenerDownstreamTimedOutConnectionsRateChartTmpl = module.Chart{
ID: "listener_downstream_cx_transport_socket_connect_timeout_%s",
Title: "Listener downstream timed out connections",
Units: "connections/s",
Fam: "downstream conns",
Ctx: "envoy.listener_downstream_cx_transport_socket_connect_timeout_rate",
Priority: prioListenerDownstreamTimedOutConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_downstream_cx_transport_socket_connect_timeout_%s", Name: "timeout", Algo: module.Incremental},
},
}
listenerDownstreamRejectedConnectionsRateChartTmpl = module.Chart{
ID: "listener_downstream_cx_rejected_%s",
Title: "Listener downstream rejected connections",
Units: "connections/s",
Fam: "downstream conns",
Ctx: "envoy.listener_downstream_cx_rejected_rate",
Priority: prioListenerDownstreamRejectedConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_downstream_cx_overflow_%s", Name: "overflow", Algo: module.Incremental},
{ID: "envoy_listener_downstream_cx_overload_reject_%s", Name: "overload", Algo: module.Incremental},
{ID: "envoy_listener_downstream_global_cx_overflow_%s", Name: "global_overflow", Algo: module.Incremental},
},
}
listenerDownstreamFilterClosedByRemoteConnectionsRateChartTmpl = module.Chart{
ID: "listener_downstream_listener_filter_remote_close_%s",
Title: "Listener downstream connections closed by remote when peek data for listener filters",
Units: "connections/s",
Fam: "downstream conns",
Ctx: "envoy.listener_downstream_listener_filter_remote_close_rate",
Priority: prioListenerDownstreamFilterClosedByRemoteConnectionsRate,
Dims: module.Dims{
{ID: "envoy_listener_downstream_listener_filter_remote_close_%s", Name: "closed", Algo: module.Incremental},
},
}
listenerDownstreamFilterReadErrorsRateChartTmpl = module.Chart{
ID: "listener_downstream_listener_filter_error_%s",
Title: "Listener downstream read errors when peeking data for listener filters",
Units: "errors/s",
Fam: "downstream conns",
Ctx: "envoy.listener_downstream_listener_filter_error_rate",
Priority: prioListenerDownstreamFilterReadErrorsRate,
Dims: module.Dims{
{ID: "envoy_listener_downstream_listener_filter_error_%s", Name: "read", Algo: module.Incremental},
},
}
listenerDownstreamActiveSocketsCountChartTmpl = module.Chart{
ID: "listener_downstream_pre_cx_active_%s",
Title: "Listener downstream current active sockets",
Units: "sockets",
Fam: "downstream sockets",
Ctx: "envoy.listener_downstream_pre_cx_active_count",
Priority: prioListenerDownstreamActiveSocketsCount,
Dims: module.Dims{
{ID: "envoy_listener_downstream_pre_cx_active_%s", Name: "active"},
},
}
listenerDownstreamTimedOutSocketsRateChartTmpl = module.Chart{
ID: "listener_downstream_pre_cx_timeout_%s",
Title: "Listener downstream timed out sockets",
Units: "sockets/s",
Fam: "downstream sockets",
Ctx: "envoy.listener_downstream_pre_cx_timeout_rate",
Priority: prioListenerDownstreamTimedOutSocketsRate,
Dims: module.Dims{
{ID: "envoy_listener_downstream_pre_cx_timeout_%s", Name: "timeout", Algo: module.Incremental},
},
}
)
func (e *Envoy) addServerCharts(id string, labels labels.Labels) {
e.addCharts(serverChartsTmpl.Copy(), id, labels)
}
func (e *Envoy) addClusterManagerCharts(id string, labels labels.Labels) {
e.addCharts(clusterManagerChartsTmpl.Copy(), id, labels)
}
func (e *Envoy) addClusterUpstreamCharts(id string, labels labels.Labels) {
e.addCharts(clusterUpstreamChartsTmpl.Copy(), id, labels)
}
func (e *Envoy) addListenerManagerCharts(id string, labels labels.Labels) {
e.addCharts(listenerManagerChartsTmpl.Copy(), id, labels)
}
func (e *Envoy) addListenerAdminDownstreamCharts(id string, labels labels.Labels) {
e.addCharts(listenerAdminDownstreamChartsTmpl.Copy(), id, labels)
}
func (e *Envoy) addListenerDownstreamCharts(id string, labels labels.Labels) {
e.addCharts(listenerDownstreamChartsTmpl.Copy(), id, labels)
}
func (e *Envoy) addCharts(charts *module.Charts, id string, labels labels.Labels) {
charts = charts.Copy()
for _, chart := range *charts {
if id == "" {
chart.ID = strings.Replace(chart.ID, "_%s", "", 1)
for _, dim := range chart.Dims {
dim.ID = strings.Replace(dim.ID, "_%s", "", 1)
}
} else {
chart.ID = fmt.Sprintf(chart.ID, dotReplacer.Replace(id))
for _, dim := range chart.Dims {
dim.ID = fmt.Sprintf(dim.ID, id)
}
}
for _, lbl := range labels {
chart.Labels = append(chart.Labels, module.Label{Key: lbl.Name, Value: lbl.Value})
}
}
if err := e.Charts().Add(*charts...); err != nil {
e.Warning(err)
}
}
func (e *Envoy) removeCharts(id string) {
if id == "" {
return
}
id = dotReplacer.Replace(id)
for _, chart := range *e.Charts() {
if strings.HasSuffix(chart.ID, id) {
chart.MarkRemove()
chart.MarkNotCreated()
}
}
}
var dotReplacer = strings.NewReplacer(".", "_")