harness

package module

Go to main page

Versions in this module

v0

v0.6.0

Aug 11, 2026

Changes in this version

type AgentDefinition

+ Description string

type Config

+ SubagentLimits SubagentLimits

+ Subagents SubagentPolicy

type ConversationCreatedPayload

+ ParentRef *ParentRef

type Dispatch

+ Parent *SpawnParent

+ type OrphanPolicy int

+ const CancelChildren

+ type ParentRef struct

+ ConversationID string

+ SpawnRecordID string

type RecordKind

+ const KindTaskSpawned

type SettledErrorCode

+ const SettledErrCancelled

+ type SpawnParent struct

+ CallID string

+ ConversationID string

+ Depth int

+ SpawnRecordID string

+ SubmissionID string

+ type SubagentLimits struct

+ MaxChildrenPerRun int

+ MaxDepth int

+ MaxWait time.Duration

+ OnParentTerminal OrphanPolicy

+ type SubagentPolicy map[string][]string

type Submission

+ CancelRequested bool

+ Depth int

+ ParentCallID string

+ ParentSubmissionID string

+ PendingResume bool

+ WaitUntil time.Time

+ type SubmissionResumedEvent struct

+ type SubmissionSpawnedEvent struct

+ Agent string

+ CallID string

+ ChildConversationID string

+ ChildSubmissionID string

type SubmissionStatus

+ const StatusWaiting

type SubmissionStore

+ CancelSubmission func(ctx context.Context, submissionID, reason string) (wasRunning bool, err error)

+ ListChildSubmissions func(ctx context.Context, parentSubmissionID string) ([]Submission, error)

+ ListExpiredWaits func(ctx context.Context, now time.Time) ([]Submission, error)

+ ResumeSubmission func(ctx context.Context, submissionID string) error

+ WaitSubmission func(ctx context.Context, wait SubmissionWait) error

+ type SubmissionWait struct

+ AttemptID string

+ SubmissionID string

+ WaitUntil time.Time

+ type SubmissionWaitingEvent struct

+ type TaskSpawnedPayload struct

+ Agent string

+ CallID string

+ ChildConversationID string

+ ChildInstance string

+ ChildSubmissionID string

+ Prompt string

v0.5.0

Aug 9, 2026

v0.4.0

Jul 26, 2026

Changes in this version

type CompactionPayload

+ Usage *pi.Usage

v0.3.0

Jul 25, 2026

Changes in this version

+ type ToolCallUpdatedEvent struct

+ CallID string

+ Result pi.ToolResult

+ ToolName string

v0.2.0

Jul 22, 2026

Changes in this version

type AgentRuntimeConfig

+ SummarizationRetry pi.SummarizationRetryPolicy

v0.1.1

Jul 6, 2026

Changes in this version

+ const DefaultMaxAttempts

+ const DefaultResultRetries

+ const DefaultSubmissionTimeout

+ var ErrAttachmentNotFound = errors.New("attachment not found")

+ var ErrClaimLost = errors.New("submission claim lost")

+ var ErrConversationNotFound = errors.New("conversation not found")

+ var ErrDispatchConflict = errors.New("dispatch id already admitted with a different payload")

+ var ErrInvalidDispatch = errors.New("invalid dispatch")

+ var ErrNoRunInFlight = errors.New("no run in flight for the session")

+ var ErrRuntimeClosed = errors.New("runtime is closed")

+ var ErrSessionBusy = errors.New("session has a run in flight")

+ var ErrSubmissionNotFound = errors.New("submission not found")

+ var ErrUnknownAgent = errors.New("unknown agent")

+ var ErrUnsupportedSchema = errors.New("unsupported store schema version")

+ type AgentDefinition struct

+ Initialize func(ctx context.Context, id InstanceID, env Env) (AgentRuntimeConfig, error)

+ type AgentRuntimeConfig struct

+ ContextWindow int

+ KeepRecentTokens int

+ MaxAttempts int

+ MaxTokens int

+ Model string

+ Providers []llm.LLMProvider

+ ReserveTokens int

+ Skills []pi.Skill

+ SubmissionTimeout time.Duration

+ SystemPrompt string

+ Tools []pi.RegisteredTool

+ type AssistantMessageCompletedPayload struct

+ Message MessagePayload

+ type AssistantMessageStartedPayload struct

+ MessageType string

+ Model string

+ type AssistantToolCallPayload struct

+ Args json.RawMessage

+ CallID string

+ ThoughtSignature []byte

+ ToolName string

