feat: support eino

Signed-off-by: Meinhard Zhou <[email protected]>
(cherry picked from commit 74189e52ed6245dcc79fc6e36dba19b5fef66011)

Author: MeinhardZhou

agentkit/toolkit/cli/cli_config.py

@@ -102,7 +102,7 @@ def config_command(
         --agent_name myGoAgent \\
         --entry_point main.go \\
         --language Golang \\
-        --language_version 1.23
+        --language_version 1.24
     
     \b
     # App-level vs Strategy-level environment variables

agentkit/toolkit/config/config.py

@@ -42,13 +42,13 @@ class CommonConfig(AutoSerializableMixin):
     entry_point: str = field(
         default="", 
         metadata={
-            "description": "Agent application entry file (path allowed), e.g. simple_agent.py", 
+            "description": "Agent application entry file (path allowed), e.g. simple_agent.py or main.go or build.sh", 
             "icon": "📝",
             "validation": {
                 "required": True,
                 # allow relative paths with directories and either .py or .go endings
-                "pattern": r"^[\w\-/\.]+?\.(py)$",
-                "message": "Must be a Python (.py), containing only letters, numbers, underscore(_), hyphen(-), dot(.) and '/' for directories"
+                "pattern": r"^[\w\-/\.]+?\.(py|go|sh)$",
+                "message": "Must be a Python (.py) or Go (.go) file path or shell script (.sh), containing only letters, numbers, underscore(_), hyphen(-), dot(.) and '/' for directories"
             }
         }
     )
@@ -58,7 +58,7 @@ class CommonConfig(AutoSerializableMixin):
         "icon": "✏️",
         "choices": [
             {"value": "Python", "description": "Python"},
-            # {"value": "Golang", "description": "Go (Golang)"}
+            {"value": "Golang", "description": "Go (Golang)"}
         ]
     })
     language_version: str = field(
@@ -74,17 +74,16 @@ class CommonConfig(AutoSerializableMixin):
                         "choices": ["3.10", "3.11", "3.12", "3.13"],
                         "message": "Python version must be 3.10, 3.11, 3.12, or 3.13"
                     },
-                    # "Golang": {
-                    #     "pattern": r"^1\.\d+$",
-                    #     "message": "Go 版本格式应为 '1.x' (如 1.21, 1.23)",
-                    #     "hint": "[格式: 1.x]"
-                    # }
+                    "Golang": {
+                        "choices": ["1.24"],
+                        "message": "Golang version must be '1.24'",
+                    }
                 }
             }
         }
     )
     agent_type: str = field(default="Basic App", metadata={"description" : "Agent application Type", "icon": "📩", "hidden": True})
