Versions in this module Expand all Collapse all v0 v0.9.0 Oct 20, 2021retracted Changes in this version + const ClusterAgeCacheKey + const NoExpiration + var KubernetesResourceCache = cache.New(defaultExpire, defaultPurge) + func BuildStatsKey(nodeType NodeType) string + func ChunkRange(numberOfElements, chunkCount, chunkSize, counter int) (int, int) + func GroupSize(msgs, maxPerMessage int) int + func SkipKubernetesResource(uid types.UID, resourceVersion string, nodeType NodeType) bool + type CheckStats struct + CacheHits int + CacheMiss int + type NodeType int + const K8sCluster + const K8sClusterRole + const K8sClusterRoleBinding + const K8sCronJob + const K8sDaemonSet + const K8sDeployment + const K8sJob + const K8sNode + const K8sPersistentVolume + const K8sPersistentVolumeClaim + const K8sPod + const K8sReplicaSet + const K8sRole + const K8sRoleBinding + const K8sService + const K8sServiceAccount + const K8sStatefulSet + func NodeTypes() []NodeType + func (n NodeType) Orchestrator() string + func (n NodeType) String() string + func (n NodeType) TelemetryTags() []string
Go to main page