metrics

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// SELECT host_ip::tag, mem_used::field FROM host_summary WHERE cluster_name::tag=$cluster_name
	// usage rate , distribution rate , usage percent of distribution
	//NodeCpuUsageSelectStatement    = `SELECT last(cpu_cores_usage::field) FROM host_summary WHERE cluster_name::tag=$cluster_name AND host_ip::tag=$host_ip `
	NodeResourceUsageSelectStatement = `` /* 187-byte string literal not displayed */
	//NodeResourceUsageSelectStatement = `SELECT  mem_usage::field  ,cpu_cores_usage::field, host_ip FROM host_summary WHERE cluster_name::tag=$cluster_name GROUP BY host_ip::tag`
	//PodCpuUsageSelectStatement     = `SELECT SUM(cpu_allocation::field) * 100 / SUM(cpu_limit::field) as cpuRate, pod_name FROM docker_container_summary WHERE pod_namespace::tag=$pod_namespace and podsandbox != true GROUP BY pod_name::tag`
	PodResourceUsageSelectStatement = `` /* 352-byte string literal not displayed */

	DiskResourceUsageSelectStatement = `` /* 138-byte string literal not displayed */

	Memory  = "memory"
	Cpu     = "cpu"
	Disk    = "disk"
	NodeAll = "nodeall" // cpu + disk + memory

	Pod  = "pod"
	Node = "node"
)

Variables

View Source 
var (
	ResourceNotSupport = errors.New("resource type not support")
	QueryTimeoutError  = errors.New("metrics query timeout")
	ParameterNotFound  = errors.New("parameter required")
)

Functions

func GenerateNodeAllKey added in v1.5.0 

func GenerateNodeAllKey(cluster string) string

func GenerateNodeallAllKey added in v1.5.0 

func GenerateNodeallAllKey(orgName string) string

func GeneratePodAllKey added in v1.5.0 

func GeneratePodAllKey(cluster string) string

func GetAllCache added in v1.5.0 

func GetAllCache(key string) map[string]*MetricsData

func SetCache added in v1.3.1 

func SetCache(k string, d interface{})

Types

type Basic 

type Basic interface {
	OrgName() string
	ResourceType() string
	ResourceKind() string
	ClusterName() string
}

type Interface 

type Interface interface {
	NodeMetrics(ctx context.Context, req *MetricsRequest) (map[string]*MetricsData, error)
	PodMetrics(ctx context.Context, req *MetricsRequest) (map[string]*MetricsData, error)
	NodeAllMetrics(ctx context.Context, req *MetricsRequest) (map[string]*MetricsData, error)
}

type Key 

type Key interface {
	CacheKey() string
}

type Metric 

type Metric struct {
	Metricq pb.MetricServiceServer
	// contains filtered or unexported fields
}

func New 

func New(metricq pb.MetricServiceServer, ctx context.Context) *Metric

func (*Metric) NodeAllMetrics added in v1.5.0 

func (m *Metric) NodeAllMetrics(ctx context.Context, req *MetricsRequest) (map[string]*MetricsData, error)

func (*Metric) NodeMetrics 

func (m *Metric) NodeMetrics(ctx context.Context, req *MetricsRequest) (map[string]*MetricsData, error)

NodeMetrics query cpu and memory metrics from es database, return immediately if cache hit.

func (*Metric) PodMetrics 

func (m *Metric) PodMetrics(ctx context.Context, req *MetricsRequest) (map[string]*MetricsData, error)

func (*Metric) Store 

func (m *Metric) Store(response *pb.QueryWithInfluxFormatResponse, metricsRequest *MetricsReq) map[string]*MetricsData

func (*Metric) ToInfluxReq added in v1.3.1 

func (m *Metric) ToInfluxReq(request *MetricsRequest, reqKind string) ([]*MetricsReq, map[string]*MetricsData, error)

type MetricsAllRequest added in v1.5.0 

type MetricsAllRequest struct {
	*MetricsRequest
}

func (*MetricsAllRequest) CacheKey added in v1.5.0 

func (m *MetricsAllRequest) CacheKey() string

func (*MetricsAllRequest) ClusterName added in v1.5.0 

func (m *MetricsAllRequest) ClusterName() string

func (*MetricsAllRequest) IP added in v1.5.0 

