telemetry

Documentation

Index

• Variables
• func BuildCustomVectorToml(telemetrySpec *telemetry.TelemetrySpec) string
• func BuildVectorAgentConfigMap(namespace, k8cName, dcName, k8cNamespace, vectorToml string) *corev1.ConfigMap
• func CreateCassandraVectorToml(telemetrySpec *telemetry.TelemetrySpec, mcacEnabled bool) (string, error)
• func InjectCassandraTelemetryFilters(telemetrySpec *telemetry.TelemetrySpec, dcConfig *cassandra.DatacenterConfig)
• func InjectCassandraVectorAgent(telemetrySpec *telemetry.TelemetrySpec, dcConfig *cassandra.DatacenterConfig, ...) error
• func IsPromInstalled(client client.Client, logger logr.Logger) (bool, error)
• func SpecIsValid(tspec *telemetryapi.TelemetrySpec, promInstalled bool) bool
• func VectorAgentConfigMapName(k8cName, dcName string) string
• type PrometheusResourcer
  • func (cfg PrometheusResourcer) CleanupResources(ctx context.Context, client runtimeclient.Client) error
  • func (cfg PrometheusResourcer) NewCassServiceMonitor(legacyEndpoints bool) (*promapi.ServiceMonitor, error)
  • func (cfg PrometheusResourcer) NewReaperServiceMonitor() (promapi.ServiceMonitor, error)
  • func (cfg PrometheusResourcer) NewStargateServiceMonitor() (promapi.ServiceMonitor, error)
  • func (cfg PrometheusResourcer) UpdateResources(ctx context.Context, client runtimeclient.Client, owner metav1.Object, ...) error
• type TelemetryConfigIncomplete
  • func (detail TelemetryConfigIncomplete) Error() string
• type TelemetryDepsNotInstalled
  • func (detail TelemetryDepsNotInstalled) Error() string

Variables

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

func BuildCustomVectorToml(telemetrySpec *telemetry.TelemetrySpec) string

func BuildVectorAgentConfigMap

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

func CreateCassandraVectorToml

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

func InjectCassandraTelemetryFilters

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 InjectCassandraVectorAgent

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

InjectCassandraVectorAgent adds the Vector agent container to the Cassandra pods. If the Vector agent is already present, it is not added again.

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 SpecIsValid

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

func VectorAgentConfigMapName

func VectorAgentConfigMapName(k8cName, dcName string) string

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

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 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