prometheusUtil

README

连接Prometheus

示例

address := "http://10.77.50.201:30364"  // 示例 asteria中的prometheus地址
_, queryClient, err := GetPrometheusClient(address)
if err != nil {
    t.Fatalf("Cannot connect to prometheus: %s, %s", address, err.Error())
}

执行查询

已有的查询从 prometheusClient.go,prometheusQuerys.go 中获得

示例

result, err = QueryPodMemoryUsage("prometheus", queryClient)  // 返回值为model.Value类型
if err != nil {
    t.Fatalf("Cannot query prometheus: %s, %s", address, err.Error())
}

测试

go test

Documentation

Index

• Constants
• func GetPrometheusClient(address string) (*api.Config, *prometheus.API, error)
• func QueryClusterCpuUsagePercentage(cluster string, client *prometheus.API) (model.Value, error)
• func QueryClusterMemoryUsagePercentage(cluster string, client *prometheus.API) (model.Value, error)
• func QueryClusterNumber(cluster string, client *prometheus.API) (model.Value, error)
• func QueryMasterCpuUsagePercentage(cluster string, client *prometheus.API) (model.Value, error)
• func QueryPodCpuUsage(podPrefix string, client *prometheus.API) (model.Value, error)
• func QueryPodCpuUsagePercentage(podPrefix string, client *prometheus.API) (model.Value, error)
• func QueryPodMemoryUsage(podPrefix string, client *prometheus.API) (model.Value, error)
• func QueryPodMemoryUsagePercentage(podPrefix string, client *prometheus.API) (model.Value, error)
• func QueryWorkerCpuUsagePercentage(cluster string, client *prometheus.API) (model.Value, error)

Constants

const (
	PodCpuUsage                  = "sum(rate(container_cpu_usage_seconds_total{pod=~\"%s.*\"}[1m])) by (pod)"
	PodCpuUsagePercentage        = ""                                                 /* 161-byte string literal not displayed */
	PodMemoryUsage               = "sum(container_memory_rss{pod=~\"%s.*\"}) by(pod)" // /1024/1024/1024 = GiB
	PodMemoryUsagePercentage     = ""                                                 /* 141-byte string literal not displayed */
	ClusterCpuUsagePercentage    = ""                                                 /* 197-byte string literal not displayed */
	MasterCpuUsagePercentage     = ""                                                 /* 179-byte string literal not displayed */
	WorkerCpuUsagePercentage     = ""                                                 /* 181-byte string literal not displayed */
	ClusterMemoryUsagePercentage = ""                                                 /* 177-byte string literal not displayed */
	ClusterNum                   = "sum(kube_pod_container_info{pod=~\"%s-(masters|replicas)-.\"})"
)

Functions

func GetPrometheusClient

func GetPrometheusClient(address string) (*api.Config, *prometheus.API, error)

GetPrometheusClient returns prometheus apiConfig and apiClient

func QueryClusterCpuUsagePercentage

func QueryClusterCpuUsagePercentage(cluster string, client *prometheus.API) (model.Value, error)

func QueryClusterMemoryUsagePercentage

func QueryClusterMemoryUsagePercentage(cluster string, client *prometheus.API) (model.Value, error)

func QueryClusterNumber

func QueryClusterNumber(cluster string, client *prometheus.API) (model.Value, error)

func QueryMasterCpuUsagePercentage

func QueryMasterCpuUsagePercentage(cluster string, client *prometheus.API) (model.Value, error)

func QueryPodCpuUsage

func QueryPodCpuUsage(podPrefix string, client *prometheus.API) (model.Value, error)

func QueryPodCpuUsagePercentage

func QueryPodCpuUsagePercentage(podPrefix string, client *prometheus.API) (model.Value, error)

func QueryPodMemoryUsage

func QueryPodMemoryUsage(podPrefix string, client *prometheus.API) (model.Value, error)

func QueryPodMemoryUsagePercentage

func QueryPodMemoryUsagePercentage(podPrefix string, client *prometheus.API) (model.Value, error)

func QueryWorkerCpuUsagePercentage

func QueryWorkerCpuUsagePercentage(cluster string, client *prometheus.API) (model.Value, error)