thanos

package
v0.10.182 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2026 License: MIT Imports: 15 Imported by: 0

Documentation

Overview

Package thanos implements a read-only client for the Thanos Querier endpoints of external OpenShift clusters (v0.8.575, audit: docs/audit/thanos-multicluster-metrics-audit.md). It powers the /clusters surface: per-(namespace, pod) CPU + memory pulled straight from each cluster's platform monitoring stack — telemetry the applications themselves never emit.

Structure mirrors internal/tempo/client.go (the canonical external-query-service template): typed Settings blob in system_settings under "thanos_clusters", narrow settingsStore interface, LoadPersisted at boot + StartConfigRefresh 30s poll for multi-pod sync, SavePersisted + live Configure swap, and a masked Snapshot for the settings UI. The one structural difference: Settings holds a LIST of clusters, and TLS-verify varies per cluster — so instead of tempo's rebuild-on-toggle single client, this package uses the Zoom two-singleton pattern (notify.go:1106): one verifying client + one lazily-built insecure twin, picked per request via thanosClientFor.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func PodNamesRegex added in v0.10.136 

func PodNamesRegex(names []string) (re string, truncated bool)

func ValidJMXMetric added in v0.9.140 

func ValidJMXMetric(m string) bool

ValidJMXMetric — ham metrik adının güvenli JMX adı olup olmadığı.

func ValidThanosLabelName added in v0.10.128 

func ValidThanosLabelName(s string) bool

ValidThanosLabelName — PUT doğrulaması: boş ya da Prometheus etiket adı.

Types

type AlertRow added in v0.9.36 

type AlertRow struct {
	AlertName string `json:"alertName"`
	Severity  string `json:"severity"`
	Namespace string `json:"namespace,omitempty"`
	Pod       string `json:"pod,omitempty"`
	AgeSec    int64  `json:"ageSec,omitempty"`
}

