metrics

package
v0.0.0-...-85f0ed0 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type SparkApplicationMetrics

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

func NewSparkApplicationMetrics

func NewSparkApplicationMetrics(prefix string, labels []string, jobStartLatencyBuckets []float64) *SparkApplicationMetrics

func (*SparkApplicationMetrics) HandleSparkApplicationCreate

func (m *SparkApplicationMetrics) HandleSparkApplicationCreate(app *v1beta2.SparkApplication)

func (*SparkApplicationMetrics) HandleSparkApplicationDelete

func (m *SparkApplicationMetrics) HandleSparkApplicationDelete(app *v1beta2.SparkApplication)

func (*SparkApplicationMetrics) HandleSparkApplicationUpdate

func (m *SparkApplicationMetrics) HandleSparkApplicationUpdate(oldApp *v1beta2.SparkApplication, newApp *v1beta2.SparkApplication)

func (*SparkApplicationMetrics) Register

func (m *SparkApplicationMetrics) Register()

type SparkExecutorMetrics

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

func NewSparkExecutorMetrics

func NewSparkExecutorMetrics(prefix string, labels []string) *SparkExecutorMetrics

func (*SparkExecutorMetrics) HandleSparkExecutorCreate

func (m *SparkExecutorMetrics) HandleSparkExecutorCreate(pod *corev1.Pod)

func (*SparkExecutorMetrics) HandleSparkExecutorDelete

func (m *SparkExecutorMetrics) HandleSparkExecutorDelete(pod *corev1.Pod)

func (*SparkExecutorMetrics) HandleSparkExecutorUpdate

func (m *SparkExecutorMetrics) HandleSparkExecutorUpdate(oldPod, newPod *corev1.Pod)

func (*SparkExecutorMetrics) Register

func (m *SparkExecutorMetrics) Register()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL