Documentation ¶
Index ¶
- type SparkApplicationMetrics
- func (m *SparkApplicationMetrics) HandleSparkApplicationCreate(app *v1beta2.SparkApplication)
- func (m *SparkApplicationMetrics) HandleSparkApplicationDelete(app *v1beta2.SparkApplication)
- func (m *SparkApplicationMetrics) HandleSparkApplicationUpdate(oldApp *v1beta2.SparkApplication, newApp *v1beta2.SparkApplication)
- func (m *SparkApplicationMetrics) Register()
- type SparkExecutorMetrics
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()
Click to show internal directories.
Click to hide internal directories.