federation

package
v0.0.0-...-c91c74a Latest Latest
Warning

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

Go to latest
Published: Apr 30, 2024 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package federation Factory

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ClientFactory

func ClientFactory(ctx context.Context, clusterID string, source clientutil.MonitorSourceType, metricsPrefix string) (
	base.MetricHandler, error)

ClientFactory 自动切换Prometheus/蓝鲸监控

Types

type Federation

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

Federation xxx

func NewFederation

func NewFederation(dispatch map[string]clientutil.DispatchConf) *Federation

NewFederation xxx

func (*Federation) GetClusterCPURequest

func (p *Federation) GetClusterCPURequest(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterCPURequest 获取CPU Request

func (*Federation) GetClusterCPURequestUsage

func (p *Federation) GetClusterCPURequestUsage(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterCPURequestUsage 获取CPU核心装箱率

func (*Federation) GetClusterCPUTotal

func (p *Federation) GetClusterCPUTotal(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterCPUTotal 获取集群CPU核心总量

func (*Federation) GetClusterCPUUsage

func (p *Federation) GetClusterCPUUsage(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterCPUUsage 获取CPU核心使用量

func (*Federation) GetClusterCPUUsed

func (p *Federation) GetClusterCPUUsed(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterCPUUsed 获取CPU核心使用量

func (*Federation) GetClusterDiskTotal

func (p *Federation) GetClusterDiskTotal(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterDiskTotal 获取集群磁盘总量

func (*Federation) GetClusterDiskUsage

func (p *Federation) GetClusterDiskUsage(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterDiskUsage 获取CPU核心使用量

func (*Federation) GetClusterDiskUsed

func (p *Federation) GetClusterDiskUsed(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterDiskUsed 获取集群磁盘使用量

func (*Federation) GetClusterDiskioTotal

func (p *Federation) GetClusterDiskioTotal(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterDiskioTotal 集群磁盘IO

func (*Federation) GetClusterDiskioUsage

func (p *Federation) GetClusterDiskioUsage(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterDiskioUsage 集群磁盘IO使用率

func (*Federation) GetClusterDiskioUsed

func (p *Federation) GetClusterDiskioUsed(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterDiskioUsed 集群磁盘IO使用量

func (*Federation) GetClusterMemoryRequest

func (p *Federation) GetClusterMemoryRequest(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterMemoryRequest 获取内存 Request

func (*Federation) GetClusterMemoryRequestUsage

func (p *Federation) GetClusterMemoryRequestUsage(ctx context.Context, projectID, clusterID string,
	start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterMemoryRequestUsage 获取内存装箱率

func (*Federation) GetClusterMemoryTotal

func (p *Federation) GetClusterMemoryTotal(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterMemoryTotal 获取集群内存总量

func (*Federation) GetClusterMemoryUsage

func (p *Federation) GetClusterMemoryUsage(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterMemoryUsage 获取内存使用率

func (*Federation) GetClusterMemoryUsed

func (p *Federation) GetClusterMemoryUsed(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterMemoryUsed 获取内存使用量

func (*Federation) GetClusterPodTotal

func (p *Federation) GetClusterPodTotal(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterPodTotal 获取集群最大允许pod数

func (*Federation) GetClusterPodUsage

func (p *Federation) GetClusterPodUsage(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterPodUsage 获取集群pod使用率

func (*Federation) GetClusterPodUsed

func (p *Federation) GetClusterPodUsed(ctx context.Context, projectID, clusterID string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetClusterPodUsed 获取集群pod使用量

func (*Federation) GetContainerCPULimit

func (m *Federation) GetContainerCPULimit(ctx context.Context, projectID, clusterID, namespace, podname string,
	containerNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetContainerCPULimit 容器CPU限制

func (*Federation) GetContainerCPUUsage

func (m *Federation) GetContainerCPUUsage(ctx context.Context, projectID, clusterID, namespace, podname string,
	containerNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetContainerCPUUsage 容器CPU使用率

func (*Federation) GetContainerDiskReadTotal

func (m *Federation) GetContainerDiskReadTotal(ctx context.Context, projectID, clusterID, namespace, podname string,
	containerNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetContainerDiskReadTotal 容器磁盘读

func (*Federation) GetContainerDiskWriteTotal

func (m *Federation) GetContainerDiskWriteTotal(ctx context.Context, projectID, clusterID, namespace, podname string,
	containerNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetContainerDiskWriteTotal 容器磁盘写

func (*Federation) GetContainerGPUMemoryUsage

func (m *Federation) GetContainerGPUMemoryUsage(ctx context.Context, projectID, clusterID, namespace, podname string,
	containerNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetContainerGPUMemoryUsage 容器GPU显卡使用率

func (*Federation) GetContainerGPUUsage

func (m *Federation) GetContainerGPUUsage(ctx context.Context, projectID, clusterID, namespace, podname string,
	containerNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetContainerGPUUsage 容器GPU使用率

func (*Federation) GetContainerGPUUsed

func (m *Federation) GetContainerGPUUsed(ctx context.Context, projectID, clusterID, namespace, podname string,
	containerNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetContainerGPUUsed 容器GPU使用量

func (*Federation) GetContainerMemoryLimit

func (m *Federation) GetContainerMemoryLimit(ctx context.Context, projectID, clusterID, namespace, podname string,
	containerNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetContainerMemoryLimit 容器内存限制

func (*Federation) GetContainerMemoryUsed

func (m *Federation) GetContainerMemoryUsed(ctx context.Context, projectID, clusterID, namespace, podname string,
	containerNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetContainerMemoryUsed 容器内存使用率

func (*Federation) GetNodeCPURequest

func (m *Federation) GetNodeCPURequest(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeCPURequest 节点CPU请求量

func (*Federation) GetNodeCPURequestUsage

func (m *Federation) GetNodeCPURequestUsage(ctx context.Context, projectID, clusterID, node string,
	start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeCPURequestUsage 节点CPU装箱率

func (*Federation) GetNodeCPUTotal

func (m *Federation) GetNodeCPUTotal(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeCPUTotal 节点CPU总量

func (*Federation) GetNodeCPUUsage

func (m *Federation) GetNodeCPUUsage(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeCPUUsage 节点CPU使用率

func (*Federation) GetNodeCPUUsed

func (m *Federation) GetNodeCPUUsed(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeCPUUsed 节点CPU使用量

func (*Federation) GetNodeContainerCount

func (m *Federation) GetNodeContainerCount(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeContainerCount 容器数量

func (*Federation) GetNodeDiskTotal

func (m *Federation) GetNodeDiskTotal(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeDiskTotal 节点磁盘总量

func (*Federation) GetNodeDiskUsage

func (m *Federation) GetNodeDiskUsage(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeDiskUsage 节点磁盘使用率

func (*Federation) GetNodeDiskUsed

func (m *Federation) GetNodeDiskUsed(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeDiskUsed 节点磁盘使用量

func (*Federation) GetNodeDiskioUsage

func (m *Federation) GetNodeDiskioUsage(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeDiskioUsage 接触磁盘IO使用率

func (*Federation) GetNodeInfo

func (m *Federation) GetNodeInfo(ctx context.Context, projectID, clusterID, node string, t time.Time) (*base.NodeInfo,
	error)

GetNodeInfo 节点信息

func (*Federation) GetNodeMemoryRequest

func (m *Federation) GetNodeMemoryRequest(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeMemoryRequest 节点Memory请求量

func (*Federation) GetNodeMemoryRequestUsage

func (m *Federation) GetNodeMemoryRequestUsage(ctx context.Context, projectID, clusterID, node string,
	start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeMemoryRequestUsage 节点内存装箱率

func (*Federation) GetNodeMemoryTotal

func (m *Federation) GetNodeMemoryTotal(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeMemoryTotal 节点Memory总量

func (*Federation) GetNodeMemoryUsage

func (m *Federation) GetNodeMemoryUsage(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeMemoryUsage 节点内存使用率

func (*Federation) GetNodeMemoryUsed

func (m *Federation) GetNodeMemoryUsed(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeMemoryUsed 节点Memory使用量

func (*Federation) GetNodeNetworkReceive

func (m *Federation) GetNodeNetworkReceive(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeNetworkReceive 节点网络接收量

func (*Federation) GetNodeNetworkTransmit

func (m *Federation) GetNodeNetworkTransmit(ctx context.Context, projectID, clusterID, node string,
	start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetNodeNetworkTransmit 网络发送量

func (*Federation) GetNodePodCount

func (m *Federation) GetNodePodCount(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodePodCount PodCount

func (*Federation) GetNodePodTotal

func (m *Federation) GetNodePodTotal(ctx context.Context, projectID, clusterID, node string, start, end time.Time,
	step time.Duration) ([]*prompb.TimeSeries, error)

GetNodePodTotal PodTotal

func (*Federation) GetPodCPUUsage

func (m *Federation) GetPodCPUUsage(ctx context.Context, projectID, clusterID, namespace string, podNameList []string,
	start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetPodCPUUsage POD 使用率

func (*Federation) GetPodMemoryUsed

func (m *Federation) GetPodMemoryUsed(ctx context.Context, projectID, clusterID, namespace string, podNameList []string,
	start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetPodMemoryUsed 内存使用量

func (*Federation) GetPodNetworkReceive

func (m *Federation) GetPodNetworkReceive(ctx context.Context, projectID, clusterID, namespace string,
	podNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetPodNetworkReceive 网络接收

func (*Federation) GetPodNetworkTransmit

func (m *Federation) GetPodNetworkTransmit(ctx context.Context, projectID, clusterID, namespace string,
	podNameList []string, start, end time.Time, step time.Duration) ([]*prompb.TimeSeries, error)

GetPodNetworkTransmit 网络发送

Jump to

Keyboard shortcuts

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