agentrt

package module

Go to main page

Versions in this module

v0

v0.5.0

Oct 8, 2026

Changes in this version

+ func PolicyJSON(raw json.RawMessage) (json.RawMessage, error)

+ type ChainBreak struct

+ Detail string

+ Expected string

+ Found string

+ Seq int64

+ type IdentifiedPolicy interface

+ PolicyID func() string

+ type PolicyIdentity string

+ const IdentityChanged

+ const IdentityUnchanged

+ const IdentityUnknown

+ type RecheckOptions struct

+ Tools []Tool

+ type RecheckReport struct

+ Evaluations []RecheckedEvaluation

+ Identity PolicyIdentity

+ Notes []string

+ PolicyID string

+ RunID string

+ RunStatus RunStatus

+ SpecSource SpecSource

+ func Recheck(ctx context.Context, store *Store, runID string, policy Policy, ...) (RecheckReport, error)

+ func (r RecheckReport) Complete() bool

+ func (r RecheckReport) Differences() int

+ func (r RecheckReport) MarshalJSON() ([]byte, error)

+ func (r RecheckReport) NotRecheckable() int

+ func (r RecheckReport) Rechecked() int

+ func (r RecheckReport) Same() bool

+ type RecheckResult string

+ const RecheckDifferent

+ const RecheckNotEvaluation

+ const RecheckNotRecheckable

+ const RecheckSame

+ type RecheckedEvaluation struct

+ Detail string

+ OnResume bool

+ PolicyID string

+ Rechecked *PolicyDecision

+ RecheckedHash string

+ Recorded PolicyDecision

+ RecordedHash string

+ Result RecheckResult

+ Seq int64

+ SpecSource SpecSource

+ StepID string

+ StepIndex int

+ Tool string

+ type SpecSource string

+ const SpecCurrent

+ const SpecRecorded

type Step

+ PolicyID string

+ SpecHash string

type Store

+ func (s *Store) ChainHead(ctx context.Context) (seq int64, hash string, err error)

+ func (s *Store) EventHash(ctx context.Context, seq int64) (string, error)

+ func (s *Store) ToolSpec(ctx context.Context, hash string) (ToolSpec, error)

+ func (s *Store) VerifyEvents(ctx context.Context, fromSeq, toSeq int64) (VerifyReport, error)

+ type VerifyReport struct

+ Break *ChainBreak

+ Checked int64

+ From int64

+ Hash string

+ To int64

v0.4.0

Oct 5, 2026

Changes in this version

+ var ErrSessionClosed = errors.New("agentrt: session is closed")

+ func CanonicalJSON(raw json.RawMessage) ([]byte, error)

type Decision

+ Origin DecisionOrigin

+ type DecisionOrigin string

+ const OriginModel

+ const OriginOperator

+ const OriginPlan

+ type Gate struct

+ func NewGate(cfg GateConfig) (*Gate, error)

+ func (g *Gate) Attach(ctx context.Context, runID string) (*Session, Verdict, error)

+ func (g *Gate) Begin(ctx context.Context, runID, goal string, limits Limits) (*Session, error)

+ type GateConfig struct

+ LeaseOwner string

+ LeaseTTL time.Duration

+ Model *ModelConfig

+ NewID func() string

+ Now func() time.Time

+ Observer Observer

+ Policy Policy

+ Reconcile func(ctx context.Context, view RunView) (Reconciliation, error)

+ Store *Store

+ Tools []Tool

+ type OpenStep struct

+ func (st *OpenStep) Execute(ctx context.Context) (Observation, error)

+ func (st *OpenStep) Fail(ctx context.Context, err error) (Verdict, error)

+ func (st *OpenStep) ID() string

+ func (st *OpenStep) Index() int

+ func (st *OpenStep) Model() ModelCaller

+ func (st *OpenStep) Propose(ctx context.Context, decision Decision) (Verdict, error)

+ type Session struct

+ func (s *Session) Close()

+ func (s *Session) Current() *OpenStep

+ func (s *Session) Done() bool

+ func (s *Session) Input(ctx context.Context) (StepInput, error)

