This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-agents.git
from 9429239 [infra] Add doc-including label to indicate docs are included
in the PR (#407)
add 6066182 [Feature][Java] Add MCP support in Java (#356)
No new revisions were added by this update.
Summary of changes:
.github/workflows/ci.yml | 18 +-
api/pom.xml | 22 ++
.../apache/flink/agents/api/agents/ReActAgent.java | 2 +-
.../flink/agents/api/annotation/MCPServer.java | 68 ++++
.../org/apache/flink/agents/api/prompt/Prompt.java | 321 ++++++++++------
.../agents/api/chat/model/BaseChatModelTest.java | 21 +-
.../apache/flink/agents/api/prompt/PromptTest.java | 12 +-
docs/content/docs/development/prompts.md | 4 +-
docs/content/docs/development/react_agent.md | 2 +-
.../agents/integration/test/ReActAgentTest.java | 2 +-
.../examples/agents/CustomTypesAndResources.java | 6 +-
integrations/mcp/pom.xml | 94 +++++
.../integrations/mcp/MCPContentExtractor.java | 106 ++++++
.../flink/agents/integrations/mcp/MCPPrompt.java | 230 +++++++++++
.../flink/agents/integrations/mcp/MCPServer.java | 423 +++++++++++++++++++++
.../flink/agents/integrations/mcp/MCPTool.java | 128 +++++++
.../agents/integrations/mcp/auth/ApiKeyAuth.java | 102 +++++
.../flink/agents/integrations/mcp/auth/Auth.java | 59 +++
.../agents/integrations/mcp/auth/BasicAuth.java | 108 ++++++
.../integrations/mcp/auth/BearerTokenAuth.java | 89 +++++
.../agents/integrations/mcp/MCPPromptTest.java | 185 +++++++++
.../integrations/mcp/MCPSerializationTest.java | 146 +++++++
.../agents/integrations/mcp/MCPServerTest.java | 246 ++++++++++++
.../flink/agents/integrations/mcp/MCPToolTest.java | 159 ++++++++
integrations/pom.xml | 1 +
plan/pom.xml | 47 +++
.../org/apache/flink/agents/plan/AgentPlan.java | 74 +++-
.../agents/plan/resource/python/PythonPrompt.java | 6 +-
.../agents/plan/AgentPlanDeclareChatModelTest.java | 4 +-
.../agents/plan/AgentPlanDeclareMCPServerTest.java | 320 ++++++++++++++++
pom.xml | 28 +-
python/flink_agents/api/tests/mcp/mcp_server.py | 10 +-
runtime/pom.xml | 1 -
33 files changed, 2881 insertions(+), 163 deletions(-)
create mode 100644
api/src/main/java/org/apache/flink/agents/api/annotation/MCPServer.java
create mode 100644 integrations/mcp/pom.xml
create mode 100644
integrations/mcp/src/main/java/org/apache/flink/agents/integrations/mcp/MCPContentExtractor.java
create mode 100644
integrations/mcp/src/main/java/org/apache/flink/agents/integrations/mcp/MCPPrompt.java
create mode 100644
integrations/mcp/src/main/java/org/apache/flink/agents/integrations/mcp/MCPServer.java
create mode 100644
integrations/mcp/src/main/java/org/apache/flink/agents/integrations/mcp/MCPTool.java
create mode 100644
integrations/mcp/src/main/java/org/apache/flink/agents/integrations/mcp/auth/ApiKeyAuth.java
create mode 100644
integrations/mcp/src/main/java/org/apache/flink/agents/integrations/mcp/auth/Auth.java
create mode 100644
integrations/mcp/src/main/java/org/apache/flink/agents/integrations/mcp/auth/BasicAuth.java
create mode 100644
integrations/mcp/src/main/java/org/apache/flink/agents/integrations/mcp/auth/BearerTokenAuth.java
create mode 100644
integrations/mcp/src/test/java/org/apache/flink/agents/integrations/mcp/MCPPromptTest.java
create mode 100644
integrations/mcp/src/test/java/org/apache/flink/agents/integrations/mcp/MCPSerializationTest.java
create mode 100644
integrations/mcp/src/test/java/org/apache/flink/agents/integrations/mcp/MCPServerTest.java
create mode 100644
integrations/mcp/src/test/java/org/apache/flink/agents/integrations/mcp/MCPToolTest.java
create mode 100644
plan/src/test/java/org/apache/flink/agents/plan/AgentPlanDeclareMCPServerTest.java
