telemetry

package
v1.30.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 23, 2026 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultScrapeIntervalInSeconds = 30
	// CassandraMetricsPortLegacy is the metrics port to scrape for the legacy MCAC stack (Metrics
	// Collector for Apache Cassandra).
	CassandraMetricsPortLegacy = 9103
	// CassandraMetricsPortModern is the metrics port to scrape for the modern stack (metrics
	// exposed by management-api).
	CassandraMetricsPortModern = 9000
)
View Source 
const (
	DefaultVectorCpuRequest    = "200m"
	DefaultVectorMemoryRequest = "128Mi"
	DefaultVectorCpuLimit      = "2"
	DefaultVectorMemoryLimit   = "2Gi"
)

Variables

View Source 
var (
	DefaultFilters = []string{"deny:org.apache.cassandra.metrics.Table",
		"deny:org.apache.cassandra.metrics.table",
		"allow:org.apache.cassandra.metrics.table.live_ss_table_count",
		"allow:org.apache.cassandra.metrics.Table.LiveSSTableCount",
		"allow:org.apache.cassandra.metrics.table.live_disk_space_used",
		"allow:org.apache.cassandra.metrics.table.LiveDiskSpaceUsed",
		"allow:org.apache.cassandra.metrics.Table.Pending",
		"allow:org.apache.cassandra.metrics.Table.Memtable",
		"allow:org.apache.cassandra.metrics.Table.Compaction",
		"allow:org.apache.cassandra.metrics.table.read",
		"allow:org.apache.cassandra.metrics.table.write",
		"allow:org.apache.cassandra.metrics.table.range",
		"allow:org.apache.cassandra.metrics.table.coordinator",
		"allow:org.apache.cassandra.metrics.table.dropped_mutations"}
)

Functions

func BuildCustomVectorToml added in v1.5.0 

func BuildCustomVectorToml(telemetrySpec *telemetry.TelemetrySpec) string

func BuildDefaultVectorComponents added in v1.6.0 

func BuildDefaultVectorComponents(config PrometheusScrapeConfig) ([]telemetry.VectorSourceSpec, []telemetry.VectorTransformSpec, []telemetry.VectorSinkSpec)

func BuildVectorAgentConfigMap added in v1.5.0 

func BuildVectorAgentConfigMap(namespace, k8cName, dcName, k8cNamespace, vectorToml string) *corev1.ConfigMap

func CreateCassandraVectorToml added in v1.5.0 

func CreateCassandraVectorToml(telemetrySpec *telemetry.TelemetrySpec, mcacEnabled bool) (string, error)

func FilterUnusedPipelines added in v1.6.0 

func FilterUnusedPipelines(sources []telemetry.VectorSourceSpec, transformers []telemetry.VectorTransformSpec, sinks []telemetry.VectorSinkSpec) ([]telemetry.VectorSourceSpec, []telemetry.VectorTransformSpec, []telemetry.VectorSinkSpec)

FilterUnusedPipelines removes sources that have no destination in the sinks. If there are duplicate transformer, source or sink names, only the first occurence wins

func InjectCassandraTelemetryFilters added in v1.2.0 

func InjectCassandraTelemetryFilters(telemetrySpec *telemetry.TelemetrySpec, dcConfig *cassandra.DatacenterConfig)

InjectCassandraTelemetryFilters adds MCAC filters to the cassandra container as an env variable. If filter list is set to nil, the default filters are used, otherwise the provided filters are used.

func InjectCassandraVectorAgentConfig added in v1.6.0 

func InjectCassandraVectorAgentConfig(telemetrySpec *telemetry.TelemetrySpec, dcConfig *cassandra.DatacenterConfig, k8cName string, logger logr.Logger) error

InjectCassandraVectorAgentConfig adds a override Vector agent config to the Cassandra pods, overwriting the default in the cass-operator

func IsNewMetricsEndpointAvailable added in v1.7.0 

func IsNewMetricsEndpointAvailable(serverVersion string) bool

IsNewMetricsEndpointAvailable returns true if the new metrics endpoint is available, false otherwise. It is available since Cassandra 3.11.13 in the 3.11 branch and since 4.0.4 in the 4.0 branch.

func IsPromInstalled 

func IsPromInstalled(client client.Client, logger logr.Logger) (bool, error)

IsPromInstalled returns true if Prometheus is installed in the cluster, false otherwise.

func NewTelemetrySpec added in v1.6.0 

func NewTelemetrySpec() telemetryapi.TelemetrySpec

func SpecIsValid 

func SpecIsValid(tspec *telemetryapi.TelemetrySpec, promInstalled bool) bool

func VectorAgentConfigMapName added in v1.5.0 

func VectorAgentConfigMapName(k8cName, dcName string) string

func VectorContainerResources added in v1.30.0 

func VectorContainerResources(telemetrySpec *telemetry.TelemetrySpec) corev1.ResourceRequirements

Types

type PrometheusResourcer 

type PrometheusResourcer struct {
	MonitoringTargetNS   string
	MonitoringTargetName string
	ServiceMonitorName   string
	Logger               logr.Logger
	CommonLabels         map[string]string
}

func (PrometheusResourcer) CleanupResources 

func (cfg PrometheusResourcer) CleanupResources(ctx context.Context, client runtimeclient.Client) error

CleanupResources executes the cleanup of any resources on the cluster, once they are no longer required.

func (PrometheusResourcer) NewCassServiceMonitor 

func (cfg PrometheusResourcer) NewCassServiceMonitor(legacyEndpoints bool) (*promapi.ServiceMonitor, error)

NewCassServiceMonitor returns a Prometheus operator ServiceMonitor resource.

func (PrometheusResourcer) NewReaperServiceMonitor added in v1.2.0 

func (cfg PrometheusResourcer) NewReaperServiceMonitor() (promapi.ServiceMonitor, error)

NewReaperServiceMonitor returns a Prometheus operator ServiceMonitor resource.

func (PrometheusResourcer) NewStargateServiceMonitor 

func (cfg PrometheusResourcer) NewStargateServiceMonitor() (promapi.ServiceMonitor, error)

NewStargateServiceMonitor returns a Prometheus operator ServiceMonitor resource.

func (PrometheusResourcer) UpdateResources 

func (cfg PrometheusResourcer) UpdateResources(
	ctx context.Context,
	client runtimeclient.Client,
	owner metav1.Object,
	desiredSM *promapi.ServiceMonitor,
) error

UpdateResources executes the creation of the desired Prometheus resources on the cluster.

type PrometheusScrapeConfig added in v1.30.0 

type PrometheusScrapeConfig struct {
	ScrapePort     int32
	ScrapeInterval int32
	ScrapeAddress  string
	ScrapeEndpoint string
	TLS            *telemetry.TLSConfig
}

func (*PrometheusScrapeConfig) String added in v1.30.0 

func (p *PrometheusScrapeConfig) String() string

type TelemetryConfigIncomplete 

type TelemetryConfigIncomplete struct {
	// contains filtered or unexported fields
}

func (TelemetryConfigIncomplete) Error 

func (detail TelemetryConfigIncomplete) Error() string

type TelemetryDepsNotInstalled 

type TelemetryDepsNotInstalled struct {
	// contains filtered or unexported fields
}

func (TelemetryDepsNotInstalled) Error 

func (detail TelemetryDepsNotInstalled) Error() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.