Documentation
¶
Overview ¶
Package factory wires concrete dependencies for the agent-pi binary.
Index ¶
- Constants
- func CreateAgent(runner pilib.Runner, envContext map[string]string) *agentlib.Agent
- func CreateAgentProvider(runner pilib.Runner, envContext map[string]string) agentlib.AgentProvider
- func CreateFileResultDeliverer(filePath string) agentlib.ResultDeliverer
- func CreateKafkaResultDeliverer(syncProducer libkafka.SyncProducer, topicPrefix base.TopicPrefix, ...) agentlib.ResultDeliverer
- func CreatePiRunner(agentDir string, allowedTools string, model string, env map[string]string) pilib.Runner
Constants ¶
View Source
const ServiceName = "agent-pi"
ServiceName is the canonical service name for the agent-pi binary.
Variables ¶
This section is empty.
Functions ¶
func CreateAgent ¶
CreateAgent assembles the 3-phase pi agent from a pre-constructed Runner.
func CreateAgentProvider ¶
func CreateAgentProvider( runner pilib.Runner, envContext map[string]string, ) agentlib.AgentProvider
CreateAgentProvider wires the per-task-type dispatch table from a pre-constructed Runner so callers control Runner lifecycle.
func CreateFileResultDeliverer ¶
func CreateFileResultDeliverer(filePath string) agentlib.ResultDeliverer
CreateFileResultDeliverer creates a ResultDeliverer that writes the agent's output back to a markdown file.
func CreateKafkaResultDeliverer ¶
func CreateKafkaResultDeliverer( syncProducer libkafka.SyncProducer, topicPrefix base.TopicPrefix, taskID agentlib.TaskIdentifier, originalContent string, currentDateTime libtime.CurrentDateTimeGetter, ) agentlib.ResultDeliverer
CreateKafkaResultDeliverer creates a ResultDeliverer that publishes task updates to Kafka.
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.