AlertRow — firing bir alert (v0.9.36, design handoff B3 + panel). AgeSec best-effort (ALERTS_FOR_STATE join'i; yoksa 0).

type ClusterConfig 

type ClusterConfig struct {
	// ID — v0.10.128: opak, DEĞİŞMEZ kimlik ("c-" + 8 hex). Entity
	// hiyerarşisinin kökü (cluster_identity.go); sunucu sahipli — PUT
	// istemciden gelen ID'yi ada göre saklı kayıttan alır, boşsa türetir.
	ID   string `json:"id,omitempty"`
	Name string `json:"name"`
	URL  string `json:"url"`
	// ThanosLabelName/Value — v0.10.128: TEK querier'ın önünde N cluster
	// varken seriyi bu cluster'a bağlayan external label. Ad BOŞ =
	// enjeksiyon yok = cluster başına URL modeli (eski davranış). Değer
	// boşsa Name.
	ThanosLabelName  string `json:"thanosLabelName,omitempty"`
	ThanosLabelValue string `json:"thanosLabelValue,omitempty"`
	// SpanClusterValue — v0.10.128: span `cluster` kolonunda bu cluster'ın
	// değeri; boşsa Name (bugünkü join anahtarı). v0.10.139'dan itibaren
	// LİSTENİN ilk elemanı (SpanClusterKeys) — eski kayıtlar okunmaya devam
	// eder, yazımda liste kanoniktir.
	SpanClusterValue string `json:"spanClusterValue,omitempty"`
	// SpanClusterValues — v0.10.139 (otomatik eşleme brief'i): bir kayıt
	// birden çok span cluster değeri taşır (geçiş dönemleri, farklı
	// Collector konfigürasyonları). Teklik: bir değer aynı anda TEK kayda
	// (ReconcileClusterSettings reddeder, bağlı kaydı söyler).
	SpanClusterValues []string `json:"spanClusterValues,omitempty"`
	// ThanosLabelSource — v0.10.139: "auto" (algılandı) | "manual" | "" (eski
	// kayıt = elle). Auto değer UI'da rozetlenir, elle geçersiz kılınabilir;
	// periyodik doğrulama eşleşmezse uyarı üretir, kaydı bozmaz.
	ThanosLabelSource     string `json:"thanosLabelSource,omitempty"`
	ThanosLabelDetectedAt int64  `json:"thanosLabelDetectedAt,omitempty"` // unix ms
	// AuthType — none | bearer. Bearer covers the standard
	// OpenShift path: a ServiceAccount token with the
	// cluster-monitoring-view ClusterRole against the
	// oauth-proxy'd thanos-querier route.
	AuthType string `json:"authType,omitempty"`
	// Token — never echoed; Snapshot exposes HasToken only.
	Token string `json:"token,omitempty"`
	// NamespaceFilter is a PromQL regex injected as
	// namespace=~"..." into every query — the cardinality shield
	// that keeps a 10k-pod estate from riding home in one
	// response. Empty = all namespaces (topk still caps rows).
	NamespaceFilter    string `json:"namespaceFilter,omitempty"`
	InsecureSkipVerify bool   `json:"insecureSkipVerify,omitempty"`
	Enabled            bool   `json:"enabled"`
}

ClusterConfig is one remote cluster entry. Name doubles as the APM join key: it must equal the cluster value spans carry (k8s.cluster.name / openshift.cluster.name — clusterDeriveExpr) for the service→cluster pivot to light up; the Settings UI suggests observed names for exactly that reason.

func ApplyDetection added in v0.10.140 

func ApplyDetection(c ClusterConfig, d Detection, now time.Time) (ClusterConfig, error)

ApplyDetection — saf: algılamayı kayda yazar (auto + zaman damgası).

func SpanClusterOwner added in v0.10.139 

func SpanClusterOwner(cfg Settings, value string) (ClusterConfig, bool)

SpanClusterOwner — değerin bağlı olduğu kayıt (teklik kuralının okuma yüzü).

func (ClusterConfig) EffectiveID added in v0.10.128 

func (c ClusterConfig) EffectiveID() string

EffectiveID — kayıtlı ID ya da Name'den türetilmiş id.

func (ClusterConfig) EffectiveThanosLabel added in v0.10.128 

func (c ClusterConfig) EffectiveThanosLabel() (string, string)

EffectiveThanosLabel — (etiket adı, değeri). Ad boşsa ("", "") = enjeksiyon yok. Değer boşsa Name.

func (ClusterConfig) ExplicitSpanClusterValues added in v0.10.139 

func (c ClusterConfig) ExplicitSpanClusterValues() []string

ExplicitSpanClusterValues — kayda AÇIKÇA yazılmış değerler (Name yedeği HARİÇ). Snapshot/Settings formu bunu gösterir: yedeği değer gibi göstermek, yeniden kaydetmede eski adı kalıcı değere çevirirdi (inceleme).

func (ClusterConfig) MatchesSpanCluster added in v0.10.139 

func (c ClusterConfig) MatchesSpanCluster(v string) bool

MatchesSpanCluster — değer bu kayda mı ait.

func (ClusterConfig) SpanClusterKey added in v0.10.128 

func (c ClusterConfig) SpanClusterKey() string

SpanClusterKey — span `cluster` kolonunda bu cluster'ın BİRİNCİL değeri (listenin ilki). Eşleşme için SpanClusterKeys / MatchesSpanCluster.

func (ClusterConfig) SpanClusterKeys added in v0.10.139 

func (c ClusterConfig) SpanClusterKeys() []string

SpanClusterKeys — v0.10.139: kaydın TÜM span cluster değerleri (SpanClusterValue + SpanClusterValues, tekil, boşlar atılmış); hiçbiri yoksa Name. Okuma tarafı haritaları BUNU anahtarlar — atama geriye dönük çalışır (tarihsel entity_seen satırları okuma anında bağlanır).

type ClusterSnapshot 

type ClusterSnapshot struct {
	ID                    string   `json:"id,omitempty"`
	Name                  string   `json:"name"`
	URL                   string   `json:"url"`
	ThanosLabelName       string   `json:"thanosLabelName,omitempty"`
	ThanosLabelValue      string   `json:"thanosLabelValue,omitempty"`
	SpanClusterValue      string   `json:"spanClusterValue,omitempty"`
	SpanClusterValues     []string `json:"spanClusterValues,omitempty"`
	ThanosLabelSource     string   `json:"thanosLabelSource,omitempty"`
	ThanosLabelDetectedAt int64    `json:"thanosLabelDetectedAt,omitempty"`
	// LabelCheck — v0.10.140: periyodik doğrulama sonucu (bellek; auto
	// etiketli kayıtlar). nil = henüz denetlenmedi.
	LabelCheck         *LabelCheck `json:"labelCheck,omitempty"`
	AuthType           string      `json:"authType,omitempty"`
	HasToken           bool        `json:"hasToken"`
	NamespaceFilter    string      `json:"namespaceFilter,omitempty"`
	InsecureSkipVerify bool        `json:"insecureSkipVerify,omitempty"`
	Enabled            bool        `json:"enabled"`
}

ClusterSnapshot mirrors ClusterConfig with the token masked.

type ClusterSummary added in v0.8.586 

type ClusterSummary struct {
	Cluster      string  `json:"cluster"`
	Nodes        int     `json:"nodes,omitempty"`
	Pods         int     `json:"pods,omitempty"`
	CPUUsedCores float64 `json:"cpuUsedCores,omitempty"`
	MemUsedBytes float64 `json:"memUsedBytes,omitempty"`
	// v0.9.9 — cluster toplam network hızı (node-exporter, lo hariç).
	// Best-effort: seri yoksa 0 kalır, UI kartı hiç render etmez.
	NetInBps  float64 `json:"netInBps,omitempty"`
	NetOutBps float64 `json:"netOutBps,omitempty"`
	// v0.9.30 (design handoff B1) — kapasite (%), pod-fazı (donut),
	// firing-alert sayısı (banner/KPI). Hepsi best-effort; 0 =
	// kube-state-metrics/ALERTS serisi yok, UI ilgili görseli gizler.
	CPUCapacityCores float64 `json:"cpuCapacityCores,omitempty"`
	MemCapacityBytes float64 `json:"memCapacityBytes,omitempty"`
	PodsRunning      int     `json:"podsRunning,omitempty"`
	PodsPending      int     `json:"podsPending,omitempty"`
	PodsFailed       int     `json:"podsFailed,omitempty"`
	AlertsCritical   int     `json:"alertsCritical,omitempty"`
	AlertsWarning    int     `json:"alertsWarning,omitempty"`
}

ClusterSummary — genel görünüm kartının verisi (v0.8.586, redesign audit §3.1). Her alan kendi sorgusundan BEST-EFFORT dolar: token tenancy-port'a bağlıysa node ailesi boş kalır ama pod sayısı yine gelir (kısmi kart > hata kartı). Dört sorgunun DÖRDÜ de başarısızsa cluster erişilemez sayılır ve hata döner.

type ContainerStatus added in v0.10.135 

type ContainerStatus struct {
	Name           string `json:"name"`
	Ready          bool   `json:"ready"`
	ReadyKnown     bool   `json:"readyKnown"`
	Restarts       int    `json:"restarts"`
	WaitingReason  string `json:"waitingReason,omitempty"`
	LastTermReason string `json:"lastTermReason,omitempty"`
}

type DeploymentRow added in v0.9.22 

type DeploymentRow struct {
	Cluster    string   `json:"cluster"`
	Namespace  string   `json:"namespace"`
	Deployment string   `json:"deployment"`
	Pods       int      `json:"pods"`
	CPUCores   float64  `json:"cpuCores"`
	MemBytes   float64  `json:"memBytes"`
	PodNames   []string `json:"podNames"`
	// v0.9.39 — KSM replicas/status (best-effort). Status boş = KSM
	// ailesi bu iş yükü için yok (heuristik eşleşen StatefulSet/
	// DaemonSet dahil); ready/desired yalnız Status doluyken anlamlı.
	DesiredReplicas int    `json:"desiredReplicas"`
	ReadyReplicas   int    `json:"readyReplicas"`
	Status          string `json:"status,omitempty"`
}

DeploymentRow — bir namespace içindeki iş yükü (Deployment/STS/DS) rollup satırı (v0.9.22). PodNames pod tablosunun ?deployment= süzgecini besler (istemci üyelikle süzer — ad-önek sezgiseli değil, gerçek eşleme).

type Detection added in v0.10.140 

type Detection struct {
	Label      string              `json:"label"`
	Value      string              `json:"value"`
	Ambiguous  bool                `json:"ambiguous"`
	Candidates map[string][]string `json:"candidates,omitempty"` // etiket → değerler (belirsizlikte ya da bilgi için)
	Series     int                 `json:"series"`
}

func PickClusterLabel added in v0.10.140 

func PickClusterLabel(rows []map[string]string, name string) Detection

PickClusterLabel — saf; tablo-testli. rows: her seri için etiket seti.

type LabelCheck added in v0.10.140 

type LabelCheck struct {
	OK        bool      `json:"ok"`
	Series    int       `json:"series"`
	CheckedAt time.Time `json:"checkedAt"`
	Error     string    `json:"error,omitempty"`
}

type NamedSeries added in v0.9.35 

type NamedSeries struct {
	Name   string       `json:"name"`
	Points []ValuePoint `json:"points"`
}

NamedSeries — adlandırılmış çok-serili trend (v0.9.35): total modda tek seri (Name=""), byNode modda instance başına.

type NamespaceRow added in v0.8.588 

type NamespaceRow struct {
	Cluster   string  `json:"cluster"`
	Namespace string  `json:"namespace"`
	Pods      int     `json:"pods,omitempty"`
	CPUCores  float64 `json:"cpuCores"`
	MemBytes  float64 `json:"memBytes"`
	// v0.9.37 (B4) — restart toplamı + failing pod sayısı (best-effort).
	Restarts int `json:"restarts,omitempty"`
	Failing  int `json:"failing,omitempty"`
}

NamespaceRow — bir namespace'in rollup satırı (v0.8.588, redesign audit §3.3). Ayrı sorgudan gelir — pod listesinin topk kesmesinden ETKİLENMEZ (toplamlar tam).

type NetTrendPoint added in v0.9.9 

type NetTrendPoint struct {
	Bucket int64   `json:"bucket"`
	InBps  float64 `json:"inBps"`
	OutBps float64 `json:"outBps"`
}

NetTrendPoint — cluster network throughput trendi (v0.9.9): dakika bucket'ında in/out byte/s.

type NodeRow added in v0.8.582 

type NodeRow struct {
	Cluster  string  `json:"cluster"`
	Node     string  `json:"node"`
	CPUCores float64 `json:"cpuCores"`
	MemBytes float64 `json:"memBytes"`
	CPUPct   float64 `json:"cpuPct,omitempty"`
	MemPct   float64 `json:"memPct,omitempty"`
	// v0.9.9 — node network hızı (node-exporter, lo hariç; best-effort).
	NetInBps  float64 `json:"netInBps,omitempty"`
	NetOutBps float64 `json:"netOutBps,omitempty"`
	// v0.9.37 (B4) — rol (heatmap dot + Nodes tab); kube_node_role.
	Role string `json:"role,omitempty"`
}

NodeRow — bir node'un anlık CPU/memory kullanımı (v0.8.582, audit: clusters-node-metrics-audit.md §3). Node = kube_node_info eşleşirse gerçek node adı, yoksa instance (ip:port). Pct'ler kendi paydalarına oran: CPUPct çekirdek sayısına (best-effort — 0 = bilinmiyor), MemPct MemTotal'a (zorunlu aileden, hep dolu).

type PodRow 

type PodRow struct {
	Cluster   string  `json:"cluster"`
	Namespace string  `json:"namespace"`
	Pod       string  `json:"pod"`
	CPUCores  float64 `json:"cpuCores"`
	MemBytes  float64 `json:"memBytes"`
	CPUPct    float64 `json:"cpuPct,omitempty"`
	MemPct    float64 `json:"memPct,omitempty"`
	// Request-based percentages (v0.8.580) — provisioning accuracy
	// axis, alongside the limit-based throttle/OOM axis above. Can
	// legitimately exceed 100 (pod using more than it requested) —
	// deliberately NOT clamped like the limit pcts; the overshoot
	// IS the signal. 0 = requests not exposed (best-effort).
	CPUPctOfReq float64 `json:"cpuPctOfReq,omitempty"`
	MemPctOfReq float64 `json:"memPctOfReq,omitempty"`
	// Ham limit/request değerleri (v0.9.3, trend-upgrade audit §1
	// düzeltmesi): threshold referans ÇİZGİLERİ mutlak değer ister
	// (cores/bytes ekseninde) — yüzdeler yetmez. acc'ta zaten
	// vardı, satıra indirildi; 0 = bilinmiyor.
	CPULimitCores   float64 `json:"cpuLimitCores,omitempty"`
	MemLimitBytes   float64 `json:"memLimitBytes,omitempty"`
	CPURequestCores float64 `json:"cpuRequestCores,omitempty"`
	MemRequestBytes float64 `json:"memRequestBytes,omitempty"`
	// v0.9.9 — pod network hızı (cAdvisor, best-effort).
	NetInBps  float64 `json:"netInBps,omitempty"`
	NetOutBps float64 `json:"netOutBps,omitempty"`
	// Service (v0.9.11) — Coremetry servis eşleşmesi (host_name =
	// pod adı köprüsü). API katmanı doldurur (chstore.PodServiceMap
	// + pickPodService); thanos paketi bu alana yazmaz. Boş =
	// eşleşme yok (instrument edilmemiş / infra pod'u / belirsiz).
	Service string `json:"service,omitempty"`
	// v0.9.37 (B4) — faz + restart (Pods tab Status/Restarts).
	// Best-effort: kube-state-metrics yoksa Phase="" / Restarts=0.
	// v0.9.371 — Restarts'ta omitempty YOK artık: gerçek 0 wire'da
	// görünür (Clusters sayfası 0'ı '—' çiziyordu). Bilinmezlik ayrı
	// bayrak: restart SERİSİ hiç gelmediyse (KSM yok ya da 1000-seri
	// parse tavanı) RestartsUnknown=true — 0 sağlıklıymış gibi değil,
	// '—' bilinmiyor gibi çizilir. Üyelik = bilgi: KSM 0 restart'lı
	// pod için de seri döndürür.
	Phase           string `json:"phase,omitempty"`
	Restarts        int    `json:"restarts"`
	RestartsUnknown bool   `json:"restartsUnknown,omitempty"`
	// v0.9.1276 (Dynatrace-parite #5) — son sonlanma sebebi
	// (kube_pod_container_status_last_terminated_reason), pod
	// satırında rozet. Boş = hiç sonlanmamış YA DA KSM yok:
	// RestartsUnknown'dan BAĞIMSIZ best-effort — restart sayısı
	// bilinirken sebep bilinmeyebilir (ve tersi). Pod'un birden çok
	// container'ı farklı sebep taşıyabilir; satıra en kötüsü çıkar
	// (worseTermReason).
	LastTermReason string `json:"lastTermReason,omitempty"`
}

PodRow is one (cluster, namespace, pod) sample from the merged instant queries. CPU is CORES (rate of cpu-seconds), not the 0-1 utilization ratio HostRow carries — deliberately a separate shape (audit §7). Pct fields are 0 when the cluster doesn't expose kube-state-metrics limits — same "0 = unknown" contract HostRow.MemPct already established.

type PodSeriesTrend added in v0.9.3 

type PodSeriesTrend struct {
	Pod   string       `json:"pod"`
	Trend []TrendPoint `json:"trend"`
}

PodSeriesTrend — multi-pod görünümün seri birimi (v0.9.3): bir pod'un dakika-bucket trendi.

type Sample added in v0.10.132 

type Sample struct {
	Labels map[string]string
	Value  float64
}

Sample — anlık sorgu satırı: etiket seti + değer (entity syncer için dışa açık şekil; promSeries paket-içi kalır).

type Service 

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

Service holds the live cluster list. Concurrency contract is tempo's: RWMutex around the config, background refresh poll keeping multi-pod deployments in sync via the shared blob.

func New 

func New() *Service

func (*Service) ClusterByID added in v0.10.128 

func (s *Service) ClusterByID(id string) (ClusterConfig, bool)

ClusterByID — etkin kayıt, id ile.

func (*Service) ClusterByName 

func (s *Service) ClusterByName(name string) (ClusterConfig, bool)

ClusterByName returns the ENABLED cluster entry for name.

func (*Service) ClusterByRef added in v0.10.128 

func (s *Service) ClusterByRef(ref string) (ClusterConfig, bool)

ClusterByRef — `?cluster=` id YA DA ad taşıyabilir (eski URL'ler ad taşır; yeni yüzeyler id). Önce id, sonra ad.

func (*Service) Configure 

func (s *Service) Configure(cfg Settings)

Configure swaps the live cluster list.

func (*Service) CurrentSettings 

func (s *Service) CurrentSettings() Settings

CurrentSettings — full config INCLUDING tokens; only for the PUT handler's stored-token merge. Never echo over the wire (tempo contract).

func (*Service) DeployTrend added in v0.9.50 

func (s *Service) DeployTrend(ctx context.Context, c ClusterConfig, namespace, deploy, metric string, byPod bool, from, to time.Time) ([]NamedSeries, int, error)

DeployTrend — bir deployment'ın pod'larına kapsanmış CPU/Mem trendi (v0.9.50, design handoff §8 — Servis → Infrastructure sekmesi). ResourceTrend'in deployment-kapsamlı aynası: total tek seri, byPod modunda sum by (pod) ham çekilir ve top-8 seçimi ortalamaya göre Go'da yapılır (topk'siz — v0.9.3 adım-kayması notu). Metrik ailesi yoksa boş döner; UI grafiği gizler (görünmez-düşer). İkinci dönüş (v0.9.539): kesme ÖNCESİ seri sayısı — UI "N / M pod" rozetini bununla çizer (NamespacePodsTrend'in aynı sözleşmesi).

func (*Service) DeploymentMetrics added in v0.9.22 

func (s *Service) DeploymentMetrics(ctx context.Context, c ClusterConfig, namespace string) ([]DeploymentRow, error)

DeploymentMetrics — namespace'in pod başına cpu/mem'ini (zorunlu 2 sorgu) kube-state-metrics owner eşlemesiyle (best-effort 2 sorgu) iş yüküne toplar. Fallback zinciri (deployment audit uyarlaması — probe yerine runtime): tam join → rs-hash soyma → pod-adı sezgiseli → "(unassigned)".

func (*Service) DetectClusterLabel added in v0.10.140 

func (s *Service) DetectClusterLabel(ctx context.Context, c ClusterConfig) (Detection, error)

DetectClusterLabel — ENJEKSİYONSUZ sorgu + saf seçim.

func (*Service) FiringAlerts added in v0.9.36 

func (s *Service) FiringAlerts(ctx context.Context, c ClusterConfig) ([]AlertRow, error)

FiringAlerts — firing alert listesi (kritik-önce). ALERTS (authoritative firing set) + ALERTS_FOR_STATE (best-effort yaş, join by label). Metrik yoksa boş liste; UI paneli gizler.

func (*Service) HaproxyTrend added in v0.9.534 

func (s *Service) HaproxyTrend(ctx context.Context, c ClusterConfig, namespace, kind string, from, to time.Time) ([]NamedSeries, error)

HaproxyTrend — v0.9.534. Namespace'in route'larına router (HAProxy) gözünden trend: kind = "2xx" | "5xx" (yanıt oranı, req/s) | "latency" (backend ortalama, ms). DeployTrend'in aynası: query_range, seri adı route etiketi, top-N seçimi ortalamaya göre Go'da (topk'siz — v0.9.3 adım-kayması notu). Metrik ailesi cluster'da yoksa boş döner; UI bölümü gizler (görünmez-düşer).

func (*Service) HasEnabledClusters 

func (s *Service) HasEnabledClusters() bool

HasEnabledClusters gates the /clusters surface: false → the page shows its Empty state without any HTTP attempts.

func (*Service) InstantSamples added in v0.10.132 

func (s *Service) InstantSamples(ctx context.Context, c ClusterConfig, expr string) ([]Sample, error)

InstantSamples — matcher'lı anlık sorgu (doQuery enjeksiyonu). Görev kısıtı: Thanos'a giden her sorgu seçici taşır — expr'in seçicisi çağıranın sorumluluğu (entity.SnapshotQueries); cluster matcher burada.

func (*Service) JMXMetricNames added in v0.9.144 

func (s *Service) JMXMetricNames(ctx context.Context, c ClusterConfig, namespace, deploy string) ([]string, error)

JMXMetricNames — bir deployment'ın Thanos'ta taşıdığı jvm_/jboss_ metrik ADLARINI keşfeder (v0.9.144 auto-discovery). count by (__name__) instant sorgusu; her serinin __name__ label'ını toplar, sıralı+tekilleştirir. Boş dönmesi = cluster'da servisin JMX'i yok (UI o cluster'ı göstermez).

func (*Service) JMXTrend added in v0.9.140 

func (s *Service) JMXTrend(ctx context.Context, c ClusterConfig, namespace, deploy, metric string, byPod bool, podFilter string, from, to time.Time) ([]NamedSeries, int, error)

JMXTrend — keşfedilen bir JBoss/JVM JMX metriğinin trendi (v0.9.140, selector+discovery v0.9.144). DeployTrend'in JMX aynası: aynı query_range + Go-tarafı top-8 seçimi (topk'siz), tek fark seri adının `pod` label'ından okunması ve JMX-özel selector (jmxTrendQuery). Metrik ailesi yoksa boş döner; UI grafiği gizler (görünmez-düşer). İkinci dönüş (v0.9.370): kesme ÖNCESİ toplam seri sayısı. Saf pod grouping'te top-8 kesilir (aşağıda) ve UI "8 / N pod" diyebilsin diye N burada döner — sekmenin var olma sebebi "hangi pod'un heap'i dolu" sorusuyken en DÜŞÜK ortalamalı pod'ların sessizce düşmesi, pencere sonunda OOM'a tırmanan pod'u da düşürebiliyordu (ortalaması düşük).

func (*Service) LabelCheckTick added in v0.10.140 

func (s *Service) LabelCheckTick(ctx context.Context)

func (*Service) LabelCheckTickPersist added in v0.10.140 

func (s *Service) LabelCheckTickPersist(ctx context.Context, store labelCheckStore)

LabelCheckTickPersist — denetim + blob'a yaz (lider ticker'ı).