+ func (s *Session) Run() Run

+ func (s *Session) Step(ctx context.Context) (*OpenStep, error)

+ type Verdict struct

+ Approval *Approval

+ Observation *Observation

+ Outcome VerdictOutcome

+ Request *ToolRequest

+ Run Run

+ type VerdictOutcome string

+ const VerdictAllowed

+ const VerdictDenied

+ const VerdictEnded

+ const VerdictPending

v0.3.2

Oct 3, 2026

v0.3.1

Oct 3, 2026

Changes in this version

+ var ErrApprovalExpired error = notPending("agentrt: approval has expired")

+ func CheckArgs(spec ToolSpec, args json.RawMessage) error

+ type Operator struct

+ Now func() time.Time

+ Observer Observer

+ Store *Store

+ func (o Operator) Approve(ctx context.Context, runID, approvalID, by, note string) error

+ func (o Operator) ApproveShown(ctx context.Context, runID, approvalID, shownHash, by, note string) error

+ func (o Operator) Cancel(ctx context.Context, runID, by, note string) error

+ func (o Operator) Reject(ctx context.Context, runID, approvalID, by, note string) error

+ func (o Operator) RejectShown(ctx context.Context, runID, approvalID, shownHash, by, note string) error

type Store

+ func (s *Store) ApprovalReason(ctx context.Context, runID, approvalID string) (string, error)

+ func (s *Store) Lease(ctx context.Context, runID string) (owner string, until time.Time, err error)

+ func (s *Store) ListEventsAfter(ctx context.Context, runID string, seq int64, limit int) ([]Event, error)

+ type ToolSchema struct

+ func CompileTool(spec ToolSpec) (*ToolSchema, error)

+ func (s *ToolSchema) Check(args json.RawMessage) error

v0.3.0

Oct 2, 2026

Changes in this version

+ const DefaultLeaseTTL

+ const DefaultMaxRetryAfter

+ const EventLeaseTakenOver

+ const InterruptedSideEffect

+ const MaxPageText

+ var ErrApprovalChanged = errors.New("agentrt: approval is not the one that was shown")

+ var ErrLeaseLost = errors.New("agentrt: run lease lost")

+ var ErrNotPending = errors.New("agentrt: approval is not pending")

+ var ErrRunState = errors.New("agentrt: run is not in the required state")

+ var ErrSchemaVersion = errors.New("agentrt: database schema version does not match this build")

+ var ErrSymlink = errors.New("agentrt: database path is a symbolic link")

+ var ErrUnsafeSchema = errors.New("agentrt: database holds a trigger or view")

+ var ErrUnusableUsage = errors.New("unusable usage")

+ func ApproveShown(ctx context.Context, store *Store, obs Observer, ...) error

+ func RejectShown(ctx context.Context, store *Store, obs Observer, ...) error

type Approval

+ DecodeError string

type Config

+ LeaseOwner string

+ LeaseTTL time.Duration

type Decision

+ InvalidArgs string

+ InvalidBase64 bool

+ InvalidResult string

+ type ErrInsecureMode struct

+ Mode fs.FileMode

+ Path string

+ Reason string

+ func (e ErrInsecureMode) Error() string

+ type ErrRunLeased struct

+ ExpiresAt time.Time

+ Owner string

+ RunID string

+ func (e ErrRunLeased) Error() string

+ func (e ErrRunLeased) Unwrap() error

type Limits

+ GrantTTL time.Duration

type ModelConfig

+ MaxRetryAfter time.Duration

type Reconciliation

+ Pause *PolicyDecision

+ type ServedError struct

+ Err error

+ Usage Usage

+ func (e ServedError) Error() string

+ func (e ServedError) Unwrap() error

type Step

+ DecodeError string

type Store

+ func OpenExisting(path string, readOnly bool) (*Store, error)

+ func (s *Store) GetRunCapped(ctx context.Context, id string) (Run, error)

+ func (s *Store) ListApprovalsPage(ctx context.Context, runID string, status ApprovalStatus, limit, offset int) ([]Approval, int, error)

