subjectchange

type Config struct {
	// Poller — источник изменений субъекта. Обязателен.
	Poller Poller
	// Flush — сброс кэша решений этой реплики. Обязателен.
	Flush func()
	// Interval — период перепроса. Неположительный резолвится в 2s.
	Interval time.Duration

	// Closer — реестр открытых потоков. ОБЯЗАТЕЛЕН.
	//
	// Необязательным он быть не может, и это выяснилось инъекцией: передай в
	// точке сборки ноль — и весь корпус проб потребителя остаётся зелёным, код
	// собирается, а отзыв перестаёт доезжать до потоков совсем. То есть
	// несделанная провязка была бы НЕОТЛИЧИМА от сделанной, и неотличима именно
	// тем механизмом, ради которого задача заведена.
	//
	// Потребитель проекцию строит безусловно, поэтому законного нуля здесь нет.
	Closer StreamCloser

	// StaleAfter — сколько потребитель вправе ДЕРЖАТЬ потоки, не подтвердив
	// чтения отзыва. Обязателен вместе с [Config.Closer].
	//
	// Это ОКНО FAIL-CLOSED, и оно есть следствие решения, а не срока жизни
	// соединения: величина отсчитывается от последнего удачного перепроса и к
	// длительности соединения отношения не имеет. Обязана превосходить
	// [Config.Interval] — иначе один пропущенный перепрос объявляется аварией.
	StaleAfter time.Duration

	// Now — часы. Ноль резолвится в [time.Now]; проба подставляет свои, потому
	// что срок обязан быть свойством решения, а не занятости машины.
	Now func() time.Time

	// Logger — журнал процесса. Обязателен.
	Logger *slog.Logger
}

type Poller interface {
	PollSubjectChanges(ctx context.Context, since int64, limit int32) (changes []SubjectChange, headID int64, err error)
}

type PositionLostError struct {
	// EarliestResumable — нижняя позиция, с которой возобновление ещё ничего не
	// теряет: «самая ранняя удержанная строка минус один», а у вычищенного
	// целиком журнала — сама граница устоявшегося.
	EarliestResumable int64
}

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

type StreamCloser interface {
	// CloseSubject закрывает потоки названного субъекта и возвращает их число.
	CloseSubject(subject string) int
	// CloseAll закрывает ВСЕ открытые потоки и возвращает их число.
	CloseAll() int
}

type SubjectChange struct {
	// ID — номер строки журнала; им двигается курсор.
	ID int64
	// Subject — субъект модели прав («user:usr-x»). Может быть пуст, если
	// владелец журнала его не назвал; такая строка двигает курсор и никого не
	// закрывает.
	Subject string
	// Naming — ПОЧЕМУ [SubjectChange.Subject] пуст.
	//
	// Пустое имя приходит по двум несравнимым причинам, и наблюдение обязано
	// их различать: выдача ГРУППЕ безымянна по устройству продукта (норма,
	// при каждом снятии привязки в предпочтительной форме выдачи), а
	// потерянный производителем тип означает, что отзыв по этой строке не
	// доедет ни до кэша поимённо, ни до открытого потока (дефект). Величина, в
	// которую сложены обе, ненулевая в штатной работе — тревогу на неё не
	// повесить (kacho#1463).
	//
	// Читается ТОЛЬКО при пустом имени. Ноль значения —
	// [authz.SubjectUnnameable]: строка, собранная без разбора, попадает в
	// громкую корзину, а не в тихую.
	Naming authz.SubjectNaming
}

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