Function New

internal/nodehub/hub.go:120–151

New 构造 Hub。

(opts Options)

// New 构造 Hub。
func New(opts Options) *Hub {
	logger := opts.Logger
	if logger == nil {
		logger = slog.Default()
	}
	ph := opts.PushHandler
	if ph == nil {
		ph = NoopPushHandler{}
	}
	pe := opts.PeerExtractor
	if pe == nil {
		pe = mtlsPeerExtractor
	}
	dct := opts.DeadConnectionTimeout
	if dct <= 0 {
		dct = 60 * time.Second
	}
	ri := opts.ReaperInterval
	if ri <= 0 {
		ri = 10 * time.Second
	}
	return &Hub{
		logger:          logger,
		pushHandler:     ph,
		peerExtractor:   pe,
		onNodeConnected: opts.OnNodeConnected,
		deadConnTimeout: dct,
		reaperInterval:  ri,
		conns:           make(map[string]*conn),
		metrics:         newMetrics(),
	}
}

// RunReaper 阻塞运行死连接清理：每 ReaperInterval 扫描一次注册表，
// 关闭超过 DeadConnectionTimeout 没收到任何帧的连接。ctx 取消时返回。