func (*Service) LoadLabelChecks added in v0.10.140 

func (s *Service) LoadLabelChecks(ctx context.Context, store labelCheckStore) error

LoadLabelChecks — blob'dan belleğe (her pod; api rolü lider değildir).

func (*Service) LoadPersisted 

func (s *Service) LoadPersisted(ctx context.Context, store settingsStore) error

LoadPersisted hydrates from system_settings. Missing blob = empty list (HasEnabledClusters reports false; handlers 404).

func (*Service) NamespaceMetrics added in v0.8.588 

func (s *Service) NamespaceMetrics(ctx context.Context, c ClusterConfig) ([]NamespaceRow, error)

NamespaceMetrics — cpu+mem zorunlu (2 sorgu), pod sayısı best-effort (1 sorgu; aynı metrik ailesi, pratikte hep döner).

func (*Service) NamespacePodsTrend added in v0.9.3 

func (s *Service) NamespacePodsTrend(ctx context.Context, c ClusterConfig, namespace string, from, to time.Time) ([]PodSeriesTrend, int, error)

NamespacePodsTrend — namespace'in pod başına dakika-bucket trendleri (v0.9.3). Sorgu topk'siz (adım-başına set kayması kırar — promql.go notu); top-10 seçimi ortalama CPU'ya göre Go'da, cpu+mem AYNI pod setine filtrelenir. İkinci dönüş: kesme öncesi toplam pod sayısı ("top 10 of N" etiketi için).

