项目文件夹

文件
Asim Aslam 3acf74a29a Refactor tool management and add CLI commands for interfaces (#2918)
* refactor(ai): rename ToolSet to Tools, simplify wiring with WithTools

Move tool discovery/execution fully into the ai package as ai.Tools
(formerly ai.ToolSet), and simplify the usage model:

- NewTools(reg, ai.ToolClient(c)) takes the execution client as an
  option instead of threading it through Handler(c) per call
- New ai.WithTools(tools) option wires the tool handler into a model
  in one call, replacing ai.WithToolHandler(set.Handler(c))
- ai.DiscoverTools(reg) for one-shot discovery

Before:
  set := ai.NewToolSet(reg)
  list, _ := set.Discover()
  m := ai.New(p, ai.WithToolHandler(set.Handler(client)))

After:
  tools := ai.NewTools(reg, ai.ToolClient(client))
  list, _ := tools.Discover()
  m := ai.New(p, ai.WithTools(tools))

Update ai/flow, micro chat, README, ai integration doc, Atlas Cloud
guide, and blog posts 3/8/9/10.

* feat(cli): add per-interface commands (registry, broker, store, config)

Map go-micro's core interfaces onto the CLI so the framework's
building blocks are inspectable and manipulable from the terminal:

  micro registry list/get/watch       service discovery
  micro broker publish/subscribe      pub/sub messaging
  micro store read/write/delete/list  persistence
  micro config get/dump               dynamic config (from env)

Structured pluggably in cmd/micro/resource: each interface is one
file exposing a Command() func, all wired through a commandFuncs
slice in resource.go. Adding a new resource command is a single
file plus one slice entry. Shared printJSON/fail helpers keep
output and errors consistent across commands.

Each command's verbs mirror the interface methods. Output is JSON
for structured data, raw for single values. Update README and
getting-started with an "inspecting the framework" section.

---------

Co-authored-by: Claude <noreply@anthropic.com>
2026-05-30 14:43:09 +01:00

80 行
1.8 KiB
Go

package resource
import (
"fmt"
"strings"
"github.com/urfave/cli/v2"
"go-micro.dev/v5/config"
"go-micro.dev/v5/config/source/env"
)
// configCommand exposes the config interface: get, dump.
//
// The CLI loads configuration from environment variables (the source
// that makes sense without a running service). Keys use dot notation,
// e.g. "database.host" reads from DATABASE_HOST.
func configCommand() *cli.Command {
return &cli.Command{
Name: "config",
Usage: "Read dynamic configuration (from environment)",
Description: `Read dynamic configuration loaded from environment variables.
Keys use dot notation: "database.host" maps to DATABASE_HOST.
micro config get <key> Read a config value
micro config dump Print the full config as JSON`,
Subcommands: []*cli.Command{
{
Name: "get",
Usage: "Read a config value",
ArgsUsage: "<key>",
Action: configGet,
},
{
Name: "dump",
Usage: "Print the full config",
Action: configDump,
},
},
}
}
func loadConfig() (config.Config, error) {
conf, err := config.NewConfig()
if err != nil {
return nil, err
}
if err := conf.Load(env.NewSource()); err != nil {
return nil, err
}
return conf, nil
}
func configGet(c *cli.Context) error {
key := c.Args().First()
if key == "" {
return fail("usage: micro config get <key>")
}
conf, err := loadConfig()
if err != nil {
return fail("load config: %v", err)
}
path := strings.Split(key, ".")
val, err := conf.Get(path...)
if err != nil {
return fail("get %q: %v", key, err)
}
fmt.Println(string(val.Bytes()))
return nil
}
func configDump(c *cli.Context) error {
conf, err := loadConfig()
if err != nil {
return fail("load config: %v", err)
}
fmt.Println(string(conf.Bytes()))
return nil
}