Documentation
¶
Index ¶
- func IsValidMarkdownWithFrontmatter(content string) bool
- func ParseMarkdownFrontmatter(content string) (map[string]string, string)
- func PrintResult(ctx context.Context, result any) error
- func ReplaceOrAppendSection(content, heading, newSection string) string
- func SetFrontmatterField(content, key, value string) string
- func StripMarkdownCodeFences(s string) string
- type AgentResultInfo
- type AgentStatus
- type ContentGenerator
- type ResultDeliverer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func IsValidMarkdownWithFrontmatter ¶
IsValidMarkdownWithFrontmatter checks that the string has valid YAML frontmatter delimiters. The content must start with "---" followed by a newline and have a closing "---" on its own line.
func ParseMarkdownFrontmatter ¶
ParseMarkdownFrontmatter splits a markdown document with YAML frontmatter into a string map and the body. Returns empty map and full content if no frontmatter. Values are converted to strings: arrays become fmt representation, nested objects become fmt representation.
func PrintResult ¶
PrintResult marshals any value to JSON and prints to stdout.
func ReplaceOrAppendSection ¶
ReplaceOrAppendSection replaces an existing ## section or appends it at the end.
func SetFrontmatterField ¶
SetFrontmatterField updates or adds a field in YAML frontmatter. Returns content unchanged if no frontmatter delimiters are found.
func StripMarkdownCodeFences ¶
StripMarkdownCodeFences removes surrounding ``` code fences from a string if present.
Types ¶
type AgentResultInfo ¶
type AgentResultInfo struct {
Status AgentStatus
Output string // human-readable summary or result body
Message string // error or status message
}
AgentResultInfo holds the minimum fields a ContentGenerator needs from any agent result.
type AgentStatus ¶
type AgentStatus string
AgentStatus represents the outcome status of an agent task.
const ( // AgentStatusDone indicates the task completed successfully. AgentStatusDone AgentStatus = "done" // AgentStatusFailed indicates the task failed. AgentStatusFailed AgentStatus = "failed" // AgentStatusNeedsInput indicates the task requires additional user input. AgentStatusNeedsInput AgentStatus = "needs_input" )
type ContentGenerator ¶
type ContentGenerator interface {
Generate(ctx context.Context, originalContent string, result AgentResultInfo) (string, error)
}
ContentGenerator produces a complete updated task markdown document from the original content and agent result. The returned string must be valid markdown with YAML frontmatter.
func NewFallbackContentGenerator ¶
func NewFallbackContentGenerator() ContentGenerator
NewFallbackContentGenerator creates a ContentGenerator that uses deterministic string concatenation.
type ResultDeliverer ¶
type ResultDeliverer interface {
DeliverResult(ctx context.Context, result AgentResultInfo) error
}
ResultDeliverer publishes an agent result back to the task controller.
func NewFileResultDeliverer ¶
func NewFileResultDeliverer(generator ContentGenerator, filePath string) ResultDeliverer
NewFileResultDeliverer creates a ResultDeliverer that writes results to a task file. The generator produces the complete updated markdown; the deliverer writes it to disk.
func NewKafkaResultDeliverer ¶
func NewKafkaResultDeliverer( syncProducer libkafka.SyncProducer, branch base.Branch, taskID agentlib.TaskIdentifier, originalContent string, generator ContentGenerator, currentDateTime libtime.CurrentDateTimeGetter, ) ResultDeliverer
NewKafkaResultDeliverer creates a ResultDeliverer that publishes task updates to Kafka. taskID must be non-empty; if empty, use NewNoopResultDeliverer instead. originalContent is the original task markdown; the generator produces the complete updated content.
func NewNoopResultDeliverer ¶
func NewNoopResultDeliverer() ResultDeliverer
NewNoopResultDeliverer creates a ResultDeliverer that does nothing.
Source Files