-    dependencies_file: str = field(default="requirements.txt", metadata={"description": "Agent application Dependencies file", "icon": "📦"})
+    dependencies_file: str = field(default="", metadata={"description": "Agent application Dependencies file", "icon": "📦"})
     runtime_envs: Dict[str, str] = field(
         default_factory=dict,
         metadata={
@@ -119,7 +118,7 @@ def _recommended_for_language(language: str) -> Dict[str, str]:
         """Return recommended language_version and dependencies_file for supported languages."""
         mapping = {
             "python": {"language_version": "3.12", "dependencies_file": "requirements.txt"},
-            "golang": {"language_version": "1.23", "dependencies_file": "go.mod"},
+            "golang": {"language_version": "1.24", "dependencies_file": "go.mod"},
         }
         return mapping.get((language or "python").lower(), mapping["python"])
 
@@ -153,7 +152,7 @@ def set_language(self, language: str):
         lv = (self.language_version or "").strip()
         df = (self.dependencies_file or "").strip()
 
-        if not lv or lv in ("3.12", "1.23") or lv.startswith("3.") and language.lower() == "go":
+        if not lv or lv in ("3.12", "1.24") or lv.startswith("3.") and language.lower() == "go":
             self.language_version = rec["language_version"]
         if not df or df in ("requirements.txt", "go.mod"):
             self.dependencies_file = rec["dependencies_file"]

agentkit/toolkit/config/docker_build_config.py

@@ -36,7 +36,7 @@ class DockerBuildConfig(AutoSerializableMixin):
         Go project with multi-stage build:
         >>> docker_build:
         >>>   base_image:
-        >>>     builder: "golang:1.23-alpine"
+        >>>     builder: "golang:1.24-alpine"
         >>>     runtime: "alpine:latest"
         >>>   build_script: "scripts/install_certs.sh"
     """
@@ -48,7 +48,7 @@ class DockerBuildConfig(AutoSerializableMixin):
             "detail": (
                 "For Python projects, use a string like 'python:3.12-alpine'. "
                 "For Go projects, use a dict with 'builder' and 'runtime' keys, "
-                "e.g., {'builder': 'golang:1.23-alpine', 'runtime': 'alpine:latest'}"
+                "e.g., {'builder': 'golang:1.24-alpine', 'runtime': 'alpine:latest'}"
             )
         }
     )

agentkit/toolkit/executors/init_executor.py

@@ -65,14 +65,14 @@
         "type": "A2A App",
         "extra_requirements": ["# google-adk"],
     },
-    # "eino_a2a": {
-    #     "filepath": "eino_a2a",
-    #     "name": "Eino A2A Agent App",
-    #     "language": "Golang",
-    #     "language_version": "1.23",
-    #     "description": "基于Eino框架的A2A应用",
-    #     "type": "A2A App",
-    # },
+    "eino_a2a": {
+        "filepath": "eino_a2a",
+        "name": "Eino A2A Agent App",
+        "language": "Golang",
+        "language_version": "1.24",
+        "description": "基于Eino框架的A2A应用",
+        "type": "A2A App",
+    },
 }
 
 
@@ -410,7 +410,7 @@ def _create_dependencies_file(
             )
 
         elif language.lower() == "golang":
-            go_ver = language_version or "1.23"
+            go_ver = language_version or "1.24"
             with open(dependencies_file_path, 'w', encoding='utf-8') as gomod:
                 gomod.write(f"module {project_name}\n\ngo {go_ver}\n")
             self.created_files.append(dependencies_file_path.name)

agentkit/toolkit/resources/samples/eino_a2a/agent.go

@@ -0,0 +1,63 @@
+// Copyright (c) 2025 Beijing Volcano Engine Technology Co., Ltd. and/or its affiliates.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package main
+
+import (
+	"context"
+	"fmt"
+	"os"
+
+	"github.com/cloudwego/eino/adk"
+	"github.com/eino-contrib/agentkit-ve/components/model/chatmodelprovider"
+)
+
+func buildSimpleAgent(ctx context.Context) (adk.Agent, error) {
+	agentName := "{{ agent_name | default('A2ASimpleAgent') }}"
+	var description string
+	{% if description %}description = `{{ description }}`{% else %}description = DEFAULT_DESCRIPTION{% endif %}
+
+	var instruction string
+	{% if system_prompt %}instruction = `{{ system_prompt }}`{% else %}instruction = DEFAULT_INSTRUCTION{% endif %}
+	// // ========================================================
+
+	// Resolve BaseURL from env or use default
+	baseURL := os.Getenv("MODEL_AGENT_BASE_URL")
+	if baseURL == "" {
+		baseURL = "https://ark.cn-beijing.volces.com/api/v3"
+	}
+
+	cm, err := chatmodelprovider.NewChatModel(ctx, &chatmodelprovider.Config{
+		Provider: os.Getenv("MODEL_AGENT_PROVIDER"),
+		APIKey:   os.Getenv("MODEL_AGENT_API_KEY"),
+		Model:    os.Getenv("MODEL_AGENT_NAME"),
+		BaseURL:  os.Getenv("MODEL_AGENT_API_BASE"),
+	})
+	if err != nil {
+		return nil, err
+	}
+
+	a, err := adk.NewChatModelAgent(ctx, &adk.ChatModelAgentConfig{
+		Name:        agentName,
+		Description: description,
+		Instruction: instruction,
+		Model:       cm,
+	})
+
+	if err != nil {
+		return nil, fmt.Errorf("failed to create chatmodel: %w", err)
+	}
+
+	return a, nil
+}

agentkit/toolkit/resources/samples/eino_a2a/build.sh

@@ -0,0 +1,27 @@
+#!/bin/sh
+set -eu
+
+# Generic build script for Go projects used inside the builder image.
+# Environment variables expected (builder sets BUILD_OUTPUT_DIR, BUILD_BINARY_NAME):
+#  BUILD_OUTPUT_DIR - where to place the binary (default: /app)
+#  BUILD_BINARY_NAME - binary name (fallback to current dir name)
+# Optional:
+#  ENTRY - go build target (file, dir or package); default is '.'
+
+OUTPUT_DIR=${BUILD_OUTPUT_DIR:-/app}
+BIN_NAME=${BUILD_BINARY_NAME:-${BINARY_NAME:-$(basename "$(pwd)")}}
+ENTRY=${ENTRY:-.}
+
+mkdir -p "${OUTPUT_DIR}"
+
+# Prefer module-aware builds if go.mod exists
+if [ -f go.mod ]; then
+  echo "Building module-aware: ENTRY='${ENTRY}' BIN='${BIN_NAME}'"
+  export GOPROXY=${GOPROXY:-https://goproxy.cn}
+  CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o "${OUTPUT_DIR}/${BIN_NAME}" ${ENTRY}
+else
+  echo "No go.mod found, using standard go build: ENTRY='${ENTRY}' BIN='${BIN_NAME}'"
+  CGO_ENABLED=0 GOOS=linux go build -a -installsuffix cgo -o "${OUTPUT_DIR}/${BIN_NAME}" ${ENTRY}
+fi
+
+echo "Built ${OUTPUT_DIR}/${BIN_NAME}"

agentkit/toolkit/resources/samples/eino_a2a/go.mod

@@ -0,0 +1,129 @@
+module eino_a2a/simple-agent
+
+go 1.24
+
+require (
+	github.com/cloudwego/eino v0.7.0
+	github.com/cloudwego/eino-ext/callbacks/cozeloop v0.1.6
+	github.com/cloudwego/hertz v0.10.3
+	github.com/coze-dev/cozeloop-go v0.1.16
+	github.com/eino-contrib/agentkit-ve/components/model/chatmodelprovider v0.1.3
+	github.com/eino-contrib/agentkit-ve/server/a2a v0.0.0-20251121055902-c2941b51b5ec
+)
+
+require (
+	cloud.google.com/go v0.123.0 // indirect
+	cloud.google.com/go/auth v0.17.0 // indirect
+	cloud.google.com/go/compute/metadata v0.9.0 // indirect
+	github.com/anthropics/anthropic-sdk-go v1.19.0 // indirect
+	github.com/aws/aws-sdk-go-v2 v1.40.0 // indirect
+	github.com/aws/aws-sdk-go-v2/aws/protocol/eventstream v1.7.3 // indirect
+	github.com/aws/aws-sdk-go-v2/config v1.32.2 // indirect
+	github.com/aws/aws-sdk-go-v2/credentials v1.19.2 // indirect
+	github.com/aws/aws-sdk-go-v2/feature/ec2/imds v1.18.14 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/configsources v1.4.14 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/endpoints/v2 v2.7.14 // indirect
+	github.com/aws/aws-sdk-go-v2/internal/ini v1.8.4 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/accept-encoding v1.13.3 // indirect
+	github.com/aws/aws-sdk-go-v2/service/internal/presigned-url v1.13.14 // indirect
+	github.com/aws/aws-sdk-go-v2/service/signin v1.0.2 // indirect
+	github.com/aws/aws-sdk-go-v2/service/sso v1.30.5 // indirect
+	github.com/aws/aws-sdk-go-v2/service/ssooidc v1.35.10 // indirect
+	github.com/aws/aws-sdk-go-v2/service/sts v1.41.2 // indirect
+	github.com/aws/smithy-go v1.23.2 // indirect
+	github.com/bahlo/generic-list-go v0.2.0 // indirect
+	github.com/bluele/gcache v0.0.2 // indirect
+	github.com/buger/jsonparser v1.1.1 // indirect
+	github.com/bytedance/gopkg v0.1.3 // indirect
+	github.com/bytedance/sonic v1.14.2 // indirect
+	github.com/bytedance/sonic/loader v0.4.0 // indirect
+	github.com/cenkalti/backoff/v4 v4.3.0 // indirect
+	github.com/cloudwego/base64x v0.1.6 // indirect
+	github.com/cloudwego/eino-ext/a2a v0.0.1-alpha.8 // indirect
+	github.com/cloudwego/eino-ext/components/model/ark v0.1.50 // indirect
+	github.com/cloudwego/eino-ext/components/model/arkbot v0.1.1 // indirect
+	github.com/cloudwego/eino-ext/components/model/claude v0.1.10 // indirect
+	github.com/cloudwego/eino-ext/components/model/deepseek v0.0.0-20251125094026-d36991a29748 // indirect
+	github.com/cloudwego/eino-ext/components/model/gemini v0.1.15 // indirect
+	github.com/cloudwego/eino-ext/components/model/ollama v0.1.6 // indirect
+	github.com/cloudwego/eino-ext/components/model/openai v0.1.5 // indirect
+	github.com/cloudwego/eino-ext/components/model/qwen v0.1.2 // indirect
+	github.com/cloudwego/eino-ext/libs/acl/openai v0.1.3 // indirect
+	github.com/cloudwego/gopkg v0.1.7 // indirect
+	github.com/cloudwego/netpoll v0.7.2 // indirect
+	github.com/cohesion-org/deepseek-go v1.3.2 // indirect
+	github.com/coze-dev/cozeloop-go/spec v0.1.6 // indirect
+	github.com/dustin/go-humanize v1.0.1 // indirect
+	github.com/eino-contrib/agentkit-ve/libs/veauth v0.1.1 // indirect
+	github.com/eino-contrib/jsonschema v1.0.2 // indirect
+	github.com/eino-contrib/ollama v0.1.0 // indirect
+	github.com/evanphx/json-patch v0.5.2 // indirect
+	github.com/felixge/httpsnoop v1.0.4 // indirect
+	github.com/fsnotify/fsnotify v1.9.0 // indirect
+	github.com/go-logr/logr v1.4.3 // indirect
+	github.com/go-logr/stdr v1.2.2 // indirect
+	github.com/go-openapi/jsonpointer v0.22.3 // indirect
+	github.com/go-openapi/jsonreference v0.21.3 // indirect
+	github.com/go-openapi/spec v0.22.1 // indirect
+	github.com/go-openapi/swag/conv v0.25.3 // indirect
+	github.com/go-openapi/swag/jsonname v0.25.4 // indirect
+	github.com/go-openapi/swag/jsonutils v0.25.3 // indirect
+	github.com/go-openapi/swag/loading v0.25.3 // indirect
+	github.com/go-openapi/swag/stringutils v0.25.3 // indirect
+	github.com/go-openapi/swag/typeutils v0.25.3 // indirect
+	github.com/go-openapi/swag/yamlutils v0.25.3 // indirect
+	github.com/golang-jwt/jwt v3.2.2+incompatible // indirect
+	github.com/google/go-cmp v0.7.0 // indirect
+	github.com/google/s2a-go v0.1.9 // indirect
+	github.com/google/uuid v1.6.0 // indirect
+	github.com/googleapis/enterprise-certificate-proxy v0.3.7 // indirect
+	github.com/googleapis/gax-go/v2 v2.15.0 // indirect
+	github.com/goph/emperror v0.17.2 // indirect
+	github.com/gorilla/websocket v1.5.3 // indirect
+	github.com/jmespath/go-jmespath v0.4.0 // indirect
+	github.com/joho/godotenv v1.5.1 // indirect
+	github.com/json-iterator/go v1.1.12 // indirect
+	github.com/klauspost/cpuid/v2 v2.3.0 // indirect
+	github.com/mailru/easyjson v0.9.1 // indirect
+	github.com/meguminnnnnnnnn/go-openai v0.1.0 // indirect
+	github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
+	github.com/modern-go/reflect2 v1.0.2 // indirect
+	github.com/nikolalohinski/gonja v1.5.3 // indirect
+	github.com/nikolalohinski/gonja/v2 v2.4.2 // indirect
+	github.com/nyaruka/phonenumbers v1.6.7 // indirect
+	github.com/ollama/ollama v0.13.0 // indirect
+	github.com/pelletier/go-toml/v2 v2.2.4 // indirect
+	github.com/pkg/errors v0.9.2-0.20201214064552-5dd12d0cfe7f // indirect
+	github.com/sirupsen/logrus v1.9.3 // indirect
+	github.com/slongfield/pyfmt v0.0.0-20220222012616-ea85ff4c361f // indirect
+	github.com/tidwall/gjson v1.18.0 // indirect
+	github.com/tidwall/match v1.2.0 // indirect
+	github.com/tidwall/pretty v1.2.1 // indirect
+	github.com/tidwall/sjson v1.2.5 // indirect
+	github.com/twitchyliquid64/golang-asm v0.15.1 // indirect
+	github.com/valyala/bytebufferpool v1.0.0 // indirect
+	github.com/valyala/fasttemplate v1.2.2 // indirect
+	github.com/volcengine/volc-sdk-golang v1.0.228 // indirect
+	github.com/volcengine/volcengine-go-sdk v1.1.49 // indirect
+	github.com/wk8/go-ordered-map/v2 v2.1.8 // indirect
+	github.com/yargevad/filepathx v1.0.0 // indirect
+	go.opentelemetry.io/auto/sdk v1.2.1 // indirect
+	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.63.0 // indirect
+	go.opentelemetry.io/otel v1.38.0 // indirect
+	go.opentelemetry.io/otel/metric v1.38.0 // indirect
+	go.opentelemetry.io/otel/trace v1.38.0 // indirect
+	go.yaml.in/yaml/v3 v3.0.4 // indirect
+	golang.org/x/arch v0.23.0 // indirect
+	golang.org/x/crypto v0.45.0 // indirect
+	golang.org/x/exp v0.0.0-20251125195548-87e1e737ad39 // indirect
+	golang.org/x/net v0.47.0 // indirect
+	golang.org/x/sync v0.18.0 // indirect
+	golang.org/x/sys v0.38.0 // indirect
+	golang.org/x/text v0.31.0 // indirect
+	google.golang.org/genai v1.36.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20251124214823-79d6a2a48846 // indirect
+	google.golang.org/grpc v1.77.0 // indirect
+	google.golang.org/protobuf v1.36.10 // indirect
+	gopkg.in/yaml.v2 v2.4.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)