source

package

v1.8.2 Latest Latest Go to latest Published: Jan 9, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/volcano-sh/volcano

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type ElasticsearchMetricsClient
- func NewElasticsearchMetricsClient(conf map[string]string) (*ElasticsearchMetricsClient, error)
- func (e *ElasticsearchMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string) (*NodeMetrics, error)
- func (e *ElasticsearchMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error
type KMetricsClient
- func NewCustomMetricsClient(cfg *rest.Config) (*KMetricsClient, error)
- func (km *KMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error
type MetricsClient
- func NewMetricsClient(restConfig *rest.Config, metricsConf map[string]string) (MetricsClient, error)
type NodeMetrics
type PrometheusMetricsClient
- func NewPrometheusMetricsClient(conf map[string]string) (*PrometheusMetricsClient, error)
- func (p *PrometheusMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string) (*NodeMetrics, error)
- func (p *PrometheusMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error

Constants ¶

View Source

const (
	NODE_METRICS_PERIOD             = "10m"
	Metrics_Type_Prometheus_Adaptor = "prometheus_adaptor"
	Metrics_Tpye_Prometheus         = "prometheus"
	Metrics_Type_Elasticsearch      = "elasticsearch"
)

View Source

const (
	// CustomNodeCPUUsageAvg record name of cpu average usage defined in prometheus adapt rules
	CustomNodeCPUUsageAvg = "node_cpu_usage_avg"
	// CustomNodeMemUsageAvg record name of mem average usage defined in prometheus adapt rules
	CustomNodeMemUsageAvg = "node_memory_usage_avg"
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ElasticsearchMetricsClient ¶

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

func NewElasticsearchMetricsClient ¶

func NewElasticsearchMetricsClient(conf map[string]string) (*ElasticsearchMetricsClient, error)

func (*ElasticsearchMetricsClient) NodeMetricsAvg ¶

func (e *ElasticsearchMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string) (*NodeMetrics, error)

func (*ElasticsearchMetricsClient) NodesMetricsAvg ¶ added in v1.8.2

func (e *ElasticsearchMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error

type KMetricsClient ¶ added in v1.8.2

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

func NewCustomMetricsClient ¶ added in v1.8.2

func NewCustomMetricsClient(cfg *rest.Config) (*KMetricsClient, error)

func (*KMetricsClient) NodesMetricsAvg ¶ added in v1.8.2

func (km *KMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error

type MetricsClient ¶

type MetricsClient interface {
	NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error
}

func NewMetricsClient ¶

func NewMetricsClient(restConfig *rest.Config, metricsConf map[string]string) (MetricsClient, error)

type NodeMetrics ¶

type NodeMetrics struct {
	MetricsTime time.Time
	CPU         float64
	Memory      float64
}

type PrometheusMetricsClient ¶

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

func NewPrometheusMetricsClient ¶

func NewPrometheusMetricsClient(conf map[string]string) (*PrometheusMetricsClient, error)

func (*PrometheusMetricsClient) NodeMetricsAvg ¶

func (p *PrometheusMetricsClient) NodeMetricsAvg(ctx context.Context, nodeName string) (*NodeMetrics, error)

func (*PrometheusMetricsClient) NodesMetricsAvg ¶ added in v1.8.2

func (p *PrometheusMetricsClient) NodesMetricsAvg(ctx context.Context, nodeMetricsMap map[string]*NodeMetrics) error

Source Files ¶

View all Source files

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