+ func (s *Store) ListEventsPage(ctx context.Context, runID string, limit, offset int) ([]Event, int, error)

+ func (s *Store) ListRunsPage(ctx context.Context, limit, offset int) ([]Run, int, error)

+ func (s *Store) ListStepsPage(ctx context.Context, runID string, limit, offset int) ([]Step, int, error)

+ func (s *Store) PendingApprovalIDs(ctx context.Context) (map[string][]string, error)

+ func (s *Store) PendingApprovalIDsOf(ctx context.Context, runIDs []string, max int) (map[string][]string, error)

type TransientError

+ RetryAfter time.Duration

v0.2.1

Sep 25, 2026

v0.2.0

Sep 25, 2026

Changes in this version

+ func DecodePresentation[T any](a Approval) (T, error)

type DecisionKind

+ const KindNoToolCall

+ const KindTruncated

type PolicyDecision

+ func NeedApproval(kind, reason string, capability, presentation any) (PolicyDecision, error)

v0.1.2

Sep 23, 2026

v0.1.1

Sep 22, 2026

Changes in this version

+ func Cancel(ctx context.Context, store *Store, obs Observer, runID, by, note string) error

type Driver

+ func (d *Driver) Cancel(ctx context.Context, runID, by, note string) error

type TerminalReason

+ const ReasonOperatorCancelled

v0.1.0

Sep 20, 2026

Changes in this version

+ const EventApprovalDecided

+ const EventApprovalRequested

+ const EventLimitExceeded

+ const EventLoopDetected

+ const EventModelCompleted

+ const EventModelDispatched

+ const EventModelFailed

+ const EventRunCreated

+ const EventRunFinished

+ const EventRunInterrupted

+ const EventRunResumed

+ const EventRunStarted

+ const EventStepDecided

+ const EventStepFailed

+ const EventStepInterrupted

+ const EventStepPolicy

+ const EventStepStarted

+ const EventStepToolFinished

+ const EventStepToolStarted

+ var ErrApprovalHash = errors.New("agentrt: approval hash does not match its recorded request")

+ var ErrNotFound = errors.New("agentrt: not found")

+ func Approve(ctx context.Context, store *Store, obs Observer, ...) error

+ func EstimateInputTokens(req ModelRequest) int

+ func Reject(ctx context.Context, store *Store, obs Observer, ...) error

+ type Agent interface

+ Decide func(ctx context.Context, in StepInput) (Decision, error)

+ type Approval struct

+ Capability json.RawMessage

+ CreatedAt time.Time

+ DecidedAt time.Time

+ DecidedBy string

+ ExpiresAt time.Time

+ Hash string

+ ID string

+ Kind string

+ Note string

+ Presentation json.RawMessage

+ Request ToolRequest

+ RunID string

+ Status ApprovalStatus

+ StepID string

+ type ApprovalStatus string

+ const ApprovalApproved

+ const ApprovalExpired

+ const ApprovalPending

+ const ApprovalRejected

+ type Config struct

+ Agent Agent

+ Model *ModelConfig

+ NewID func() string

+ Now func() time.Time

+ Observer Observer

+ Policy Policy

+ Reconcile func(ctx context.Context, view RunView) (Reconciliation, error)

+ Store *Store

+ Tools []Tool

+ type ContentBlock struct

+ Content string

+ Input json.RawMessage

+ IsError bool

+ Name string

+ Text string

+ ToolUseID string

+ Type string

+ type Decision struct

+ Args json.RawMessage

+ Kind DecisionKind

+ Message string

+ Reason string

+ Result json.RawMessage

+ Tool string

+ type DecisionKind string

+ const DecideComplete

+ const DecideFail

+ const DecideToolCall

+ type Driver struct

+ func NewDriver(cfg Config) (*Driver, error)

+ func (d *Driver) Approve(ctx context.Context, runID, approvalID, by, note string) error

+ func (d *Driver) Reject(ctx context.Context, runID, approvalID, by, note string) error

+ func (d *Driver) Resume(ctx context.Context, runID string) (Run, error)

