batcher

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

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

type ErrorStatsItem struct {
	ConnectionID string
	Error        error
	ErrorAt      time.Time
}

type HeartbeatStatsEntry struct {
	ClientID string
	PingTime time.Time
	PingMs   float64
}

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

type Host interface {
	StorageBatchWriter
	GetMessageSink() spi.MessageSink
}

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

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

type MessageRecordSinkProvider interface {
	GetMessageSink() spi.MessageSink
	GetLogger() spi.Logger
}

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

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

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

type ObserverNotifier interface {
	// NotifyObserversDirect 直接通知观察者（不经批处理队列，避免递归入队）
	NotifyObserversDirect(msg *models.HubMessage, namespace string, groupIDs []string)
}

type ObserverNotifyItem struct {
	Msg       *models.HubMessage
	Namespace string
	GroupIDs  []string
}

type StatsIncrementItem struct {
	ConnectionID     string
	MessagesSent     int64
	MessagesReceived int64
	BytesSent        int64
	BytesReceived    int64
}

type StatusUpdateItem struct {
	MessageID string
	Receiver  string                   // 接收者ID（广播类记录为空串）
	Status    models.MessageSendStatus // 消息发送状态
	Reason    models.FailureReason     // 失败原因
	ErrMsg    string                   // 错误信息
}

type StorageBatchWriter interface {
	// Context 返回 Hub 生命周期上下文（仅用于日志关联）
	Context() context.Context
	// GetLogger 日志器
	GetLogger() spi.Logger

	// GetConnectionRecordRepo 连接记录仓储（心跳时间戳落 connect 表）
	GetConnectionRecordRepo() spi.ConnectionStore
	// GetConnectionQualityRepository 连接质量仓储（心跳统计 / 消息统计）
	GetConnectionQualityRepository() spi.ConnectionQualityStore
	// GetMessageRecordRepo 消息记录仓储（消息状态更新）
	GetMessageRecordRepo() spi.MessageSink
}