wsclient

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

type Config struct {
	Name string // имя шлюза, для журнала и состояния
	URL  string // ws:// или wss://
	// Header строит заголовки рукопожатия перед каждым подключением: секрет
	// разыменовывается на dial, а не на старте — появившаяся env-переменная
	// подхватывается очередной попыткой без рестарта. nil — без заголовков.
	Header           func() (http.Header, error)
	Subscribe        []byte // сообщение сразу после подключения; nil — не слать
	ReconnectInitial time.Duration
	ReconnectMax     time.Duration
	MaxMessageBytes  int64 // лимит входящего сообщения

	// Gate вызывается перед каждой попыткой подключения и перед обработкой
	// каждого сообщения. Непустая строка — причина блокировки (предохранитель
	// сети): соединение не поднимается / закрывается. nil — без блокировок.
	Gate func() string
	// OnMessage обрабатывает входящее синхронно. Ошибка пишется в журнал и
	// состояние, но соединение НЕ рвёт: решения о карантине принимает приёмка.
	OnMessage func(ctx context.Context, raw []byte) error
	// Logf — журнал владельца (формат log.Printf). nil — молча.
	Logf func(format string, args ...any)
}

type Status struct {
	Connected      bool
	BlockedReason  string    // непустая — заблокировано предохранителем
	ConnectedSince time.Time // нулевое время, если не подключено
	LastMessageAt  time.Time
	LastError      string
	Reconnects     int64 // завершившиеся попытки подключения после первой
	Received       int64 // принятых сообщений (до обработки)
	HandlerErrors  int64 // ошибок onMessage (сообщение потеряно для приёмки)
	Sent           int64
	SendErrors     int64
}