metrics

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

type CollectorConfig struct {
	// Table — full outbox table name (`<schema>.<table>`), used both for the
	// scan query and as the metric `table` label.
	Table string
	// MaxAttempts — poison threshold; a pending row with attempt_count >=
	// MaxAttempts is counted as poisoned. Default 10 (matches drainer default).
	MaxAttempts int
	// Interval — how often Run scans (default 15s). Scan can also be called
	// directly (tests / on-demand).
	Interval time.Duration
	// Directions — OPTIONAL per-direction breakdown: direction name → the event_type
	// values that belong to it (e.g. {"grant": {"fga.register"}, "withdrawal":
	// {"fga.unregister"}}). Empty ⇒ no per-direction series at all.
	//
	// The names are supplied by the composition root and never by request data, so the
	// label set stays closed and cardinality cannot grow with traffic. The event_type
	// VALUES are matched as parameters, not interpolated.
	//
	// A direction is published even when it currently has no rows — that is the point:
	// `delivered_total{direction="withdrawal"} == 0` is the statement "not one withdrawal
	// has ever been delivered", and it can only be made by a series that exists.
	Directions map[string][]string
	// Shape — КАК эта очередь помечает доставленную строку. Пусто ⇒ ShapeSentAt,
	// форма, с которой пакет заведён: прежние вызывающие не меняются.
	Shape QueueShape
}

type DirectionRecorder interface {
	// SetBacklogDepthByDirection — pending rows of one direction.
	SetBacklogDepthByDirection(table, direction string, depth float64)
	// SetOldestPendingAgeByDirection — age of the OLDEST pending row of one direction:
	// the value that answers "how long ago did this direction stop arriving".
	SetOldestPendingAgeByDirection(table, direction string, age float64)
	// IncDeliveredByDirection — ОДНА доставленная строка направления.
	//
	// СЧЁТЧИК, А НЕ ИЗМЕРИТЕЛЬ, и это несущее различие (#1714). Величина
	// объявлена «за всё время» и служит единственным способом отличить «отзывов
	// не было» от «отзывы не проходят». Прежде она ставилась сканом как
	// `count(*)` по ЖИВЫМ строкам — совпадая с объявленным ровно до тех пор, пока
	// строки не убираются. Уборка доставленных (#1361) обнулила бы её на
	// ИСПРАВНОЙ очереди, где отзыв редок, и ноль прочитался бы по контракту как
	// «не доставлено ни одного отзыва».
	//
	// Инкрементирует НАБЛЮДАТЕЛЬ ДРЕНАЖА (`drainer.WithDeliveryObserver`) — как
	// это уже сделано у отравления (`IncPoisoned`), — поэтому величина не
	// зависит от числа живых строк by construction.
	IncDeliveredByDirection(table, direction string)
	// InitDeliveredByDirection — ЗАВЕСТИ серию направления со значением ноль, не
	// увеличивая её.
	//
	// БЕЗ ЭТОГО МЕТОДА СЧЁТЧИК ТЕРЯЕТ СВОЙ ПРЕДМЕТ, и это не украшение. Дочерняя
	// серия счётчика появляется в выдаче лишь ПОСЛЕ первого инкремента — значит
	// «ни одного отзыва не доставлено» выражалось бы ОТСУТСТВИЕМ ряда, тогда как
	// весь смысл разбивки в том, чтобы это состояние было видно ЧИСЛОМ. Прежняя
	// величина-измеритель заводилась сканом и потому всегда существовала; счётчик
	// обязан получить ту же видимость явно.
	//
	// Зовётся ОДИН раз на направление при сборке наблюдателя ([DeliveryObserver]),
	// то есть при старте процесса: ряд существует с нуля, ещё до первой доставки.
	InitDeliveredByDirection(table, direction string)
}

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

type QueueShape string

type Recorder interface {
	SetBacklogDepth(table string, depth float64)
	SetOldestPendingAgeSeconds(table string, age float64)
	SetPoisonedCount(table string, count float64)
	IncPoisoned(table string)
}