+ func (d *Driver) Start(ctx context.Context, goal string, limits Limits) (Run, error)

+ func (d *Driver) StartWithID(ctx context.Context, id, goal string, limits Limits) (Run, error)

+ type ErrAbortRun struct

+ Detail string

+ func (e ErrAbortRun) Error() string

+ type ErrLimit struct

+ Detail string

+ Reason TerminalReason

+ func (e ErrLimit) Error() string

+ type ErrModelUnavailable struct

+ Attempts int

+ Last error

+ func (e ErrModelUnavailable) Error() string

+ func (e ErrModelUnavailable) Unwrap() error

+ type Event struct

+ At time.Time

+ Payload json.RawMessage

+ RunID string

+ Seq int64

+ StepID string

+ Type string

+ type Limits struct

+ ApprovalTTL time.Duration

+ LoopThreshold int

+ MaxActiveTime time.Duration

+ MaxConsecutiveToolFailures int

+ MaxElapsedTime time.Duration

+ MaxEstimatedCost Micros

+ MaxModelCalls int

+ MaxOutputTokensPerCall int

+ MaxSteps int

+ MaxTotalTokens int

+ func DefaultLimits() Limits

+ type Message struct

+ Content []ContentBlock

+ Role string

+ type Micros int64

+ type Model interface

+ Generate func(ctx context.Context, req ModelRequest) (ModelResponse, error)

+ Name func() string

+ type ModelCall struct

+ Attempt int

+ CompletedAt time.Time

+ Cost Micros

+ DispatchedAt time.Time

+ Error string

+ ID string

+ Latency time.Duration

+ Model string

+ RunID string

+ Status ModelCallStatus

+ StepID string

+ Usage Usage

+ type ModelCallStatus string

+ const CallAmbiguous

+ const CallDispatched

+ const CallError

+ const CallOK

+ type ModelCaller interface

+ Generate func(ctx context.Context, req ModelRequest) (ModelResponse, error)

+ type ModelConfig struct

+ Backoff time.Duration

+ CallTimeout time.Duration

+ MaxRetries int

+ Model Model

+ Prices PriceTable

+ type ModelRequest struct

+ MaxOutputTokens int

+ Messages []Message

+ System string

+ Tools []ToolSpec

+ type ModelResponse struct

+ Raw json.RawMessage

+ StopReason string

+ Text string

+ ToolUses []ToolUse

+ Usage Usage

+ type Observation struct

+ Content json.RawMessage

+ ContentHash string

+ Kind ObservationKind

+ Summary string

+ func (o Observation) Failure() bool

+ type ObservationKind string

+ const ObserveInterrupted

+ const ObserveInvalidDecision

+ const ObservePolicyDenied

+ const ObserveToolError

+ const ObserveToolResult

+ type Observer func(Event)

+ type Policy interface

+ Evaluate func(ctx context.Context, req ToolRequest, view RunView) (PolicyDecision, error)

+ type PolicyDecision struct

+ Capability json.RawMessage

+ Kind string

+ Outcome PolicyOutcome

+ Presentation json.RawMessage

+ Reason string

+ type PolicyFunc func(ctx context.Context, req ToolRequest, view RunView) (PolicyDecision, error)

+ func (f PolicyFunc) Evaluate(ctx context.Context, req ToolRequest, view RunView) (PolicyDecision, error)

+ type PolicyOutcome string

+ const Abort

+ const Allow

+ const Deny

+ const RequireApproval

+ type Price struct

+ CachedInputPerMTok Micros

+ InputPerMTok Micros

+ OutputPerMTok Micros

+ type PriceTable map[string]Price

+ type ReconcileOutcome string

+ const ReconcileCompleted

+ const ReconcileConflict

+ const ReconcileContinue

+ const ReconcileWaiting

+ type Reconciliation struct

+ Detail string

+ Outcome ReconcileOutcome

+ Result json.RawMessage

+ type Run struct

+ ActiveTime time.Duration

+ CreatedAt time.Time

+ EstimatedCost Micros

+ FinishedAt time.Time

+ Goal string

