util

Documentation

Index

• Constants
• Variables
• func FilterPrometheus(ctx context.Context, prom *monitor.Prometheus) error
• func GetClusterClient(ctx context.Context, clusterName string, ...) (kubernetes.Interface, error)
• func GetMonitoringClient(ctx context.Context, clusterName string, ...) (monitoringclient.Interface, error)
• func ParseES(esStr string) (esclient.Client, error)
• func ParseInfluxdb(influxdbStr string) (influxclient.Client, error)
• func RenameInfluxDB(name string) string
• func ValidateLabels(labels map[string]string) error
• type ClusterClientSets
• type ClusterCredentialSet
• type ClusterSet
• type ClusterStatisticSet
• type ComponentHealth
• type DynamicClientSet
• type GenericRouteOperator
• type GenericRuleOperator
• type MetricServerClientSets
• type PersistentOperator
• type ResourceCounter
• type RouteOperator
• type RuleGroupOperator
• type RuleOperator
• type WorkloadCounter
  • func (w *WorkloadCounter) Total() int

Constants

const (
	// DefaultAlertKey defines the default key for prometheus and alertmanager labels
	DefaultAlertKey = "alert"
)

const (
	// ProjectDatabaseName defines database name for project metrics
	ProjectDatabaseName = "projects"
)

Variables

var ClusterNameToClient sync.Map

ClusterNameToClient mapping cluster to kubernetes client clusterName => kubernetes.Interface

var ClusterNameToMonitor sync.Map

ClusterNameToMonitor mapping cluster to monitoring client clusterName => monitoringclient.Clientset

Functions

func FilterPrometheus

func FilterPrometheus(ctx context.Context, prom *monitor.Prometheus) error

FilterPrometheus is used to filter helm that do not belong to the tenant.

func GetClusterClient

func GetClusterClient(ctx context.Context, clusterName string, platformClient platformversionedclient.PlatformV1Interface) (kubernetes.Interface, error)

GetClusterClient get kubernetes client via cluster name

func GetMonitoringClient

func GetMonitoringClient(ctx context.Context, clusterName string, platformClient platformversionedclient.PlatformV1Interface) (monitoringclient.Interface, error)

GetMonitoringClient get monitoring client via cluster name

func ParseES

func ParseES(esStr string) (esclient.Client, error)

ParseES parse es address and user pwd

func ParseInfluxdb

func ParseInfluxdb(influxdbStr string) (influxclient.Client, error)

ParseInfluxdb parse influxdb address and pwd

func RenameInfluxDB

func RenameInfluxDB(name string) string

RenameInfluxDB replace invalid character for influxDB database

func ValidateLabels

func ValidateLabels(labels map[string]string) error

ValidateLabels returns if labels has default key, if not return error

Types

type ClusterClientSets

type ClusterClientSets map[string]*kubernetes.Clientset

type ClusterCredentialSet

type ClusterCredentialSet map[string]*platformv1.ClusterCredential

type ClusterSet

type ClusterSet map[string]*platformv1.Cluster

type ClusterStatisticSet

type ClusterStatisticSet map[string]*monitor.ClusterStatistic

type ComponentHealth

type ComponentHealth struct {
	Scheduler         bool
	ControllerManager bool
	Etcd              bool
}

type DynamicClientSet

type DynamicClientSet map[string]dynamic.Interface

type GenericRouteOperator

type GenericRouteOperator interface {
	RouteOperator
	PersistentOperator
}

GenericRouteOperator defines the generic alert route for alertmanager

type GenericRuleOperator

type GenericRuleOperator interface {
	RuleOperator
	RuleGroupOperator
	PersistentOperator
	LoadPromRule([]v1.RuleGroup) error
	SavePromRule() []v1.RuleGroup
}

GenericRuleOperator defines the generic rule operator for prometheus

type MetricServerClientSets

type MetricServerClientSets map[string]*metricsv.Clientset

type PersistentOperator

type PersistentOperator interface {
	Load(r io.Reader) error
	Save(w io.Writer) error
}

PersistentOperator defined the persistent method of rule operator

type ResourceCounter

type ResourceCounter struct {
	NodeTotal          int
	NodeAbnormal       int
	HasMetricServer    bool
	CPUUsed            float64
	CPURequest         float64
	CPULimit           float64
	CPUCapacity        float64
	CPUAllocatable     float64
	CPURequestRate     float64
	CPUAllocatableRate float64
	CPUUsage           float64
	MemUsed            int64
	MemRequest         int64
	MemLimit           int64
	MemCapacity        int64
	MemAllocatable     int64
	MemRequestRate     float64
	MemAllocatableRate float64
	MemUsage           float64
}

type RouteOperator

type RouteOperator interface {
	InsertRoute(route *alert_config.Route) (*alert_config.Route, error)
	DeleteRoute(alertValue string) (*alert_config.Route, error)
	UpdateRoute(alertValue string, route *alert_config.Route) (*alert_config.Route, error)
	GetRoute(alertValue string) (*alert_config.Route, error)
	ListRoute() ([]*alert_config.Route, error)
}

RouteOperator defines the CRUD interface of alert route

type RuleGroupOperator

type RuleGroupOperator interface {
	InsertRuleGroup(group *v1.RuleGroup) (int, *v1.RuleGroup, error)
	DeleteRuleGroup(groupName string) (*v1.RuleGroup, error)
	UpdateRuleGroup(groupName string, rev int, group *v1.RuleGroup) (int, *v1.RuleGroup, error)
	GetRuleGroup(groupName string) (int, *v1.RuleGroup, error)
	ListGroup() ([]*v1.RuleGroup, error)
}

RuleGroupOperator defines the CRUD interface of rule group operator

type RuleOperator

type RuleOperator interface {
	InsertRule(groupName string, rule *v1.Rule) (int, *v1.Rule, error)
	DeleteRule(groupName, recordName string) (*v1.Rule, error)
	UpdateRule(groupName, recordName string, rev int, rule *v1.Rule) (int, *v1.Rule, error)
	GetRule(groupName, recordName string) (int, *v1.Rule, error)
	ListRule(groupName string) ([]*v1.Rule, error)
}

RuleOperator defines the CRUD interface of rule record operator

type WorkloadCounter

type WorkloadCounter struct {
	Deployment  int
	DaemonSet   int
	StatefulSet int
	TApp        int
}

func (*WorkloadCounter) Total

func (w *WorkloadCounter) Total() int