程序包 com.alibaba.nacos.client.ai.remote

类 AiGrpcClient

java.lang.Object
com.alibaba.nacos.client.ai.remote.AiGrpcClient
所有已实现的接口:
com.alibaba.nacos.common.lifecycle.Closeable
public class AiGrpcClient extends Object implements com.alibaba.nacos.common.lifecycle.Closeable
Nacos AI GRPC protocol client.
作者:
xiweng.yy

  • 构造器详细资料

    • AiGrpcClient

      public AiGrpcClient(String namespaceId, com.alibaba.nacos.client.env.NacosClientProperties properties)

  • 方法详细资料

    • start

      public void start(NacosMcpServerCacheHolder mcpServerCacheHolder) throws com.alibaba.nacos.api.exception.NacosException
      Start the grpc client.
      抛出:
      com.alibaba.nacos.api.exception.NacosException - nacos exception

    • queryMcpServer

      public com.alibaba.nacos.api.ai.model.mcp.McpServerDetailInfo queryMcpServer(String mcpName, String version) throws com.alibaba.nacos.api.exception.NacosException
      Do query mcp server by mcpId and version.
      参数:
      mcpName - name of mcp server
      version - version of mcp server, if input empty or null, return the latest version
      返回:
      mcp server detail info
      抛出:
      com.alibaba.nacos.api.exception.NacosException - if request parameter is invalid or handle error

    • releaseMcpServer

      public String releaseMcpServer(com.alibaba.nacos.api.ai.model.mcp.McpServerBasicInfo serverSpecification, com.alibaba.nacos.api.ai.model.mcp.McpToolSpecification toolSpecification, com.alibaba.nacos.api.ai.model.mcp.McpEndpointSpec endpointSpecification) throws com.alibaba.nacos.api.exception.NacosException
      Do release mcp server.
      参数:
      serverSpecification - mcp server specification
      toolSpecification - mcp server tool specification, optional
      返回:
      mcp id
      抛出:
      com.alibaba.nacos.api.exception.NacosException - if request parameter is invalid or handle error

    • registerMcpServerEndpoint

      public void registerMcpServerEndpoint(String mcpName, String address, int port, String version) throws com.alibaba.nacos.api.exception.NacosException
      Register endpoint to target mcp server and cached to redo service.
      参数:
      mcpName - name of mcp server
      address - address of mcp endpoint
      port - port of mcp endpoint
      version - version of mcp endpoint, if empty, the endpoint will return for all mcp version
      抛出:
      com.alibaba.nacos.api.exception.NacosException - if request parameter is invalid or handle error

    • doRegisterMcpServerEndpoint

      public void doRegisterMcpServerEndpoint(String mcpName, String address, int port, String version) throws com.alibaba.nacos.api.exception.NacosException
      Actual do Register endpoint to target mcp server.
      参数:
      mcpName - name of mcp server
      address - address of mcp endpoint
      port - port of mcp endpoint
      version - version of mcp endpoint, if empty, the endpoint will return for all mcp version
      抛出:
      com.alibaba.nacos.api.exception.NacosException - if request parameter is invalid or handle error

    • deregisterMcpServerEndpoint

      public void deregisterMcpServerEndpoint(String mcpName, String address, int port) throws com.alibaba.nacos.api.exception.NacosException
      Deregister endpoint from target mcp server and cached to redo service.
      参数:
      mcpName - name of mcp server
      address - address of mcp endpoint
      port - port of mcp endpoint
      抛出:
      com.alibaba.nacos.api.exception.NacosException - if request parameter is invalid or handle error

    • doDeregisterMcpServerEndpoint

      public void doDeregisterMcpServerEndpoint(String mcpName, String address, int port) throws com.alibaba.nacos.api.exception.NacosException
      Actual do deregister endpoint from target mcp server.
      参数:
      mcpName - name of mcp server
      address - address of mcp endpoint
      port - port of mcp endpoint
      抛出:
      com.alibaba.nacos.api.exception.NacosException - if request parameter is invalid or handle error

    • subscribeMcpServer

      public com.alibaba.nacos.api.ai.model.mcp.McpServerDetailInfo subscribeMcpServer(String mcpName, String version) throws com.alibaba.nacos.api.exception.NacosException
      Subscribe mcp server latest version.
      参数:
      mcpName - name of mcp server
      version - version of mcp server
      返回:
      latest version mcp server
      抛出:
      com.alibaba.nacos.api.exception.NacosException - if request parameter is invalid or handle error

    • unsubscribeMcpServer

      public void unsubscribeMcpServer(String mcpName, String version) throws com.alibaba.nacos.api.exception.NacosException
      Un-subscribe mcp server.
      参数:
      mcpName - name of mcp server
      version - version of mcp server
      抛出:
      com.alibaba.nacos.api.exception.NacosException - if request parameter is invalid or handle error

    • isEnable

      public boolean isEnable()

    • isAbilitySupportedByServer

      public boolean isAbilitySupportedByServer(com.alibaba.nacos.api.ability.constant.AbilityKey abilityKey)
      Determine whether nacos-server supports the capability.
      参数:
      abilityKey - ability key
      返回:
      true if supported, otherwise false

    • shutdown

      public void shutdown() throws com.alibaba.nacos.api.exception.NacosException
      指定者:
      shutdown 在接口中 com.alibaba.nacos.common.lifecycle.Closeable
      抛出:
      com.alibaba.nacos.api.exception.NacosException