1 files changed, 461 insertions, 0 deletions
diff --git a/src/go/collectors/go.d.plugin/modules/cassandra/charts.go b/src/go/collectors/go.d.plugin/modules/cassandra/charts.go
new file mode 100644
index 000000000..8c3fc239a
--- /dev/null
+++ b/src/go/collectors/go.d.plugin/modules/cassandra/charts.go
@@ -0,0 +1,461 @@
+// SPDX-License-Identifier: GPL-3.0-or-later
+
+package cassandra
+
+import (
+	"fmt"
+
+	"github.com/netdata/netdata/go/go.d.plugin/agent/module"
+)
+
+const (
+	prioClientRequestsRate = module.Priority + iota
+
+	prioClientRequestReadLatency
+	prioClientRequestWriteLatency
+	prioClientRequestsLatency
+
+	prioKeyCacheHitRatio
+	prioRowCacheHitRatio
+	prioKeyCacheHitRate
+	prioRowCacheHitRate
+	prioKeyCacheUtilization
+	prioRowCacheUtilization
+	prioKeyCacheSize
+	prioRowCacheSize
+
+	prioStorageLiveDiskSpaceUsed
+
+	prioCompactionCompletedTasksRate
+	prioCompactionPendingTasksCount
+	prioCompactionBytesCompactedRate
+
+	prioThreadPoolActiveTasksCount
+	prioThreadPoolPendingTasksCount
+	prioThreadPoolBlockedTasksCount
+	prioThreadPoolBlockedTasksRate
+
+	prioJVMMemoryUsed
+	prioJVMGCCount
+	prioJVMGCTime
+
+	prioDroppedMessagesRate
+	prioRequestsTimeoutsRate
+	prioRequestsUnavailablesRate
+	prioRequestsFailuresRate
+	prioStorageExceptionsRate
+)
+
+var baseCharts = module.Charts{
+	chartClientRequestsRate.Copy(),
+
+	chartClientRequestsLatency.Copy(),
+	chartClientRequestReadLatencyHistogram.Copy(),
+	chartClientRequestWriteLatencyHistogram.Copy(),
+
+	chartKeyCacheHitRatio.Copy(),
+	chartRowCacheHitRatio.Copy(),
+	chartKeyCacheHitRate.Copy(),
+	chartRowCacheHitRate.Copy(),
+	chartKeyCacheUtilization.Copy(),
+	chartRowCacheUtilization.Copy(),
+	chartKeyCacheSize.Copy(),
+	chartRowCacheSize.Copy(),
+
+	chartStorageLiveDiskSpaceUsed.Copy(),
+
+	chartCompactionCompletedTasksRate.Copy(),
+	chartCompactionPendingTasksCount.Copy(),
+	chartCompactionBytesCompactedRate.Copy(),
+
+	chartJVMMemoryUsed.Copy(),
+	chartJVMGCRate.Copy(),
+	chartJVMGCTime.Copy(),
+
+	chartDroppedMessagesRate.Copy(),
+	chartClientRequestTimeoutsRate.Copy(),
+	chartClientRequestUnavailablesRate.Copy(),
+	chartClientRequestFailuresRate.Copy(),
+	chartStorageExceptionsRate.Copy(),
+}
+
+var (
+	chartClientRequestsRate = module.Chart{
+		ID:       "client_requests_rate",
+		Title:    "Client requests rate",
+		Units:    "requests/s",
+		Fam:      "throughput",
+		Ctx:      "cassandra.client_requests_rate",
+		Priority: prioClientRequestsRate,
+		Dims: module.Dims{
+			{ID: "client_request_latency_reads", Name: "read", Algo: module.Incremental},
+			{ID: "client_request_latency_writes", Name: "write", Algo: module.Incremental, Mul: -1},
+		},
+	}
+)
+
+var (
+	chartClientRequestReadLatencyHistogram = module.Chart{
+		ID:       "client_request_read_latency_histogram",
+		Title:    "Client request read latency histogram",
+		Units:    "seconds",
+		Fam:      "latency",
+		Ctx:      "cassandra.client_request_read_latency_histogram",
+		Priority: prioClientRequestReadLatency,
+		Dims: module.Dims{
+			{ID: "client_request_read_latency_p50", Name: "p50", Div: 1e6},
+			{ID: "client_request_read_latency_p75", Name: "p75", Div: 1e6},
+			{ID: "client_request_read_latency_p95", Name: "p95", Div: 1e6},
+			{ID: "client_request_read_latency_p98", Name: "p98", Div: 1e6},
+			{ID: "client_request_read_latency_p99", Name: "p99", Div: 1e6},
+			{ID: "client_request_read_latency_p999", Name: "p999", Div: 1e6},
+		},
+	}
+	chartClientRequestWriteLatencyHistogram = module.Chart{
+		ID:       "client_request_write_latency_histogram",
+		Title:    "Client request write latency histogram",
+		Units:    "seconds",
+		Fam:      "latency",
+		Ctx:      "cassandra.client_request_write_latency_histogram",
+		Priority: prioClientRequestWriteLatency,
+		Dims: module.Dims{
+			{ID: "client_request_write_latency_p50", Name: "p50", Div: 1e6},
+			{ID: "client_request_write_latency_p75", Name: "p75", Div: 1e6},
+			{ID: "client_request_write_latency_p95", Name: "p95", Div: 1e6},
+			{ID: "client_request_write_latency_p98", Name: "p98", Div: 1e6},
+			{ID: "client_request_write_latency_p99", Name: "p99", Div: 1e6},
+			{ID: "client_request_write_latency_p999", Name: "p999", Div: 1e6},
+		},
+	}
+	chartClientRequestsLatency = module.Chart{
+		ID:       "client_requests_latency",
+		Title:    "Client requests total latency",
+		Units:    "seconds",
+		Fam:      "latency",
+		Ctx:      "cassandra.client_requests_latency",
+		Priority: prioClientRequestsLatency,
+		Dims: module.Dims{
+			{ID: "client_request_total_latency_reads", Name: "read", Algo: module.Incremental, Div: 1e6},
+			{ID: "client_request_total_latency_writes", Name: "write", Algo: module.Incremental, Div: 1e6},
+		},
+	}
+)
+
+var (
+	chartKeyCacheHitRatio = module.Chart{
+		ID:       "key_cache_hit_ratio",
+		Title:    "Key cache hit ratio",
+		Units:    "percentage",
+		Fam:      "cache",
+		Ctx:      "cassandra.key_cache_hit_ratio",
+		Priority: prioKeyCacheHitRatio,
+		Dims: module.Dims{
+			{ID: "key_cache_hit_ratio", Name: "hit_ratio", Div: 1000},
+		},
+	}
+	chartKeyCacheHitRate = module.Chart{
+		ID:       "key_cache_hit_rate",
+		Title:    "Key cache hit rate",
+		Units:    "events/s",
+		Fam:      "cache",
+		Ctx:      "cassandra.key_cache_hit_rate",
+		Priority: prioKeyCacheHitRate,
+		Type:     module.Stacked,
+		Dims: module.Dims{
+			{ID: "key_cache_hits", Name: "hits", Algo: module.Incremental},
+			{ID: "key_cache_misses", Name: "misses", Algo: module.Incremental},
+		},
+	}
+	chartKeyCacheUtilization = module.Chart{
+		ID:       "key_cache_utilization",
+		Title:    "Key cache utilization",
+		Units:    "percentage",
+		Fam:      "cache",
+		Ctx:      "cassandra.key_cache_utilization",
+		Priority: prioKeyCacheUtilization,
+		Dims: module.Dims{
+			{ID: "key_cache_utilization", Name: "used", Div: 1000},
+		},
+	}
+	chartKeyCacheSize = module.Chart{
+		ID:       "key_cache_size",
+		Title:    "Key cache size",
+		Units:    "bytes",
+		Fam:      "cache",
+		Ctx:      "cassandra.key_cache_size",
+		Priority: prioKeyCacheSize,
+		Dims: module.Dims{
+			{ID: "key_cache_size", Name: "size"},
+		},
+	}
+
+	chartRowCacheHitRatio = module.Chart{
+		ID:       "row_cache_hit_ratio",
+		Title:    "Row cache hit ratio",
+		Units:    "percentage",
+		Fam:      "cache",
+		Ctx:      "cassandra.row_cache_hit_ratio",
+		Priority: prioRowCacheHitRatio,
+		Dims: module.Dims{
+			{ID: "row_cache_hit_ratio", Name: "hit_ratio", Div: 1000},
+		},
+	}
+	chartRowCacheHitRate = module.Chart{
+		ID:       "row_cache_hit_rate",
+		Title:    "Row cache hit rate",
+		Units:    "events/s",
+		Fam:      "cache",
+		Ctx:      "cassandra.row_cache_hit_rate",
+		Priority: prioRowCacheHitRate,
+		Type:     module.Stacked,
+		Dims: module.Dims{
+			{ID: "row_cache_hits", Name: "hits", Algo: module.Incremental},
+			{ID: "row_cache_misses", Name: "misses", Algo: module.Incremental},
+		},
+	}
+	chartRowCacheUtilization = module.Chart{
+		ID:       "row_cache_utilization",
+		Title:    "Row cache utilization",
+		Units:    "percentage",
+		Fam:      "cache",
+		Ctx:      "cassandra.row_cache_utilization",
+		Priority: prioRowCacheUtilization,
+		Dims: module.Dims{
+			{ID: "row_cache_utilization", Name: "used", Div: 1000},
+		},
+	}
+	chartRowCacheSize = module.Chart{
+		ID:       "row_cache_size",
+		Title:    "Row cache size",
+		Units:    "bytes",
+		Fam:      "cache",
+		Ctx:      "cassandra.row_cache_size",
+		Priority: prioRowCacheSize,
+		Dims: module.Dims{
+			{ID: "row_cache_size", Name: "size"},
+		},
+	}
+)
+
+var (
+	chartStorageLiveDiskSpaceUsed = module.Chart{
+		ID:       "storage_live_disk_space_used",
+		Title:    "Disk space used by live data",
+		Units:    "bytes",
+		Fam:      "disk usage",
+		Ctx:      "cassandra.storage_live_disk_space_used",
+		Priority: prioStorageLiveDiskSpaceUsed,
+		Dims: module.Dims{
+			{ID: "storage_load", Name: "used"},
+		},
+	}
+)
+
+var (
+	chartCompactionCompletedTasksRate = module.Chart{
+		ID:       "compaction_completed_tasks_rate",
+		Title:    "Completed compactions rate",
+		Units:    "tasks/s",
+		Fam:      "compaction",
+		Ctx:      "cassandra.compaction_completed_tasks_rate",
+		Priority: prioCompactionCompletedTasksRate,
+		Dims: module.Dims{
+			{ID: "compaction_completed_tasks", Name: "completed", Algo: module.Incremental},
+		},
+	}
+	chartCompactionPendingTasksCount = module.Chart{
+		ID:       "compaction_pending_tasks_count",
+		Title:    "Pending compactions",
+		Units:    "tasks",
+		Fam:      "compaction",
+		Ctx:      "cassandra.compaction_pending_tasks_count",
+		Priority: prioCompactionPendingTasksCount,
+		Dims: module.Dims{
+			{ID: "compaction_pending_tasks", Name: "pending"},
+		},
+	}
+	chartCompactionBytesCompactedRate = module.Chart{
+		ID:       "compaction_compacted_rate",
+		Title:    "Compaction data rate",
+		Units:    "bytes/s",
+		Fam:      "compaction",
+		Ctx:      "cassandra.compaction_compacted_rate",
+		Priority: prioCompactionBytesCompactedRate,
+		Dims: module.Dims{
+			{ID: "compaction_bytes_compacted", Name: "compacted", Algo: module.Incremental},
+		},
+	}
+)
+
+var (
+	chartsTmplThreadPool = module.Charts{
+		chartTmplThreadPoolActiveTasksCount.Copy(),
+		chartTmplThreadPoolPendingTasksCount.Copy(),
+		chartTmplThreadPoolBlockedTasksCount.Copy(),
+		chartTmplThreadPoolBlockedTasksRate.Copy(),
+	}
+
+	chartTmplThreadPoolActiveTasksCount = module.Chart{
+		ID:       "thread_pool_%s_active_tasks_count",
+		Title:    "Active tasks",
+		Units:    "tasks",
+		Fam:      "thread pools",
+		Ctx:      "cassandra.thread_pool_active_tasks_count",
+		Priority: prioThreadPoolActiveTasksCount,
+		Dims: module.Dims{
+			{ID: "thread_pool_%s_active_tasks", Name: "active"},
+		},
+	}
+	chartTmplThreadPoolPendingTasksCount = module.Chart{
+		ID:       "thread_pool_%s_pending_tasks_count",
+		Title:    "Pending tasks",
+		Units:    "tasks",
+		Fam:      "thread pools",
+		Ctx:      "cassandra.thread_pool_pending_tasks_count",
+		Priority: prioThreadPoolPendingTasksCount,
+		Dims: module.Dims{
+			{ID: "thread_pool_%s_pending_tasks", Name: "pending"},
+		},
+	}
+	chartTmplThreadPoolBlockedTasksCount = module.Chart{
+		ID:       "thread_pool_%s_blocked_tasks_count",
+		Title:    "Blocked tasks",
+		Units:    "tasks",
+		Fam:      "thread pools",
+		Ctx:      "cassandra.thread_pool_blocked_tasks_count",
+		Priority: prioThreadPoolBlockedTasksCount,
+		Dims: module.Dims{
+			{ID: "thread_pool_%s_blocked_tasks", Name: "blocked"},
+		},
+	}
+	chartTmplThreadPoolBlockedTasksRate = module.Chart{
+		ID:       "thread_pool_%s_blocked_tasks_rate",
+		Title:    "Blocked tasks rate",
+		Units:    "tasks/s",
+		Fam:      "thread pools",
+		Ctx:      "cassandra.thread_pool_blocked_tasks_rate",
+		Priority: prioThreadPoolBlockedTasksRate,
+		Dims: module.Dims{
+			{ID: "thread_pool_%s_total_blocked_tasks", Name: "blocked", Algo: module.Incremental},
+		},
+	}
+)
+
+var (
+	chartJVMMemoryUsed = module.Chart{
+		ID:       "jvm_memory_used",
+		Title:    "Memory used",
+		Units:    "bytes",
+		Fam:      "jvm runtime",
+		Ctx:      "cassandra.jvm_memory_used",
+		Priority: prioJVMMemoryUsed,
+		Type:     module.Stacked,
+		Dims: module.Dims{
+			{ID: "jvm_memory_heap_used", Name: "heap"},
+			{ID: "jvm_memory_nonheap_used", Name: "nonheap"},
+		},
+	}
+	chartJVMGCRate = module.Chart{
+		ID:       "jvm_gc_rate",
+		Title:    "Garbage collections rate",
+		Units:    "gc/s",
+		Fam:      "jvm runtime",
+		Ctx:      "cassandra.jvm_gc_rate",
+		Priority: prioJVMGCCount,
+		Dims: module.Dims{
+			{ID: "jvm_gc_parnew_count", Name: "parnew", Algo: module.Incremental},
+			{ID: "jvm_gc_cms_count", Name: "cms", Algo: module.Incremental},
+		},
+	}
+	chartJVMGCTime = module.Chart{
+		ID:       "jvm_gc_time",
+		Title:    "Garbage collection time",
+		Units:    "seconds",
+		Fam:      "jvm runtime",
+		Ctx:      "cassandra.jvm_gc_time",
+		Priority: prioJVMGCTime,
+		Dims: module.Dims{
+			{ID: "jvm_gc_parnew_time", Name: "parnew", Algo: module.Incremental, Div: 1e9},
+			{ID: "jvm_gc_cms_time", Name: "cms", Algo: module.Incremental, Div: 1e9},
+		},
+	}
+)
+
+var (
+	chartDroppedMessagesRate = module.Chart{
+		ID:       "dropped_messages_rate",
+		Title:    "Dropped messages rate",
+		Units:    "messages/s",
+		Fam:      "errors",
+		Ctx:      "cassandra.dropped_messages_rate",
+		Priority: prioDroppedMessagesRate,
+		Dims: module.Dims{
+			{ID: "dropped_messages", Name: "dropped"},
+		},
+	}
+	chartClientRequestTimeoutsRate = module.Chart{
+		ID:       "client_requests_timeouts_rate",
+		Title:    "Client requests timeouts rate",
+		Units:    "timeouts/s",
+		Fam:      "errors",
+		Ctx:      "cassandra.client_requests_timeouts_rate",
+		Priority: prioRequestsTimeoutsRate,
+		Dims: module.Dims{
+			{ID: "client_request_timeouts_reads", Name: "read", Algo: module.Incremental},
+			{ID: "client_request_timeouts_writes", Name: "write", Algo: module.Incremental, Mul: -1},
+		},
+	}
+	chartClientRequestUnavailablesRate = module.Chart{
+		ID:       "client_requests_unavailables_rate",
+		Title:    "Client requests unavailable exceptions rate",
+		Units:    "exceptions/s",
+		Fam:      "errors",
+		Ctx:      "cassandra.client_requests_unavailables_rate",
+		Priority: prioRequestsUnavailablesRate,
+		Dims: module.Dims{
+			{ID: "client_request_unavailables_reads", Name: "read", Algo: module.Incremental},
+			{ID: "client_request_unavailables_writes", Name: "write", Algo: module.Incremental, Mul: -1},
+		},
+	}
+	chartClientRequestFailuresRate = module.Chart{
+		ID:       "client_requests_failures_rate",
+		Title:    "Client requests failures rate",
+		Units:    "failures/s",
+		Fam:      "errors",
+		Ctx:      "cassandra.client_requests_failures_rate",
+		Priority: prioRequestsFailuresRate,
+		Dims: module.Dims{
+			{ID: "client_request_failures_reads", Name: "read", Algo: module.Incremental},
+			{ID: "client_request_failures_writes", Name: "write", Algo: module.Incremental, Mul: -1},
+		},
+	}
+	chartStorageExceptionsRate = module.Chart{
+		ID:       "storage_exceptions_rate",
+		Title:    "Storage exceptions rate",
+		Units:    "exceptions/s",
+		Fam:      "errors",
+		Ctx:      "cassandra.storage_exceptions_rate",
+		Priority: prioStorageExceptionsRate,
+		Dims: module.Dims{
+			{ID: "storage_exceptions", Name: "storage", Algo: module.Incremental},
+		},
+	}
+)
+
+func (c *Cassandra) addThreadPoolCharts(pool *threadPoolMetrics) {
+	charts := chartsTmplThreadPool.Copy()
+
+	for _, chart := range *charts {
+		chart.ID = fmt.Sprintf(chart.ID, pool.name)
+		chart.Labels = []module.Label{
+			{Key: "thread_pool", Value: pool.name},
+		}
+		for _, dim := range chart.Dims {
+			dim.ID = fmt.Sprintf(dim.ID, pool.name)
+		}
+	}
+
+	if err := c.Charts().Add(*charts...); err != nil {
+		c.Warning(err)
+	}
+}