Schema 与消息类型

type Message struct {
    Role      RoleType    // system / user / assistant / tool
    Content   string      // 文本内容
    ToolCalls []ToolCall  // 仅 assistant 消息可包含
    // 其他字段：MultiContent、ReasoningContent、ToolCallID 等
}

schema.SystemMessage("You are a helpful assistant.")
schema.UserMessage("今天天气怎么样？")

// 不含工具调用的回复
schema.AssistantMessage("我不知道。", nil)

// 含工具调用的回复
schema.AssistantMessage("", []schema.ToolCall{{
    ID: "call_abc",
    Function: schema.FunctionCall{Name: "get_weather", Arguments: `{"city":"北京"}`},
}})

// 工具执行结果——注意 call_id 必须与上面 ToolCall.ID 一致
schema.ToolMessage("23°C，晴", "call_abc")

type ToolCall struct {
    ID       string       // 本次调用的唯一 ID
    Function FunctionCall
}

type FunctionCall struct {
    Name      string // 目标工具名称，必须匹配 ToolInfo.Name
    Arguments string // JSON 格式的参数
}

type StreamReader[T any] struct { ... }

func (sr *StreamReader[T]) Recv() (T, error)
func (sr *StreamReader[T]) Close()

stream, _ := model.Stream(ctx, messages)
defer stream.Close()  // ← 一定 defer
for {
    chunk, err := stream.Recv()
    if errors.Is(err, io.EOF) { break }
    if err != nil { break }
    fmt.Print(chunk.Content)
}

// 从数组创建（测试/简单场景）
sr := schema.StreamReaderFromArray([]string{"a", "b", "c"})

// 从 channel 创建
sr := schema.StreamReaderFromChannel(ch)

// 一对多复制（多消费者）
sr1, sr2 := sr.Copy(2)  // 两个独立的 Reader

type Document struct {
    ID       string         // 唯一标识
    Content  string         // 文档正文
    MetaData map[string]any // 元数据：来源、作者、时间、页数等
}

type ToolInfo struct {
    Name        string        // 工具名，LLM 通过它指定调哪个
    Desc        string        // 描述，LLM 据此判断是否该调用
    ParamsOneOf *ParamsOneOf  // 参数 JSON Schema
}

// 简单参数
toolInfo := &schema.ToolInfo{
    Name: "calculator",
    Desc: "执行四则运算，支持 + - * /",
    ParamsOneOf: schema.NewParamsOneOfByParams(map[string]*schema.ParameterInfo{
        "expression": {
            Type:     schema.String,
            Desc:     "算式，如 '2+3*4'",
            Required: true,    // 必填
        },
    }),
}

// 复杂参数：多组参数互斥（OneOf 语义）
toolInfo := &schema.ToolInfo{
    Name: "send_notification",
    Desc: "发送通知给用户",
    ParamsOneOf: schema.NewParamsOneOfByParams(
        // 组 A：通过用户 ID
        map[string]*schema.ParameterInfo{
            "user_id":  {Type: schema.String, Desc: "用户 ID", Required: true},
            "message":  {Type: schema.String, Desc: "通知内容", Required: true},
        },
        // 组 B：通过邮箱
        map[string]*schema.ParameterInfo{
            "email":    {Type: schema.String, Desc: "邮箱地址", Required: true},
            "message":  {Type: schema.String, Desc: "通知内容", Required: true},
        },
    ),
}
// LLM 可以选择用 {user_id + message} 或 {email + message}

type MessageType interface {
    *schema.Message | *schema.AgenticMessage
}

// 标准路径（99% 的场景）
agent, _ := adk.NewChatModelAgent(ctx, config)   // 自动用 *schema.Message

// 泛型路径（需要结构化消息块时）
agent, _ := adk.NewTypedChatModelAgent[*schema.AgenticMessage](ctx, typedConfig)