metrics

package
v4.3.1008+incompatible Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ContainerCpu      influxdb.Measurement = "container_cpu"
	ContainerMemory   influxdb.Measurement = "container_memory"
	NodeCpu           influxdb.Measurement = "node_cpu"
	NodeMemory        influxdb.Measurement = "node_memory"
	ApplicationCpu    influxdb.Measurement = "application_cpu"
	ApplicationMemory influxdb.Measurement = "application_memory"
	ClusterCpu        influxdb.Measurement = "cluster_cpu"
	ClusterMemory     influxdb.Measurement = "cluster_memory"
	NamespaceCpu      influxdb.Measurement = "namespace_cpu"
	NamespaceMemory   influxdb.Measurement = "namespace_memory"
	ControllerCpu     influxdb.Measurement = "controller_cpu"
	ControllerMemory  influxdb.Measurement = "controller_memory"
)

Variables

View Source 
var PodNameRegularExpression = map[string]string{
	"DEPLOYMENT":       consts.DeploymentPodFormat,
	"STATEFULSET":      consts.StatefulSetPodFormat,
	"DEPLOYMENTCONFIG": consts.DeploymentConfigPodFormat,
}

Functions

func ListNodesByCluster 

func ListNodesByCluster(config influxdb.Config, cluster *types.Cluster) ([]*types.Node, error)

func ListPodsByApplication 

func ListPodsByApplication(config influxdb.Config, application *types.Application) ([]*types.Pod, error)

func ListPodsByController 

func ListPodsByController(config influxdb.Config, controller *types.Controller) ([]*types.Pod, error)

Types

type Application 

type Application struct {
	InfluxDBConfig InfluxDB.Config
}

func NewApplicationWithConfig 

func NewApplicationWithConfig(config InfluxDB.Config) *Application

func (*Application) GetMetricMap 

func (p *Application) GetMetricMap(metricType enumconv.MetricType, applications []*DaoClusterTypes.Application, req DaoMetricTypes.ListAppMetricsRequest) (DaoMetricTypes.AppMetricMap, error)

type ApplicationCPURepository 

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

func NewApplicationCPURepositoryWithConfig 

func NewApplicationCPURepositoryWithConfig(influxDBCfg InfluxDB.Config) *ApplicationCPURepository

func (*ApplicationCPURepository) CreateMetrics 

func (r *ApplicationCPURepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.AppMetricSample) error

func (*ApplicationCPURepository) GetApplicationMetricMap 

func (r *ApplicationCPURepository) GetApplicationMetricMap(ctx context.Context, request DaoMetricTypes.ListAppMetricsRequest) (DaoMetricTypes.AppMetricMap, error)

type ApplicationMemoryRepository 

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

func NewApplicationMemoryRepositoryWithConfig 

func NewApplicationMemoryRepositoryWithConfig(influxDBCfg InfluxDB.Config) *ApplicationMemoryRepository

func (*ApplicationMemoryRepository) CreateMetrics 

func (r *ApplicationMemoryRepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.AppMetricSample) error

func (*ApplicationMemoryRepository) GetApplicationMetricMap 

func (r *ApplicationMemoryRepository) GetApplicationMetricMap(ctx context.Context, request DaoMetricTypes.ListAppMetricsRequest) (DaoMetricTypes.AppMetricMap, error)

type Cluster 

type Cluster struct {
	InfluxDBConfig InfluxDB.Config
}

func NewClusterWithConfig 

func NewClusterWithConfig(config InfluxDB.Config) *Cluster

func (*Cluster) GetMetricMap 

func (p *Cluster) GetMetricMap(metricType enumconv.MetricType, clusters []*DaoClusterTypes.Cluster, req DaoMetricTypes.ListClusterMetricsRequest) (DaoMetricTypes.ClusterMetricMap, error)

type ClusterCPURepository 

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

func NewClusterCPURepositoryWithConfig 

func NewClusterCPURepositoryWithConfig(influxDBCfg InfluxDB.Config) *ClusterCPURepository

func (*ClusterCPURepository) CreateMetrics 

func (r *ClusterCPURepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.ClusterMetricSample) error

func (*ClusterCPURepository) GetClusterMetricMap 

func (r *ClusterCPURepository) GetClusterMetricMap(ctx context.Context, request DaoMetricTypes.ListClusterMetricsRequest) (DaoMetricTypes.ClusterMetricMap, error)

type ClusterMemoryRepository 

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

func NewClusterMemoryRepositoryWithConfig 

func NewClusterMemoryRepositoryWithConfig(influxDBCfg InfluxDB.Config) *ClusterMemoryRepository

func (*ClusterMemoryRepository) CreateMetrics 

func (r *ClusterMemoryRepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.ClusterMetricSample) error

func (*ClusterMemoryRepository) GetClusterMetricMap 

func (r *ClusterMemoryRepository) GetClusterMetricMap(ctx context.Context, request DaoMetricTypes.ListClusterMetricsRequest) (DaoMetricTypes.ClusterMetricMap, error)

type ContainerCpuRepository 

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

func NewContainerCpuRepositoryWithConfig 

func NewContainerCpuRepositoryWithConfig(influxDBCfg InfluxDB.Config) *ContainerCpuRepository

func (*ContainerCpuRepository) CreateMetrics 

