c713a4f142
- pulse-lets-go-agent: collects metrics from PBX nodes via ESL (FreeSWITCH) or AMI (Asterisk) - AMI client (raw TCP) for Asterisk Manager Interface - Collector interface: collect, connect, subscribe hangup events, close - FreeSWITCH collector: show channels, max_sessions, idle_cpu - Asterisk collector: CoreShowChannels, CoreSettings - System collector: /proc/loadavg, /proc/stat (CPU idle) - Failure tracker: sliding window for call_failure_rate - NATS publisher: pulse.metrics.<node_id> every 5 seconds - Graceful shutdown, retry logic (5 failures → status=down) - Template configs for UC nodes (Asterisk) and ses-sip (FreeSWITCH)
71 lines
2.4 KiB
Go
71 lines
2.4 KiB
Go
package agent
|
||
|
||
import "github.com/pulse-lets-go/internal/models"
|
||
|
||
// PBXResult — результат сбора метрик от PBX (FS или Asterisk).
|
||
type PBXResult struct {
|
||
ActiveCalls int // текущее количество звонков
|
||
MaxCalls int // ёмкость (0 — не удалось получить)
|
||
IdleCPU float64 // idle CPU из PBX (0 — не удалось, fallback на system)
|
||
Status string // "ok" — PBX отвечает нормально
|
||
SIPGateway string // авто-определённый SIP-адрес
|
||
}
|
||
|
||
// Collector — интерфейс сбора метрик с PBX.
|
||
type Collector interface {
|
||
// Type возвращает тип PBX: "freeswitch" или "asterisk".
|
||
Type() string
|
||
|
||
// Connect подключается к PBX (ESL auth / AMI login).
|
||
Connect() error
|
||
|
||
// Collect собирает метрики с PBX.
|
||
// Возвращает PBXResult и ошибку, если сбор не удался.
|
||
Collect() (*PBXResult, error)
|
||
|
||
// ListenHangups подписывается на события завершения звонков
|
||
// для расчёта call_failure_rate.
|
||
ListenHangups(onHangup func(success bool))
|
||
|
||
// Close закрывает соединение с PBX.
|
||
Close()
|
||
}
|
||
|
||
// HangupEvent — событие завершения звонка.
|
||
type HangupEvent struct {
|
||
Success bool // true — звонок успешен, false — ошибка
|
||
Cause string // код причины (NORMAL_CLEARING, BUSY, и т.д.)
|
||
}
|
||
|
||
// ToMetric формирует models.NodeMetric из результатов сбора.
|
||
func ToMetric(nodeID string, pbx *PBXResult, sys *SystemStats, failureRate float64, sipGateway string, maxCallsDefault int) *models.NodeMetric {
|
||
// Определяем max_calls: приоритет PBX → конфиг
|
||
maxCalls := pbx.MaxCalls
|
||
if maxCalls <= 0 {
|
||
maxCalls = maxCallsDefault
|
||
}
|
||
// Определяем idle_cpu: приоритет PBX → system
|
||
idleCPU := pbx.IdleCPU
|
||
if idleCPU <= 0 {
|
||
idleCPU = sys.IdleCPU
|
||
}
|
||
|
||
// Определяем статус
|
||
status := pbx.Status
|
||
if pbx.Status == "ok" && sys.IdleCPU < 5 {
|
||
status = "degraded"
|
||
}
|
||
|
||
return &models.NodeMetric{
|
||
NodeID: nodeID,
|
||
TS: nowTS(),
|
||
Status: status,
|
||
ActiveCalls: pbx.ActiveCalls,
|
||
MaxCalls: maxCalls,
|
||
IdleCPU: idleCPU,
|
||
LoadAvg: sys.Load1,
|
||
CallFailureRate: failureRate,
|
||
SIPGateway: sipGateway,
|
||
}
|
||
}
|