+ type Attachment struct

+ Data []byte

+ Ref AttachmentRef

+ type AttachmentRef struct

+ Digest string

+ MediaType string

+ Size int64

+ type AttachmentStore interface

+ GetAttachment func(ctx context.Context, digest string) (Attachment, error)

+ PutAttachment func(ctx context.Context, mediaType string, data []byte) (AttachmentRef, error)

+ type Attempt struct

+ ID string

+ OwnerID string

+ StartedAt time.Time

+ SubmissionID string

+ type AttemptStartedEvent struct

+ type CompactRequest struct

+ Agent string

+ Instance InstanceID

+ Session string

+ type CompactionEvent struct

+ Reason string

+ type CompactionPayload struct

+ EndIdx int

+ FirstKeptEntryID string

+ StartIdx int

+ Summary string

+ type Config struct

+ Agents map[string]AgentDefinition

+ ClaimInterval time.Duration

+ DeltaFlushBytes int

+ DeltaFlushInterval time.Duration

+ Env Env

+ Interceptors []Interceptor

+ LeaseDuration time.Duration

+ Logger *slog.Logger

+ Observers []Observer

+ Store Store

+ type Conversation struct

+ CreatedAt time.Time

+ ID string

+ Key SessionKey

+ type ConversationCreatedPayload struct

+ Agent string

+ Instance InstanceID

+ Session string

+ type ConversationStore interface

+ AppendRecords func(ctx context.Context, conversationID string, recs []Record) error

+ EnsureConversation func(ctx context.Context, candidate Conversation) (Conversation, bool, error)

+ GetConversation func(ctx context.Context, key SessionKey) (Conversation, error)

+ ReadRecords func(ctx context.Context, conversationID string, afterID string) ([]Record, error)

+ type ConversationTree struct

+ Entries []ReducedEntry

+ LeafID string

+ func Reduce(records []Record) ConversationTree

+ func (t ConversationTree) ActiveLeafPath() []Record

+ type Correlation struct

+ AttemptID string

+ ConversationID string

+ SessionKey SessionKey

+ SubmissionID string

+ TurnID string

+ type DeltaEvent struct

+ Kind RecordKind

+ Text string

+ type Dispatch struct

+ Agent string

+ DispatchID string

+ Instance InstanceID

+ Message DispatchMessage

+ Session string

+ type DispatchMessage struct

+ Attachments []AttachmentRef

+ Body string

+ Kind InboundKind

+ ResultRetries int

+ ResultSchema json.RawMessage

+ Signal *SignalMeta

+ func SignalMessage(body string, meta SignalMeta) DispatchMessage

+ func UserMessage(body string) DispatchMessage

+ func (m DispatchMessage) Validate() error

+ type DispatchResult struct

+ ConversationID string

+ SubmissionID string

+ type Env interface

+ Secret func(name string) string

+ func OSEnv() Env

+ type HarnessEvent interface

+ type InboundKind string

+ const InboundSignal

+ const InboundUser

+ type InstanceID string

+ type Interceptor func(ctx context.Context, op OpInfo, next func(context.Context) error) error

+ type LeaseRenewal struct

+ AttemptID string

+ LeaseExpiresAt time.Time

+ SubmissionID string

+ type MessagePayload struct

+ Body json.RawMessage

+ Role string

+ Type string

+ func (m MessagePayload) ToPi() pi.Message

+ type Observer func(HarnessEvent)

+ type OpInfo struct

+ CallID string

+ Kind OpKind

+ Operation string

+ ToolName string

+ type OpKind string

+ const OpAttempt

+ const OpOperation

+ const OpTool

+ const OpTurn

+ type OperationEndedEvent struct

+ Err string

+ Operation string

+ type OperationStartedEvent struct

+ Operation string

+ type Record struct

+ Payload json.RawMessage

+ func (r Record) DecodePayload(dst interface{ ... }) error

+ type RecordEnvelope struct

+ AttemptID string

+ ConversationID string

+ ID string

+ Kind RecordKind

+ Session string

+ SubmissionID string

+ Time time.Time

+ TurnID string

+ type RecordKind string

+ const KindAssistantMessageCompleted

+ const KindAssistantMessageStarted

+ const KindAssistantTextDelta

+ const KindAssistantThinkingDelta

+ const KindAssistantToolCall

+ const KindCompaction

+ const KindConversationCreated

+ const KindSignal

+ const KindSubmissionSettled

+ const KindToolOutcome

+ const KindUserMessage

+ type RecoveryEvent struct

