Method clientFor

internal/serverapi/api.go:794–809

(nodeID string)

}

func (a *API) clientFor(nodeID string) (*nodes.Client, error) {
	// 命中缓存直接返回（避免重复构造）
	if v, ok := a.clientCache.Load(nodeID); ok {
		return v.(*nodes.Client), nil
	}
	node, err := a.store.Get(nodeID)
	if err != nil {
		return nil, err
	}
	if node.Disabled {
		return nil, fmt.Errorf("node is disabled")
	}
	client := a.clientFactory(node)
	a.clientCache.Store(nodeID, client)
	return client, nil
}

func (a *API) evictClient(nodeID string) {
	a.clientCache.Delete(nodeID)