Fancy-hjyp

Results 7 comments of Fancy-hjyp

# TODO - [x] 创建XdsDirectory时传入老的接口实例对象,从中获取一些信息,这样做是否合理; - [x] XdsClusterInvoker具体实现,可以先简单实现一版,后期看是否可以复用原先的超时、重试等功能; - [x] 修改PilotExchanger类初始化获取资源时getResource方法命名,以防引起歧义; - [x] 订阅资源时是否有并发问题; - [x] Rds资源变更时是否需要变更invokers列表,一种情况是导致Cds资源减少,需要删除Cds资源对应的invokers列表; - [x] 每个XdsRouter都拥有与自己感兴趣的XdsCluster资源,而不直接从PilotExchanger取,这样做是否会提高效率,或者直接从PilotExchanger中取影响也不大; - [x] 目前Xds资源变更是增量的吗(增量变更的好处是为了减少资源更新风暴); - [x] 用表格列一下Xds资源的各个字段和 Dubbo Invocation / Invoker...

# TODO - [x] 过滤器筛选:当用户不使用xds协议时,从XdsDirectory的过滤器链中去除XdsRouter(通过在URL参数中添加xds属性判断,xds=true表示使用xds协议) - [ ] 将XdsDirectory放入dubbo-registry-api包下(在RegistryProtocol流程中构造XdsDirectory,再传入XdsCluster中) - [x] Pilot Exchanger初始化:在Registry Protocol#refer()中进行PilotExchanger初始化,测试是否应该把异步初始化变为同步(异步可能会有invoker为空引发调用错误的情况) - [ ] Cluster资源更新时,剔除停止服务的invoker - [ ] 复用 invoker 检查逻辑 - [ ] 生成invoker时根据cds资源确定接口协议 - [...

可以贴下修改后的 builder.py 代码么

@kzh2ang 看builder文件没啥问题,可以本地运行main.py文件打断点调试下试试呢

你的LLM模型支持stream模式么,我这样是可以的,langgraph版本 0.5.4 ```python async def chat_with_agent_with_astream_with_messages_mode(): agent = create_react_agent( model=model, tools=[get_weather_with_message], prompt="你是一名助手,帮忙解决用户问题" ) async for mode, chunk in agent.astream( {"messages": [{"role": "user", "content": "北京的天气怎么样"}]}, stream_mode=["messages"] # custom模式会输出用户自定义的流式输出内容, updates模式会输出每个节点的输出内容 ): print(chunk)...