func (m *MetricsAllRequest) IP() string

func (*MetricsAllRequest) Namespace added in v1.5.0 

func (m *MetricsAllRequest) Namespace() string

func (*MetricsAllRequest) OrgName added in v1.5.0 

func (m *MetricsAllRequest) OrgName() string

func (*MetricsAllRequest) PodName added in v1.5.0 

func (m *MetricsAllRequest) PodName() string

func (*MetricsAllRequest) ResourceKind added in v1.5.0 

func (m *MetricsAllRequest) ResourceKind() string

func (*MetricsAllRequest) ResourceType added in v1.5.0 

func (m *MetricsAllRequest) ResourceType() string

func (*MetricsAllRequest) UserID added in v1.5.0 

func (m *MetricsAllRequest) UserID() string

type MetricsData 

type MetricsData struct {
	// if qurey pod resource, used means usedPercent. request and total are useless.
	Used       float64 `json:"used"`
	Unallocate float64 `json:"unallocate"`
	Left       float64 `json:"left"`
}

func GetCache added in v1.3.1 

func GetCache(key string) *MetricsData

type MetricsNodeRequest 

type MetricsNodeRequest struct {
	*MetricsRequest
	Ip string
}

func (*MetricsNodeRequest) CacheKey 

func (m *MetricsNodeRequest) CacheKey() string

func (*MetricsNodeRequest) ClusterName 

func (m *MetricsNodeRequest) ClusterName() string

func (*MetricsNodeRequest) IP 

func (m *MetricsNodeRequest) IP() string

func (*MetricsNodeRequest) Namespace added in v1.3.1 

func (m *MetricsNodeRequest) Namespace() string

func (*MetricsNodeRequest) OrgName added in v1.5.0 

func (m *MetricsNodeRequest) OrgName() string

func (*MetricsNodeRequest) PodName added in v1.3.1 

func (m *MetricsNodeRequest) PodName() string

func (*MetricsNodeRequest) ResourceKind 

func (m *MetricsNodeRequest) ResourceKind() string

func (*MetricsNodeRequest) ResourceType 

func (m *MetricsNodeRequest) ResourceType() string

func (*MetricsNodeRequest) UserID 

func (m *MetricsNodeRequest) UserID() string

type MetricsPodRequest 

type MetricsPodRequest struct {
	*MetricsRequest
	Name         string
	PodNamespace string
}

func (MetricsPodRequest) CacheKey 

func (m MetricsPodRequest) CacheKey() string

func (*MetricsPodRequest) ClusterName 

func (m *MetricsPodRequest) ClusterName() string

func (MetricsPodRequest) IP added in v1.3.1 

func (m MetricsPodRequest) IP() string

func (*MetricsPodRequest) Namespace 

func (m *MetricsPodRequest) Namespace() string

func (*MetricsPodRequest) PodName 

func (m *MetricsPodRequest) PodName() string

func (*MetricsPodRequest) ResourceKind 

func (m *MetricsPodRequest) ResourceKind() string

func (*MetricsPodRequest) ResourceType 

func (m *MetricsPodRequest) ResourceType() string

type MetricsReq 

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

type MetricsReqInterface 

type MetricsReqInterface interface {
	Key
	PodMetrics
	NodeMetrics
}

type MetricsRequest 

type MetricsRequest struct {
	UserId           string
	OrgId            string
	OrganizationName string
	Cluster          string
	Type             string
	Kind             string
	PodRequests      []MetricsReqInterface
	NodeRequests     []MetricsReqInterface
	AllRequests      []MetricsReqInterface
}

func (MetricsRequest) ClusterName 

func (m MetricsRequest) ClusterName() string

func (MetricsRequest) OrgName added in v1.5.0 

func (m MetricsRequest) OrgName() string

func (MetricsRequest) ResourceKind 

func (m MetricsRequest) ResourceKind() string

func (MetricsRequest) ResourceType 

func (m MetricsRequest) ResourceType() string

func (MetricsRequest) UserID 

func (m MetricsRequest) UserID() string

type NodeMetrics 

type NodeMetrics interface {
	Basic
	IP() string
}

type PodMetrics 

type PodMetrics interface {
	Basic
	PodName() string
	Namespace() string
}

type ResourceType 

type ResourceType string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.