Documentation
¶
Index ¶
- type RayClusterMetricsManager
- func (r *RayClusterMetricsManager) Collect(ch chan<- prometheus.Metric)
- func (r *RayClusterMetricsManager) DeleteRayClusterMetrics(name, namespace string)
- func (r *RayClusterMetricsManager) Describe(ch chan<- *prometheus.Desc)
- func (r *RayClusterMetricsManager) ObserveRayClusterProvisionedDuration(name, namespace string, uid types.UID, duration float64)
- type RayClusterMetricsObserver
- type RayJobMetricsManager
- func (r *RayJobMetricsManager) Collect(ch chan<- prometheus.Metric)
- func (r *RayJobMetricsManager) DeleteRayJobMetrics(name, namespace string)
- func (r *RayJobMetricsManager) Describe(ch chan<- *prometheus.Desc)
- func (r *RayJobMetricsManager) ObserveRayJobExecutionDuration(name, namespace string, uid types.UID, ...)
- type RayJobMetricsObserver
- type RayServiceMetricsManager
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RayClusterMetricsManager ¶
type RayClusterMetricsManager struct {
// contains filtered or unexported fields
}
RayClusterMetricsManager implements the prometheus.Collector and RayClusterMetricsObserver interface to collect ray cluster metrics.
func NewRayClusterMetricsManager ¶
func NewRayClusterMetricsManager(ctx context.Context, client client.Client) *RayClusterMetricsManager
NewRayClusterMetricsManager creates a new RayClusterManager instance.
func (*RayClusterMetricsManager) Collect ¶
func (r *RayClusterMetricsManager) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector interface Collect method.
func (*RayClusterMetricsManager) DeleteRayClusterMetrics ¶ added in v1.5.0
func (r *RayClusterMetricsManager) DeleteRayClusterMetrics(name, namespace string)
DeleteRayClusterMetrics removes metrics that belongs to the specified RayCluster.
func (*RayClusterMetricsManager) Describe ¶
func (r *RayClusterMetricsManager) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector interface Describe method.
func (*RayClusterMetricsManager) ObserveRayClusterProvisionedDuration ¶
func (r *RayClusterMetricsManager) ObserveRayClusterProvisionedDuration(name, namespace string, uid types.UID, duration float64)
type RayJobMetricsManager ¶
type RayJobMetricsManager struct {
// contains filtered or unexported fields
}
RayJobMetricsManager implements the prometheus.Collector and RayJobMetricsObserver interface to collect ray job metrics.
func NewRayJobMetricsManager ¶
func NewRayJobMetricsManager(ctx context.Context, client client.Client) *RayJobMetricsManager
NewRayJobMetricsManager creates a new RayJobMetricsManager instance.
func (*RayJobMetricsManager) Collect ¶
func (r *RayJobMetricsManager) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector interface Collect method.
func (*RayJobMetricsManager) DeleteRayJobMetrics ¶ added in v1.5.0
func (r *RayJobMetricsManager) DeleteRayJobMetrics(name, namespace string)
DeleteRayJobMetrics removes metrics that belongs to the specified RayJob.
func (*RayJobMetricsManager) Describe ¶
func (r *RayJobMetricsManager) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector interface Describe method.
func (*RayJobMetricsManager) ObserveRayJobExecutionDuration ¶
func (r *RayJobMetricsManager) ObserveRayJobExecutionDuration(name, namespace string, uid types.UID, jobDeploymentStatus rayv1.JobDeploymentStatus, retryCount int, duration float64)
type RayJobMetricsObserver ¶
type RayServiceMetricsManager ¶
type RayServiceMetricsManager struct {
// contains filtered or unexported fields
}
RayServiceMetricsManager implements the prometheus.Collector and RayServiceMetricsObserver interface to collect ray service metrics.
func NewRayServiceMetricsManager ¶
func NewRayServiceMetricsManager(ctx context.Context, client client.Client) *RayServiceMetricsManager
NewRayServiceMetricsManager creates a new RayServiceMetricsManager instance.
func (*RayServiceMetricsManager) Collect ¶
func (c *RayServiceMetricsManager) Collect(ch chan<- prometheus.Metric)
Collect implements prometheus.Collector interface Collect method.
func (*RayServiceMetricsManager) Describe ¶
func (c *RayServiceMetricsManager) Describe(ch chan<- *prometheus.Desc)
Describe implements prometheus.Collector interface Describe method.
Source Files
Directories