lib

Jun 3, 2026

Changes in this version

type TaskType

+ const TaskTypeLLM

May 25, 2026

Changes in this version

type TaskFrontmatter

+ func (f TaskFrontmatter) JobStartedAt() (time.Time, error)

May 14, 2026

Changes in this version

+ type AgentProvider interface

+ Get func(ctx context.Context, taskType TaskType) (*Agent, error)

+ func NewAgentProvider(name string, agents map[TaskType]*Agent) AgentProvider

May 14, 2026

Changes in this version

type TaskType

+ const TaskTypeHealthcheck

May 14, 2026

Changes in this version

type TaskFrontmatter

+ func (f TaskFrontmatter) TaskType() TaskType

+ type TaskType string

+ const TaskTypeBacktest

+ const TaskTypeClaude

+ const TaskTypeHypothesis

+ const TaskTypeOAuthProbe

+ const TaskTypePRReview

+ const TaskTypeTradeAnalysis

+ func (t TaskType) Bytes() []byte

+ func (t TaskType) Ptr() *TaskType

+ func (t TaskType) String() string

+ func (t TaskType) Validate(ctx context.Context) error

Apr 27, 2026

Changes in this version

+ const CreateTaskCommandOperation

+ type CreateTaskCommand struct

+ Body string

+ Frontmatter TaskFrontmatter

+ TaskIdentifier TaskIdentifier

Apr 26, 2026

Changes in this version

+ func ExtractSectionMap(ctx context.Context, md *Markdown, heading string) (map[string]any, error)

+ func ExtractSection[T any](ctx context.Context, md *Markdown, heading string) (*T, error)

+ func PrintResult(result *Result) error

+ type AIParser interface

+ Parse func(ctx context.Context, taskContent string, target any) error

+ type Agent struct

+ func NewAgent(phases ...Phase) *Agent

+ func (a *Agent) Run(ctx context.Context, phaseName domain.TaskPhase, taskContent string, ...) (*Result, error)

+ type AgentResultInfo struct

+ Message string

+ NextPhase string

+ Output string

+ Status AgentStatus

+ type AgentStatus string

+ const AgentStatusDone

+ const AgentStatusFailed

+ const AgentStatusInProgress

+ const AgentStatusNeedsInput

+ type Markdown struct

+ Frontmatter TaskFrontmatter

+ Preamble string

+ Sections []Section

+ func ParseMarkdown(_ context.Context, content string) (*Markdown, error)

+ func (m *Markdown) AddSection(section Section)

+ func (m *Markdown) FindSection(heading string) (*Section, bool)

+ func (m *Markdown) InsertSection(pos int, section Section)

+ func (m *Markdown) Marshal(ctx context.Context) (string, error)

+ func (m *Markdown) ReplaceSection(section Section)

+ type ParseStep struct

+ func NewParseStep[T any](name string, parser AIParser, heading string, nextPhase string) *ParseStep[T]

+ func (s *ParseStep[T]) Name() string

+ func (s *ParseStep[T]) Run(ctx context.Context, md *Markdown) (*Result, error)

+ func (s *ParseStep[T]) ShouldRun(_ context.Context, md *Markdown) (bool, error)

+ type Phase struct

+ Name domain.TaskPhase

+ Steps []Step

+ func NewPhase(name domain.TaskPhase, steps ...Step) Phase

+ type Result struct

+ ContinueToNext bool

+ Message string

+ NextPhase string

+ Status AgentStatus

+ type ResultDeliverer interface

+ DeliverResult func(ctx context.Context, result AgentResultInfo) error

+ type Section struct

+ Body string

+ Heading string

+ func MarshalSectionTyped[T any](ctx context.Context, heading string, value T) (Section, error)

+ type Step interface

+ Name func() string

+ Run func(ctx context.Context, md *Markdown) (*Result, error)

+ ShouldRun func(ctx context.Context, md *Markdown) (bool, error)

+ type StepRunner struct

+ func NewStepRunner(deliverer ResultDeliverer, steps ...Step) *StepRunner

+ func (r *StepRunner) Run(ctx context.Context, md *Markdown) (*Result, error)

type TaskFrontmatter

+ func (f TaskFrontmatter) Int(key string) (int, bool)

+ func (f TaskFrontmatter) String(key string) (string, bool)

Apr 24, 2026

Changes in this version

+ const IncrementFrontmatterCommandOperation

+ const UpdateFrontmatterCommandOperation

+ type BodySection struct

+ Heading string

+ Section string

+ type IncrementFrontmatterCommand struct

+ Delta int

+ Field string

+ TaskIdentifier TaskIdentifier

type TaskFrontmatter

+ func (f TaskFrontmatter) MaxTriggers() int

+ func (f TaskFrontmatter) TriggerCount() int

+ type UpdateFrontmatterCommand struct

+ Body *BodySection

+ TaskIdentifier TaskIdentifier

+ Updates TaskFrontmatter

Apr 19, 2026

Changes in this version

type TaskFrontmatter

+ func (f TaskFrontmatter) CurrentJob() string

+ func (f TaskFrontmatter) MaxRetries() int

+ func (f TaskFrontmatter) RetryCount() int

+ func (f TaskFrontmatter) SpawnNotification() bool

Apr 18, 2026

Changes in this version

+ var CDBSchemaIDs = cdb.SchemaIDs

+ var TaskV1SchemaID = cdb.SchemaID

+ type BuildInfoMetrics interface

+ SetBuildInfo func(buildDate *libtime.DateTime)

+ func NewBuildInfoMetrics() BuildInfoMetrics

+ type Task struct

+ Content TaskContent

+ Frontmatter TaskFrontmatter

+ TaskIdentifier TaskIdentifier

+ func (t Task) Ptr() *Task

+ func (t Task) Validate(ctx context.Context) error

+ type TaskAssignee string

+ func (t TaskAssignee) String() string

+ func (t TaskAssignee) Validate(ctx context.Context) error

+ type TaskContent string

+ func (t TaskContent) String() string

+ func (t TaskContent) Validate(ctx context.Context) error

+ type TaskFrontmatter map[string]interface

+ func (f TaskFrontmatter) Assignee() TaskAssignee

+ func (f TaskFrontmatter) Phase() *domain.TaskPhase

+ func (f TaskFrontmatter) Stage() string

+ func (f TaskFrontmatter) Status() domain.TaskStatus

+ type TaskIdentifier string

+ func (t TaskIdentifier) Bytes() []byte

+ func (t TaskIdentifier) Equal(identifier base.ObjectIdentifier) bool

+ func (t TaskIdentifier) Ptr() *TaskIdentifier

+ func (t TaskIdentifier) String() string

+ func (t TaskIdentifier) Validate(ctx context.Context) error

+ type TaskIdentifierGenerator base.IdentifierGenerator[TaskIdentifier]

+ type TaskIdentifiers []TaskIdentifier

+ func (t TaskIdentifiers) Contains(value TaskIdentifier) bool