agent

type Agent struct {

	// session
	SessionID string `json:"session_id"` // 会话ID, for 持久化信息

	// basic
	ID   string `json:"id"` // 唯一标识
	Name string `json:"name"`
	Role string `json:"role"` // 角色

	// for prompt
	Description  string   `json:"description"`
	Goals        []string `json:"goals"`
	Instructions []string `json:"instructions"`
	Outputs      []string `json:"outputs"`
	Tools        []any    `json:"tools"`

	// for team
	TeamID string `json:"team_id"` // 团队ID
	// contains filtered or unexported fields
}

type AgentRunResponse struct {
	Reasoning string         `json:"reasoning"`
	Answer    string         `json:"answer"`
	ToolCalls []llm.ToolCall `json:"tool_calls"`
	Error     error

	Stream chan *llm.Chunk
}

type InvokeOption func(*InvokeOptions)

type InvokeOptions struct {
	SessionID string `json:"session_id"` // 会话ID, for 持久化信息
	Retries   int    `json:"retries"`    // 重试次数
	Stream    bool   `json:"stream"`     // 是否流式输出
}

type Memory struct {
	ID        string    `json:"id"`
	Content   string    `json:"content"`
	CreatedAt time.Time `json:"created_at"`
	UpdatedAt time.Time `json:"updated_at"`
}

type Option func(any)

type SharedContexts struct {
	Context                string
	TeamMemberInteractions []TeamMemberInteraction
}

type Team struct {
	Agent
	// contains filtered or unexported fields
}

type TeamMemberInteraction struct {
	MemberName string
	Task       string
	Response   *AgentRunResponse
}

type TeamMemory struct {
	sync.RWMutex

	SharedContexts SharedContexts
}

type TeamMode string

type TeamRunResponse struct {
	sync.RWMutex // for thread safe

	Reasoning       string         `json:"reasoning"`
	Answer          string         `json:"answer"`
	ToolCalls       []llm.ToolCall `json:"tool_calls"`
	Stream          chan *llm.Chunk
	MemberResponses []*AgentRunResponse

	Error error
}