cache

Documentation

Index

• Constants
• Variables
• func IsScheduled(pod *corev1.Pod) bool
• type Cacher
  • func NewCacher(platformClient platformversionedclient.PlatformV1Interface, ...) Cacher
• type Component

Constants

const (
	AllNamespaces = ""

	ClusterClientSet   = "ClusterClientSet"
	WorkloadCounter    = "WorkloadCounter"
	ResourceCounter    = "ResourceCounter"
	ClusterPhase       = "ClusterPhase"
	TenantID           = "TenantID"
	ClusterDisplayName = "ClusterDisplayName"
	ComponentHealth    = "ComponentHealth"

	TAppResourceName = "tapps"
	TAppGroupName    = "apps.tkestack.io"

	Scheduler         Component = "scheduler"
	ControllerManager Component = "controller-manager"
	Etcd              Component = "etcd-0"

	SchedulerPrefix         = "kube-scheduler-"
	ControllerManagerPrefix = "kube-controller-manager-"
	EtcdPrefix              = "etcd-"

	FirstLoad    = int32(1)
	NotFirstLoad = int32(0)
)

Variables

var (
	TAppResource = schema.GroupVersionResource{Group: TAppGroupName,
		Version: "v1", Resource: TAppResourceName}
	UpdateComponentStatusFunc = map[Component]updateComponent{
		Scheduler: func(componentStatus *corev1.ComponentStatus, health *util.ComponentHealth) {
			health.Scheduler = isHealthy(componentStatus)
		},
		ControllerManager: func(componentStatus *corev1.ComponentStatus, health *util.ComponentHealth) {
			health.ControllerManager = isHealthy(componentStatus)
		},
		Etcd: func(componentStatus *corev1.ComponentStatus, health *util.ComponentHealth) {
			health.Etcd = isHealthy(componentStatus)
		},
	}
)

Functions

func IsScheduled

func IsScheduled(pod *corev1.Pod) bool

Types

type Cacher

type Cacher interface {
	Reload()
	GetClusterOverviewResult(clusters []*platformv1.Cluster) *monitor.ClusterOverviewResult
}

func NewCacher

func NewCacher(platformClient platformversionedclient.PlatformV1Interface,
	businessClient businessversionedclient.BusinessV1Interface) Cacher

type Component

type Component string