func (*Service) NamespaceTrend added in v0.9.2 

func (s *Service) NamespaceTrend(ctx context.Context, c ClusterConfig, namespace string, from, to time.Time) ([]TrendPoint, error)

NamespaceTrend — PodTrend'in namespace-scoped aynası (v0.9.2): aynı dakika-bucket sözleşmesi, pod pini yok — namespace toplamı.

func (*Service) NetworkTrend added in v0.9.9 

func (s *Service) NetworkTrend(ctx context.Context, c ClusterConfig, from, to time.Time) ([]NetTrendPoint, error)

NetworkTrend — cluster toplam ağ hızının dakika-bucket trendi (Overview throughput grafiği). rangeTrend'in net karşılığı; iki sorgu da zorunlu (grafiğin kendisi bu — best-effort'luk üst katmanda: seri boşsa UI grafiği hiç göstermez).

func (*Service) NodeMetrics added in v0.8.582 

func (s *Service) NodeMetrics(ctx context.Context, c ClusterConfig) ([]NodeRow, error)

NodeMetrics — PodMetrics'in node-scope aynası: 3 zorunlu sorgu (cpu used, mem total, mem avail) + 2 best-effort (çekirdek sayısı, kube_node_info ad güzelleştirmesi). Sabit 5 sorgu/cluster.