+ Decision string

+ Detail string

+ type ReducedEntry struct

+ ParentID string

+ Record Record

+ type Runtime struct

+ func NewRuntime(cfg Config) (*Runtime, error)

+ func (rt *Runtime) Close() error

+ func (rt *Runtime) Compact(ctx context.Context, req CompactRequest) error

+ func (rt *Runtime) Dispatch(ctx context.Context, d Dispatch) (DispatchResult, error)

+ func (rt *Runtime) FollowUp(ctx context.Context, req SteerRequest) error

+ func (rt *Runtime) Handler() http.Handler

+ func (rt *Runtime) Records(ctx context.Context, conversationID string, afterID string) ([]Record, error)

+ func (rt *Runtime) Start(ctx context.Context) error

+ func (rt *Runtime) Steer(ctx context.Context, req SteerRequest) error

+ func (rt *Runtime) Wait(ctx context.Context, submissionID string) (SettledPayload, error)

+ type SessionKey struct

+ Agent string

+ Instance InstanceID

+ Session string

+ func (k SessionKey) String() string

+ type SettledErrorCode string

+ const SettledErrAttemptBudget

+ const SettledErrIndeterminate

+ const SettledErrResultInvalid

+ const SettledErrRunFailed

+ const SettledErrTimeout

+ type SettledPayload struct

+ Error string

+ ErrorCode SettledErrorCode

+ Result json.RawMessage

+ Status SettledStatus

+ type SettledStatus string

+ const SettledFailed

+ const SettledSucceeded

+ type SignalMeta struct

+ Sender map[string]string

+ Tag string

+ Type string

+ type SignalPayload struct

+ Body string

+ Sender map[string]string

+ Tag string

+ Type string

+ type SteerRequest struct

+ Agent string

+ Body string

+ Instance InstanceID

+ Session string

+ type Store interface

+ type Submission struct

+ AttemptCount int

+ AttemptID string

+ ConversationID string

+ CreatedAt time.Time

+ ID string

+ Input DispatchMessage

+ LastError string

+ LeaseExpiresAt time.Time

+ OwnerID string

+ SessionKey SessionKey

+ Status SubmissionStatus

+ type SubmissionAdmittedEvent struct

+ Input DispatchMessage

+ type SubmissionClaim struct

+ AttemptID string

+ LeaseExpiresAt time.Time

+ OwnerID string

+ SubmissionID string

+ type SubmissionClaimedEvent struct

+ AttemptCount int

+ OwnerID string

+ type SubmissionRelease struct

+ AttemptID string

+ LastError string

+ SubmissionID string

+ type SubmissionSettledEvent struct

+ Payload SettledPayload

+ type SubmissionStatus string

+ const StatusQueued

+ const StatusRunning

+ const StatusSettled

+ const StatusTerminalizing

+ type SubmissionStore interface

+ AdmitSubmission func(ctx context.Context, sub Submission) (Submission, error)

+ ClaimSubmission func(ctx context.Context, claim SubmissionClaim) (Submission, error)

+ FinalizeSettlement func(ctx context.Context, submissionID string) error

+ GetSubmission func(ctx context.Context, id string) (Submission, error)

+ ListAttempts func(ctx context.Context, submissionID string) ([]Attempt, error)

+ ListByStatus func(ctx context.Context, status SubmissionStatus) ([]Submission, error)

+ ListExpiredLeases func(ctx context.Context, now time.Time) ([]Submission, error)

+ ListRunnable func(ctx context.Context) ([]Submission, error)

+ ReleaseSubmission func(ctx context.Context, release SubmissionRelease) error

+ RenewLease func(ctx context.Context, renewal LeaseRenewal) error

+ ReserveSettlement func(ctx context.Context, submissionID, attemptID string) error

+ StartAttempt func(ctx context.Context, attempt Attempt) error

+ type TextDeltaPayload struct

+ Text string

+ type ThinkingDeltaPayload struct

+ Text string

+ type ToolCallEndedEvent struct

+ CallID string

+ IsError bool

+ ToolName string

+ type ToolCallStartedEvent struct

+ CallID string

+ ToolName string

+ type ToolOutcomePayload struct

+ CallID string

+ Content string

+ Data json.RawMessage

+ IsError bool

+ ToolName string

+ type TurnEndedEvent struct

+ Turn int

+ type TurnStartedEvent struct

+ Turn int

+ type UserMessagePayload struct

+ Attachments []AttachmentRef

+ Body string

v0.1.0

Jul 4, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL