agents

type A2A struct {
	InvokeHandler    http.Handler
	AgentCardHandler http.Handler
	// contains filtered or unexported fields
}

type Accumulator struct {
}

type Agent struct {
	Name string
	// contains filtered or unexported fields
}

type AgentInput struct {
	Namespace         string                               `json:"namespace"`
	PreviousMessageID string                               `json:"previous_message_id"`
	Messages          []responses.InputMessageUnion        `json:"messages"`
	RunContext        map[string]any                       `json:"run_context"`
	Callback          func(chunk *responses.ResponseChunk) `json:"-"`
	StreamBroker      core.StreamBroker                    `json:"-"`
}

type AgentOptions struct {
	History     *history.CommonConversationManager
	Instruction core.SystemPromptProvider
	Parameters  responses.Parameters

	Name       string
	LLM        llm.Provider
	Output     map[string]any
	Tools      []core.Tool
	McpServers []MCPToolset
	Runtime    AgentRuntime
	MaxLoops   int
}

type AgentOutput struct {
	RunID            string                          `json:"run_id"`
	Status           core.RunStatus                  `json:"status"`
	Output           []responses.InputMessageUnion   `json:"output"`
	PendingApprovals []responses.FunctionCallMessage `json:"pending_approvals"`
}

type AgentRuntime interface {
	Run(ctx context.Context, agent *Agent, in *AgentInput) (*AgentOutput, error)
}

type LLM interface {
	NewStreamingResponses(ctx context.Context, in *responses.Request, cb func(chunk *responses.ResponseChunk)) (*responses.Response, error)
}

type MCPToolset interface {
	GetName() string
	ListTools(ctx context.Context, runContext map[string]any) ([]core.Tool, error)
}

type WrappedLLM struct {
	// contains filtered or unexported fields
}