metrics

Documentation

Index

• Constants
• type ApplicationCPURepository
  • func NewApplicationCPURepositoryWithConfig(influxDBCfg InternalInflux.Config) *ApplicationCPURepository
  • func (r *ApplicationCPURepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.AppMetricSample) error
  • func (r *ApplicationCPURepository) GetApplicationMetricMap(ctx context.Context, request DaoMetricTypes.ListAppMetricsRequest) (DaoMetricTypes.AppMetricMap, error)
• type ApplicationMemoryRepository
  • func NewApplicationMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ApplicationMemoryRepository
  • func (r *ApplicationMemoryRepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.AppMetricSample) error
  • func (r *ApplicationMemoryRepository) GetApplicationMetricMap(ctx context.Context, request DaoMetricTypes.ListAppMetricsRequest) (DaoMetricTypes.AppMetricMap, error)
• type ClusterCPURepository
  • func NewClusterCPURepositoryWithConfig(influxDBCfg InternalInflux.Config) *ClusterCPURepository
  • func (r *ClusterCPURepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.ClusterMetricSample) error
  • func (r *ClusterCPURepository) GetClusterMetricMap(ctx context.Context, request DaoMetricTypes.ListClusterMetricsRequest) (DaoMetricTypes.ClusterMetricMap, error)
• type ClusterMemoryRepository
  • func NewClusterMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ClusterMemoryRepository
  • func (r *ClusterMemoryRepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.ClusterMetricSample) error
  • func (r *ClusterMemoryRepository) GetClusterMetricMap(ctx context.Context, request DaoMetricTypes.ListClusterMetricsRequest) (DaoMetricTypes.ClusterMetricMap, error)
• type ContainerCpuRepository
  • func NewContainerCpuRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ContainerCpuRepository
  • func (r *ContainerCpuRepository) CreateMetrics(metrics []*DaoMetricTypes.ContainerMetricSample) error
  • func (r *ContainerCpuRepository) ListMetrics(request DaoMetricTypes.ListPodMetricsRequest) ([]*DaoMetricTypes.ContainerMetric, error)
• type ContainerMemoryRepository
  • func NewContainerMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ContainerMemoryRepository
  • func (r *ContainerMemoryRepository) CreateMetrics(metrics []*DaoMetricTypes.ContainerMetricSample) error
  • func (r *ContainerMemoryRepository) ListMetrics(request DaoMetricTypes.ListPodMetricsRequest) ([]*DaoMetricTypes.ContainerMetric, error)
• type ControllerCPURepository
  • func NewControllerCPURepositoryWithConfig(influxDBCfg InternalInflux.Config) *ControllerCPURepository
  • func (r *ControllerCPURepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.ControllerMetricSample) error
  • func (r *ControllerCPURepository) GetControllerMetricMap(ctx context.Context, request DaoMetricTypes.ListControllerMetricsRequest) (DaoMetricTypes.ControllerMetricMap, error)
• type ControllerMemoryRepository
  • func NewControllerMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *ControllerMemoryRepository
  • func (r *ControllerMemoryRepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.ControllerMetricSample) error
  • func (r *ControllerMemoryRepository) GetControllerMetricMap(ctx context.Context, request DaoMetricTypes.ListControllerMetricsRequest) (DaoMetricTypes.ControllerMetricMap, error)
• type NamespaceCPURepository
  • func NewNamespaceCPURepositoryWithConfig(influxDBCfg InternalInflux.Config) *NamespaceCPURepository
  • func (r *NamespaceCPURepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.NamespaceMetricSample) error
  • func (r *NamespaceCPURepository) GetNamespaceMetricMap(ctx context.Context, request DaoMetricTypes.ListNamespaceMetricsRequest) (DaoMetricTypes.NamespaceMetricMap, error)
• type NamespaceMemoryRepository
  • func NewNamespaceMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NamespaceMemoryRepository
  • func (r *NamespaceMemoryRepository) CreateMetrics(ctx context.Context, metrics []DaoMetricTypes.NamespaceMetricSample) error
  • func (r *NamespaceMemoryRepository) GetNamespaceMetricMap(ctx context.Context, request DaoMetricTypes.ListNamespaceMetricsRequest) (DaoMetricTypes.NamespaceMetricMap, error)
• type NodeCpuRepository
  • func NewNodeCpuRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NodeCpuRepository
  • func (r *NodeCpuRepository) CreateMetrics(metrics []*DaoMetricTypes.NodeMetricSample) error
  • func (r *NodeCpuRepository) ListMetrics(request DaoMetricTypes.ListNodeMetricsRequest) ([]*DaoMetricTypes.NodeMetric, error)
• type NodeMemoryRepository
  • func NewNodeMemoryRepositoryWithConfig(influxDBCfg InternalInflux.Config) *NodeMemoryRepository
  • func (r *NodeMemoryRepository) CreateMetrics(metrics []*DaoMetricTypes.NodeMetricSample) error
  • func (r *NodeMemoryRepository) ListMetrics(request DaoMetricTypes.ListNodeMetricsRequest) ([]*DaoMetricTypes.NodeMetric, error)

Constants

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

Types

type ApplicationCPURepository

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

func NewApplicationCPURepositoryWithConfig

func NewApplicationCPURepositoryWithConfig(influxDBCfg InternalInflux.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 InternalInflux.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 ClusterCPURepository

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

func NewClusterCPURepositoryWithConfig

func NewClusterCPURepositoryWithConfig(influxDBCfg InternalInflux.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 InternalInflux.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 InternalInflux.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 InternalInflux.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 ControllerCPURepository

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

func NewControllerCPURepositoryWithConfig

func NewControllerCPURepositoryWithConfig(influxDBCfg InternalInflux.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 InternalInflux.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 InternalInflux.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 InternalInflux.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 InternalInflux.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 InternalInflux.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)