func (r *ContainerCpuRepository) CreateMetrics(metrics []*DaoMetricTypes.ContainerMetricSample) error

func (*ContainerCpuRepository) ListMetrics 

func (r *ContainerCpuRepository) ListMetrics(request DaoMetricTypes.ListPodMetricsRequest) ([]*DaoMetricTypes.ContainerMetric, error)

type ContainerMemoryRepository 

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

func NewContainerMemoryRepositoryWithConfig 

func NewContainerMemoryRepositoryWithConfig(influxDBCfg InfluxDB.Config) *ContainerMemoryRepository

func (*ContainerMemoryRepository) CreateMetrics 

func (r *ContainerMemoryRepository) CreateMetrics(metrics []*DaoMetricTypes.ContainerMetricSample) error

func (*ContainerMemoryRepository) ListMetrics 

func (r *ContainerMemoryRepository) ListMetrics(request DaoMetricTypes.ListPodMetricsRequest) ([]*DaoMetricTypes.ContainerMetric, error)

type Controller 

type Controller struct {
	InfluxDBConfig InfluxDB.Config
}

func NewControllerWithConfig 

func NewControllerWithConfig(config InfluxDB.Config) *Controller

func (*Controller) GetMetricMap 

func (p *Controller) GetMetricMap(metricType enumconv.MetricType, controllers []*DaoClusterTypes.Controller, req DaoMetricTypes.ListControllerMetricsRequest) (DaoMetricTypes.ControllerMetricMap, error)

type ControllerCPURepository 

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

func NewControllerCPURepositoryWithConfig 

func NewControllerCPURepositoryWithConfig(influxDBCfg InfluxDB.Config) *ControllerCPURepository

func (*ControllerCPURepository) CreateMetrics 

func (r *ControllerCPURepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.ControllerMetricSample) error

func (*ControllerCPURepository) GetControllerMetricMap 

func (r *ControllerCPURepository) GetControllerMetricMap(ctx context.Context, request DaoMetricTypes.ListControllerMetricsRequest) (DaoMetricTypes.ControllerMetricMap, error)

type ControllerMemoryRepository 

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

func NewControllerMemoryRepositoryWithConfig 

func NewControllerMemoryRepositoryWithConfig(influxDBCfg InfluxDB.Config) *ControllerMemoryRepository

func (*ControllerMemoryRepository) CreateMetrics 

func (r *ControllerMemoryRepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.ControllerMetricSample) error

func (*ControllerMemoryRepository) GetControllerMetricMap 

func (r *ControllerMemoryRepository) GetControllerMetricMap(ctx context.Context, request DaoMetricTypes.ListControllerMetricsRequest) (DaoMetricTypes.ControllerMetricMap, error)

type NamespaceCPURepository 

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

func NewNamespaceCPURepositoryWithConfig 

func NewNamespaceCPURepositoryWithConfig(influxDBCfg InfluxDB.Config) *NamespaceCPURepository

func (*NamespaceCPURepository) CreateMetrics 

func (r *NamespaceCPURepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.NamespaceMetricSample) error

func (*NamespaceCPURepository) GetNamespaceMetricMap 

func (r *NamespaceCPURepository) GetNamespaceMetricMap(ctx context.Context, request DaoMetricTypes.ListNamespaceMetricsRequest) (DaoMetricTypes.NamespaceMetricMap, error)

type NamespaceMemoryRepository 

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

func NewNamespaceMemoryRepositoryWithConfig 

func NewNamespaceMemoryRepositoryWithConfig(influxDBCfg InfluxDB.Config) *NamespaceMemoryRepository

func (*NamespaceMemoryRepository) CreateMetrics 

func (r *NamespaceMemoryRepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.NamespaceMetricSample) error

func (*NamespaceMemoryRepository) GetNamespaceMetricMap 

func (r *NamespaceMemoryRepository) GetNamespaceMetricMap(ctx context.Context, request DaoMetricTypes.ListNamespaceMetricsRequest) (DaoMetricTypes.NamespaceMetricMap, error)

type NodeCpuRepository 

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

func NewNodeCpuRepositoryWithConfig 

func NewNodeCpuRepositoryWithConfig(influxDBCfg InfluxDB.Config) *NodeCpuRepository

func (*NodeCpuRepository) CreateMetrics 

func (r *NodeCpuRepository) CreateMetrics(metrics []*DaoMetricTypes.NodeMetricSample) error

func (*NodeCpuRepository) ListMetrics 

func (r *NodeCpuRepository) ListMetrics(request DaoMetricTypes.ListNodeMetricsRequest) ([]*DaoMetricTypes.NodeMetric, error)

type NodeMemoryRepository 

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

func NewNodeMemoryRepositoryWithConfig 

func NewNodeMemoryRepositoryWithConfig(influxDBCfg InfluxDB.Config) *NodeMemoryRepository

func (*NodeMemoryRepository) CreateMetrics 

func (r *NodeMemoryRepository) CreateMetrics(metrics []*DaoMetricTypes.NodeMetricSample) error

func (*NodeMemoryRepository) ListMetrics 

func (r *NodeMemoryRepository) ListMetrics(request DaoMetricTypes.ListNodeMetricsRequest) ([]*DaoMetricTypes.NodeMetric, error)

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.