+ ID string

+ Limits Limits

+ ModelCalls int

+ Reason TerminalReason

+ ReasonDetail string

+ Result json.RawMessage

+ StartedAt time.Time

+ Status RunStatus

+ StepCount int

+ Usage Usage

+ type RunStatus string

+ const StatusCancelled

+ const StatusCompleted

+ const StatusCreated

+ const StatusFailed

+ const StatusInterrupted

+ const StatusRunning

+ const StatusWaitingForApproval

+ func (s RunStatus) Terminal() bool

+ type RunView struct

+ Approvals []Approval

+ Run Run

+ Steps []Step

+ type SideEffect string

+ const Destructive

+ const LocalMutation

+ const ReadOnly

+ const RemoteMutation

+ type SideEffectPolicy map[SideEffect]PolicyOutcome

+ func DefaultPolicy() SideEffectPolicy

+ func (p SideEffectPolicy) Evaluate(_ context.Context, req ToolRequest, _ RunView) (PolicyDecision, error)

+ type Step struct

+ Decision *Decision

+ FinishedAt time.Time

+ ID string

+ Index int

+ Observation *Observation

+ Policy *PolicyDecision

+ RunID string

+ StartedAt time.Time

+ Status StepStatus

+ type StepInput struct

+ Approvals []Approval

+ Model ModelCaller

+ Run Run

+ Steps []Step

+ Tools []ToolSpec

+ type StepStatus string

+ const StepAwaitingApproval

+ const StepDeciding

+ const StepDone

+ const StepExecuting

+ const StepFailed

+ const StepInterrupted

+ type Store struct

+ func OpenStore(path string) (*Store, error)

+ func (s *Store) Close() error

+ func (s *Store) CreateRun(ctx context.Context, r Run) error

+ func (s *Store) DB() *sql.DB

+ func (s *Store) GetApproval(ctx context.Context, runID, id string) (Approval, error)

+ func (s *Store) GetRun(ctx context.Context, id string) (Run, error)

+ func (s *Store) ListApprovals(ctx context.Context, runID string) ([]Approval, error)

+ func (s *Store) ListEvents(ctx context.Context, runID string) ([]Event, error)

+ func (s *Store) ListModelCalls(ctx context.Context, runID string) ([]ModelCall, error)

+ func (s *Store) ListRuns(ctx context.Context) ([]Run, error)

+ func (s *Store) ListSteps(ctx context.Context, runID string) ([]Step, error)

+ type TerminalReason string

+ const ReasonAgentError

+ const ReasonApprovalExpired

+ const ReasonApprovalRejected

+ const ReasonGoalCompleted

+ const ReasonGoalFailed

+ const ReasonInternalError

+ const ReasonLimitActiveTime

+ const ReasonLimitCost

+ const ReasonLimitElapsedTime

+ const ReasonLimitModelCalls

+ const ReasonLimitSteps

+ const ReasonLimitTokens

+ const ReasonLoopDetected

+ const ReasonModelUnavailable

+ const ReasonPolicyAbort

+ const ReasonReconcileConflict

+ const ReasonRepeatedToolFailures

+ const ReasonToolAbort

+ type Tool interface

+ Call func(ctx context.Context, call ToolCall) (ToolResult, error)

+ Spec func() ToolSpec

+ type ToolCall struct

+ Args json.RawMessage

+ RunID string

+ StepID string

+ type ToolRequest struct

+ Args json.RawMessage

+ RunID string

+ Spec ToolSpec

+ StepID string

+ type ToolResult struct

+ Content json.RawMessage

+ Summary string

+ type ToolSpec struct

+ Description string

+ InputSchema json.RawMessage

+ Name string

+ SideEffect SideEffect

+ Terminal bool

+ Timeout time.Duration

+ type ToolUse struct

+ Args json.RawMessage

+ ID string

+ Name string

+ type TransientError struct

+ Err error

+ func (e TransientError) Error() string

+ func (e TransientError) Unwrap() error

+ type Usage struct

+ CachedInputTokens int

+ InputTokens int

+ OutputTokens int

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