func (*Service) NodeResourceTrend added in v0.10.142 

func (s *Service) NodeResourceTrend(ctx context.Context, c ClusterConfig, metric, host string, from, to time.Time) ([]NamedSeries, error)

NodeResourceTrend — v0.10.142: tek node (topk yok); seri adı instance host.

func (*Service) PodContainers added in v0.10.135 

func (s *Service) PodContainers(ctx context.Context, c ClusterConfig, ns, pod string) ([]ContainerStatus, error)

func (*Service) PodMetrics 

func (s *Service) PodMetrics(ctx context.Context, c ClusterConfig, podRe string) ([]PodRow, bool, error)

PodMetrics runs the per-cluster instant queries (CPU rate, working-set memory, cpu/mem limits) and merges them by (namespace, pod). Exactly four queries per cluster regardless of pod count — never a query per pod (audit §4). PodMetrics'in ikinci dönüşü truncated: cpu/mem serilerinden biri podListLimit tavanına DAYANDIYSA liste cluster'ın tamamı değildir — düşük trafikli pod'lar topk dışında kalmıştır. v0.9.369: bu bayrak olmadan 3000-pod'luk cluster'da sakin bir servisin sekmesi kendinden emin "Pods (0)" diyordu; süzme istemcide, kesme sunucuda ve İFŞASIZDI. podRe — v0.9.536: boş = tüm cluster (eski davranış, /clusters sayfası); dolu = hedefli seçici pod=~"<re>" (servis sekmeleri). Hedefli modda topk(500) servisin KENDİ pod'ları içinde işler — düşük trafikli pod cluster-geneli kesime takılmaz (operator-reported: BFF pod'ları 0.001 core'da top-500'e giremiyordu, "No pods matched").

func (*Service) PodTrend 

func (s *Service) PodTrend(ctx context.Context, c ClusterConfig, namespace, pod string, from, to time.Time) ([]TrendPoint, error)

PodTrend returns per-bucket CPU + memory for ONE pod (drawer path — bounded by construction). Bucket = adaptif step (stepForWindow, v0.9.26): dar pencerede 15s'e kadar iner.

func (*Service) ProbeCluster added in v0.10.128 

func (s *Service) ProbeCluster(ctx context.Context, c ClusterConfig) (int, error)

ProbeCluster — rozet: matcher'lı `count(kube_node_info)` kaç seri döndürüyor? (Settings "Test label"; 10 s deadline çağıranda.) Etiket adı boşsa matcher yok — yine de URL/token'ı sınar.

func (*Service) ResetLabelChecks added in v0.10.140 

func (s *Service) ResetLabelChecks(ctx context.Context, store labelCheckStore)

LabelCheckTick — auto etiketli (ya da etiketli) her etkin kayıt için matcher'lı probe; sonuç bellekte, Snapshot ile ilan edilir. Worker rolünde lider ticker'dan çağrılır (main.go). ResetLabelChecks — ayar kaydedilince bayat uyarılar düşer (inceleme); bir sonraki denetim (kaydın hemen ardından tetiklenir) taze sonucu yazar. store verilirse blob da boşaltılır (diğer pod'lar 30 s içinde görür).

func (*Service) ResourceTrend added in v0.9.35 

func (s *Service) ResourceTrend(ctx context.Context, c ClusterConfig, metric string, byNode bool, from, to time.Time) ([]NamedSeries, error)

ResourceTrend — Overview CPU/Mem area chart verisi. metric "cpu"|"mem"; byNode false→tek toplam seri, true→top-N instance. Bucket adaptif step'e bağlı (stepForWindow); byNode'da instance adı instanceHost ile güzelleştirilir.

func (*Service) SavePersisted 

func (s *Service) SavePersisted(ctx context.Context, store settingsStore, cfg Settings) error

SavePersisted writes the merged config (handler does the empty-token-preserves-stored merge first) and swaps it live.

func (*Service) Snapshot 

func (s *Service) Snapshot() Snapshot

Snapshot returns the masked config for the settings UI.

func (*Service) StartConfigRefresh 

func (s *Service) StartConfigRefresh(ctx context.Context, store settingsStore, interval time.Duration)

StartConfigRefresh — multi-pod blob sync, 30s default (tempo v0.5.324 precedent). Run as a goroutine from main().

func (*Service) StartLabelCheckRefresh added in v0.10.140 

func (s *Service) StartLabelCheckRefresh(ctx context.Context, store labelCheckStore, interval time.Duration)

StartLabelCheckRefresh — 30 s'de bir blob'u yükle (StartConfigRefresh emsali).

func (*Service) Summary added in v0.8.586 

func (s *Service) Summary(ctx context.Context, c ClusterConfig) (ClusterSummary, error)

Summary — kart başına sabit 4 skaler sorgu (topk'li vektör yok; pod sayısı topk kesmesiz TAM).

type Settings 

type Settings struct {
	Clusters []ClusterConfig `json:"clusters"`
}

Settings is the persisted blob: the whole cluster list, written atomically (custom_roles convention — no per-row races at the realistic N≤20 scale).

func BackfillClusterIDs added in v0.10.128 

func BackfillClusterIDs(cfg Settings) (Settings, bool)

BackfillClusterIDs — boş ID'leri türetir. Girdi değişmez; changed=true ise çağıran tam-blob yazar (SavePersisted). Adsız kayıt dokunulmaz.

func ReconcileClusterSettings added in v0.10.128 

func ReconcileClusterSettings(in, cur Settings) (Settings, error)

ReconcileClusterSettings — PUT'un kimlik/gizli birleştirmesi (saf).

ID sunucu sahipli: 

(a) gelen ID saklı bir kayda aitse → yeniden adlandırma: o id ve
    (gelen token boşsa) o kaydın token'ı korunur;
(b) aynı AD saklıysa → saklı id + (boş token yerine) saklı token;
(c) yeni kayıt → Name'den türetilmiş id; istemcinin gönderdiği
    yabancı id alınmaz.

Etiket adı Prometheus etiket sözdizimine uymuyorsa hata (boş serbest).

type Snapshot 

type Snapshot struct {
	Clusters []ClusterSnapshot `json:"clusters"`
}

Snapshot is what GET /api/settings/thanos returns.

type TrendPoint 

type TrendPoint struct {
	Bucket   int64   `json:"bucket"`
	CPUCores float64 `json:"cpuCores"`
	MemBytes float64 `json:"memBytes"`
}

TrendPoint matches HostTrendPoint's bucket contract: unix SECONDS on minute boundaries, so the frontend drawer reuses the same rendering path.

type ValuePoint added in v0.9.35 

type ValuePoint struct {
	Bucket int64   `json:"bucket"`
	Value  float64 `json:"value"`
}

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.