Versions in this module Expand all Collapse all v2 v2.2.0 Jul 29, 2026 Changes in this version + type ToolCallStream struct + ID string + Name string v2.1.0 Jul 29, 2026 Changes in this version + type ActivePendingToolCompletion struct + CompletionRequestID string + ContinuationRunID RunID + ContinuationTurnID TurnID + Input TurnInput + Labels RunLabels + Output string + Status PendingToolCompletionStatus + Summary string + Target ActivePendingToolTarget + type ActivePendingToolSettlement struct + Activity *observation.ActivityPresentation + Output string + Status PendingToolSettlementStatus + Summary string + Target ActivePendingToolTarget + type ActivePendingToolTarget struct + EffectAttemptID string + Handle string + RunID RunID + ToolCallID string + ToolName string + TurnID TurnID + type AgentTodoUpdateRequest struct + ExpectedVersion int64 + Items []AgentTodo + RunID RunID + ToolCallID string + TurnID TurnID + type ApprovalResolutionRequest struct + Decision ApprovalDecision + DecisionID string + ExpectedApprovalRevision int64 + ExpectedCurrent ApprovalIdentity + ExpectedGeneration int64 + ExpectedRevision int64 + type RetryRequest struct + Labels RunLabels + Reason string type SubAgentManager + func (manager *SubAgentManager) SettlePendingTool(ctx context.Context, request PendingToolSettlementRequest) (PendingToolSettlementResult, error) type SubAgentReader + func (reader *SubAgentReader) ListPendingToolTargets(ctx context.Context, childThreadID ThreadID) ([]PendingToolSettlementTarget, error) + func (reader *SubAgentReader) ListTurns(ctx context.Context, childThreadID ThreadID, request ThreadTurnsRequest) (ThreadTurnsPage, error) + func (reader *SubAgentReader) ReadArtifact(ctx context.Context, childThreadID ThreadID, artifactID ArtifactID) (ArtifactContent, error) + func (reader *SubAgentReader) ReadTurn(ctx context.Context, childThreadID ThreadID, turnID TurnID) (ThreadTurnSnapshot, error) + type ThreadDetailRequest struct + AfterOrdinal int64 + IncludeRaw bool + Limit int type ThreadReader + func (reader *ThreadReader) ListDetailEvents(ctx context.Context, request ThreadDetailRequest) (ThreadDetailEvents, error) + func (reader *ThreadReader) ListPendingToolTargets(ctx context.Context) ([]PendingToolSettlementTarget, error) + func (reader *ThreadReader) ListTurns(ctx context.Context, request ThreadTurnsRequest) (ThreadTurnsPage, error) + func (reader *ThreadReader) ReadAgentTodos(ctx context.Context) (ThreadAgentTodoState, error) + func (reader *ThreadReader) ReadApprovalQueue(ctx context.Context) (ApprovalQueue, error) + func (reader *ThreadReader) ReadArtifact(ctx context.Context, artifactID ArtifactID) (ArtifactContent, error) + func (reader *ThreadReader) ReadContext(ctx context.Context) (ThreadContextSnapshot, error) + func (reader *ThreadReader) ReadOverview(ctx context.Context) (ThreadOverview, error) + func (reader *ThreadReader) ReadProjection(ctx context.Context, turnID TurnID, runID RunID) (ThreadTurnProjection, error) + type ThreadTurnsRequest struct + BeforeCursor *ThreadTurnCursor + Limit int + SinceCursor *ThreadTurnCursor + Tail int type TurnRunner + func (runner *TurnRunner) CompletePendingTool(ctx context.Context, request ActivePendingToolCompletion) (PendingToolCompletionResult, error) + func (runner *TurnRunner) ResolveApproval(ctx context.Context, request ApprovalResolutionRequest) (ResolveApprovalResult, error) + func (runner *TurnRunner) Retry(ctx context.Context, request RetryRequest) (TurnResult, error) + func (runner *TurnRunner) SettlePendingTool(ctx context.Context, request ActivePendingToolSettlement) (PendingToolSettlementResult, error) + func (runner *TurnRunner) UpdateAgentTodos(ctx context.Context, request AgentTodoUpdateRequest) (ThreadAgentTodoState, error) v2.0.0 Jul 29, 2026 Changes in this version + const CoreControlAskUser + const CoreControlTaskComplete + const MaxMessageAttachmentMIMETypeBytes + const MaxMessageAttachmentNameRunes + const MaxMessageAttachmentResourceRefBytes + const MaxMessageAttachmentSizeBytes + const MaxMessageAttachmentsPayloadBytes + const MaxMessageAttachmentsPerTurn + const MaxMessageAttachmentsTotalSizeBytes + const MaxMessageReferenceIDBytes + const MaxMessageReferenceLabelRunes + const MaxMessageReferenceResourceRefBytes + const MaxMessageReferenceTextRunes + const MaxMessageReferencesPayloadBytes + const MaxMessageReferencesPerTurn + const MaxTurnSupplementalContextItems + const MaxTurnSupplementalContextKindRunes + const MaxTurnSupplementalContextTextRunes + const MaxTurnSupplementalContextTitleRunes + const MaxTurnSupplementalMetadataKeyBytes + const MaxTurnSupplementalMetadataPairs + const MaxTurnSupplementalMetadataValueRunes + const MaxTurnSupplementalPayloadBytes + const MessageReferenceDirectory + const MessageReferenceFile + const MessageReferenceProcess + const MessageReferenceTerminal + const MessageReferenceText + var ErrAgentTodoVersionConflict = errors.New("floret agent todo version conflict") + var ErrArtifactNotFound = errors.New("floret artifact not found") + var ErrAuthorityCorrupt = errors.New("floret authority state is corrupt") + var ErrAuthorizationContract = errors.New("floret effect authorization contract failed") + var ErrAuthorizationUnavailable = errors.New("floret effect authorization is unavailable") + var ErrEffectDispatchConsumed = errors.New("floret authorized effect dispatch was consumed") + var ErrEffectOutcomeUnknown = errors.New("floret effect outcome is unknown") + var ErrEffectUnauthorized = errors.New("floret effect is unauthorized") + var ErrForkDestinationConflict = errors.New("floret fork destination conflicts with operation plan") + var ErrForkOperationConflict = errors.New("floret fork operation conflicts with existing request") + var ErrInterruptedTurnNotFound = errors.New("floret interrupted turn not found") + var ErrInvalidAuthorizationProof = errors.New("floret effect authorization proof is invalid") + var ErrInvalidThreadInventoryCursor = errors.New("floret thread inventory cursor is invalid") + var ErrInvalidThreadTurnCursor = errors.New("floret thread turn cursor is invalid") + var ErrJournalInvariant = errors.New("floret thread journal invariant violated") + var ErrMigrationRequired = errors.New("floret storage migration required") + var ErrNoRetryTarget = errors.New("floret thread has no retry target") + var ErrPendingToolNotActive = errors.New("floret pending tool is not active") + var ErrPendingToolNotFound = errors.New("floret pending tool not found") + var ErrPendingToolSettlementConflict = errors.New("floret pending tool settlement conflict") + var ErrRecoveryTargetResolved = errors.New("floret interrupted turn recovery target is resolved") + var ErrRequestConflict = errors.New("floret request conflicts with persisted authority") + var ErrRunNotFound = errors.New("floret run not found") + var ErrStaleAuthority = errors.New("floret authority proof is stale") + var ErrStaleThreadTurnCursor = errors.New("floret thread turn cursor is stale") + var ErrStoreClosed = errors.New("floret store is closed") + var ErrSubAgentClosed = errors.New("floret subagent is closed") + var ErrSubAgentClosing = errors.New("floret subagent is closing") + var ErrSubAgentNotFound = errors.New("floret subagent not found") + var ErrSubAgentParentRequired = errors.New("floret subagent operation requires parent authority") + var ErrThreadAuthorityInvariant = errors.New("floret thread authority invariant violated") + var ErrThreadBusy = errors.New("floret thread is busy") + var ErrThreadDeleted = errors.New("floret thread is deleted") + var ErrThreadNotActive = errors.New("floret thread is not active") + var ErrThreadNotFound = errors.New("floret thread not found") + var ErrTurnNotFound = errors.New("floret turn not found") + var ErrUnsupportedSchema = errors.New("unsupported floret logical schema") + var ErrUnsupportedStoreCapability = errors.New("floret store capability is unsupported") + func CoreControlDefinitions(includeTaskComplete bool) []tools.ToolDefinition + func ManualCompactionOperationID(runID RunID, step int, requestID string) string + func ProviderSafeCoreControlText(signal TurnSignal) string + type Agent struct + func NewAgent(configuration config.AgentConfig, gateway provider.Gateway, ...) (*Agent, error) + func (agent *Agent) Config() config.AgentConfig + func (agent *Agent) ProviderIdentity() provider.Identity + func (agent *Agent) ToolDefinitions() []tools.ToolDefinition + type AgentOption struct + func WithAgentCapabilities(capabilities CapabilityOptions) AgentOption + func WithAgentDynamicToolSurface(surface ToolSurfaceProvider) AgentOption + func WithAgentEffectAuthorization(gate EffectAuthorizationGate) AgentOption + func WithAgentEventSink(sink EventSink) AgentOption + func WithAgentIDGenerator(generator func(string) string) AgentOption + func WithAgentLoopLimits(limits LoopLimits) AgentOption + func WithAgentSubAgentTimeout(timeout time.Duration) AgentOption + func WithAgentThreadTitleMode(mode ThreadTitleMode) AgentOption + func WithAgentTools(items ...tools.Tool) AgentOption + type AgentTodo struct + Content string + ID string + Status AgentTodoStatus + type AgentTodoStatus string + const AgentTodoCompleted + const AgentTodoInProgress + const AgentTodoPending + func (s AgentTodoStatus) Valid() bool + type ApprovalDecision string + const ApprovalDecisionApprove + const ApprovalDecisionReject + type ApprovalDecisionReceipt struct + ApprovalID string + ApprovalRevision int64 + AuthorizationProofHash string + Decision ApprovalDecision + DecisionID string + QueueGeneration int64 + QueueRevision int64 + Reason string + ResolvedAt time.Time + RootThreadID ThreadID + State string + SubmittedAt time.Time + func (r ApprovalDecisionReceipt) Validate() error + type ApprovalIdentity struct + ApprovalID string + EffectAttemptID string + RunID RunID + ThreadID ThreadID + ToolCallID string + TurnID TurnID + func (i ApprovalIdentity) Validate() error + type ApprovalQueue struct + CurrentApprovalID string + GeneratedAt time.Time + Generation int64 + Items []ApprovalRecord + Revision int64 + RootThreadID ThreadID + func (q ApprovalQueue) Validate() error + type ApprovalRecord struct + ApprovalID string + ArgsHash string + AuthorizationProofHash string + BatchIndex int + BatchSize int + DecisionID string + Destructive bool + EffectAttemptID string + Effects []string + HostContext map[string]string + Labels map[string]string + OpenWorld bool + ParentThreadID ThreadID + QueueSequence int64 + ReadOnly bool + Reason string + RequestFingerprint string + RequestedAt time.Time + ResolvedAt time.Time + Resources []ApprovalResource + Revision int64 + RootThreadID ThreadID + RunID RunID + State string + Step int + ThreadID ThreadID + ToolCallID string + ToolKind string + ToolName string + TurnID TurnID + UpdatedAt time.Time + func (p ApprovalRecord) Validate() error + type ApprovalResource struct + Kind string + Value string + func (r ApprovalResource) Validate() error + type ArtifactContent struct + Ref ArtifactRef + Text string + func (c ArtifactContent) Validate() error + type ArtifactID string + type ArtifactRef struct + ID ArtifactID + Kind string + MIME string + SHA256 string + SafeLabel string + SizeBytes int64 + func (r ArtifactRef) Validate() error + type AuthorityBusyError struct + Err error + Kind AuthorityBusyKind + func (e *AuthorityBusyError) Error() string + func (e *AuthorityBusyError) Is(target error) bool + func (e *AuthorityBusyError) Unwrap() error + type AuthorityBusyKind string + const AuthorityBusyAuthority + const AuthorityBusyTurn + type AuthorizedEffect func(context.Context, EffectAuthorizationProof) (EffectDispatchResult, error) + type CapabilityOptions struct + SkillPromptBudgetBytes int + SkillSources []string + SkillsEnabled bool + type CloseSubAgent struct + ChildThreadID ThreadID + CloseOperationID string + Reason string + type CloseSubAgentRequest struct + ChildThreadID ThreadID + CloseOperationID string + ParentThreadID ThreadID + Reason string + type CommittedCleanupError struct + Err error + ThreadID ThreadID + func (e *CommittedCleanupError) Error() string + func (e *CommittedCleanupError) Unwrap() error + type CommittedEffectError struct + EffectAttemptID string + Err error + func (e *CommittedEffectError) Error() string + func (e *CommittedEffectError) Unwrap() error + type CompactThreadRequest struct + Labels RunLabels + Limits TurnLimits + Reasoning config.ReasoningSelection + RequestID string + Source string + ThreadID ThreadID + type CompactThreadResult struct + ActivityTimeline observation.ActivityTimeline + Compaction observation.CompactionEvent + Metrics RunMetrics + Replayed bool + RequestID string + RunID RunID + ThreadID ThreadID + func (r CompactThreadResult) Validate() error + type ContractError struct + Contract string + Err error + func (e *ContractError) Error() string + func (e *ContractError) Is(target error) bool + func (e *ContractError) Unwrap() error + type CreateIntentID string + type CreateThreadRequest struct + CreateIntentID CreateIntentID + ThreadID ThreadID + func (r CreateThreadRequest) Validate() error + type EffectAuthorizationGate interface + Dispatch func(context.Context, EffectAuthorizationRequest, AuthorizedEffect) (EffectDispatchResult, error) + type EffectAuthorizationGateFunc func(context.Context, EffectAuthorizationRequest, AuthorizedEffect) (EffectDispatchResult, error) + func (f EffectAuthorizationGateFunc) Dispatch(ctx context.Context, req EffectAuthorizationRequest, effect AuthorizedEffect) (EffectDispatchResult, error) + type EffectAuthorizationProof struct + ApprovalID string + AuditHash string + AuditReference string + AuthorizedAt time.Time + EffectAttemptID string + LeaseGeneration int64 + LeaseOwnerID string + PolicyRevision string + RequestFingerprint string + RunID RunID + ThreadID ThreadID + ToolCallID string + TurnID TurnID + type EffectAuthorizationRequest struct + ArgumentHash string + BatchIndex int + BatchSize int + Destructive bool + EffectAttemptID string + Effects []tools.Effect + HostContext map[string]string + Labels map[string]string + LeaseGeneration int64 + LeaseOwnerID string + ObservedHeartbeat int64 + OpenWorld bool + Permission tools.PermissionSpec + ReadOnly bool + RequestFingerprint string + Resources []tools.ResourceRef + RunID RunID + Step int + ThreadID ThreadID + ToolCallID string + ToolName string + TurnID TurnID + type EffectDispatchResult struct + type Event struct + Activity *observation.ActivityPresentation + ActivityTimeline *observation.ActivityTimeline + ArgsHash string + Committed *ThreadDetailEvent + Compaction *observation.CompactionEvent + CompactionDebug *observation.CompactionDebugEvent + CompletionReason observation.CompletionReason + ContextStatus *observation.ContextStatus + ContinuationReason observation.ContinuationReason + DurationMS int64 + Error string + FinishInferred bool + FinishReason observation.FinishReason + Message string + Metadata map[string]any + Model string + Projection *ThreadTurnProjection + Provider string + RawFinishReason string + Result string + RunID RunID + Sources []publicprovider.Source + Step int + Stream *StreamObservation + ThreadID ThreadID + Timestamp time.Time + ToolID string + ToolKind string + ToolName string + TraceID TraceID + TurnID TurnID + Type observation.EventType + func (e Event) Validate() error + type EventSink interface + EmitEvent func(Event) + type ForkOperationID string + type ForkThreadRequest struct + DestinationThreadID ThreadID + OperationID ForkOperationID + SourceThreadID ThreadID + type ForkThreadResult struct + OperationID ForkOperationID + Thread ThreadSummary + func (r ForkThreadResult) Validate() error + type Host struct + func Open(ctx context.Context, options Options) (*Host, error) + func (host *Host) Close() error + func (host *Host) InterruptedTurnRecovery(ctx context.Context, target InterruptedTurnRecoveryTarget, sink EventSink) (*InterruptedTurnRecovery, error) + func (host *Host) PendingToolRecovery(ctx context.Context, target PendingToolRecoveryTarget, sink EventSink) (*PendingToolRecovery, error) + func (host *Host) SubAgentManager(ctx context.Context, parentThreadID ThreadID, agent *Agent) (*SubAgentManager, error) + func (host *Host) SubAgentReader(ctx context.Context, parentThreadID ThreadID) (*SubAgentReader, error) + func (host *Host) ThreadCompactor(ctx context.Context, threadID ThreadID, agent *Agent) (*ThreadCompactor, error) + func (host *Host) ThreadCreator(threadID ThreadID, createIntentID CreateIntentID) (*ThreadCreator, error) + func (host *Host) ThreadDeleter(ctx context.Context, threadID ThreadID) (*ThreadDeleter, error) + func (host *Host) ThreadForker(ctx context.Context, threadID ThreadID) (*ThreadForker, error) + func (host *Host) ThreadInventory(ctx context.Context) (*ThreadInventory, error) + func (host *Host) ThreadReader(ctx context.Context, threadID ThreadID) (*ThreadReader, error) + func (host *Host) ThreadTitleEditor(ctx context.Context, threadID ThreadID) (*ThreadTitleEditor, error) + func (host *Host) TurnRunner(ctx context.Context, threadID ThreadID, agent *Agent) (*TurnRunner, error) + type InterruptedTurnRecovery struct + func (recovery *InterruptedTurnRecovery) Recover(ctx context.Context) (RecoverInterruptedTurnResult, error) + type InterruptedTurnRecoveryTarget struct + ParentThreadID ThreadID + ThreadID ThreadID + func (target InterruptedTurnRecoveryTarget) Validate() error + type ListRootThreadsRequest struct + Cursor ThreadInventoryCursor + Limit int + type ListSubAgentActivityTimelineRequest struct + Meta observation.ActivityRunMeta + ParentThreadID ThreadID + type ListSubAgentPendingToolSettlementTargetsRequest struct + ChildThreadID ThreadID + ParentThreadID ThreadID + type ListThreadDetailEventsRequest struct + AfterOrdinal int64 + IncludeRaw bool + Limit int + ThreadID ThreadID + type ListThreadTurnsRequest struct + BeforeCursor *ThreadTurnCursor + Limit int + SinceCursor *ThreadTurnCursor + Tail int + ThreadID ThreadID + type LoopLimits struct + DuplicateToolLimit int + MaxEmptyProviderRetries int + NoProgressLimit int + WallTime time.Duration + type ManualCompactionPollRequest struct + PromptScopeID PromptScopeID + RunID RunID + Step int + ThreadID ThreadID + TraceID TraceID + TurnID TurnID + type ManualCompactionRequest struct + RequestID string + RequestedAt time.Time + Source string + type ManualCompactionSource interface + PollManualCompaction func(context.Context, ManualCompactionPollRequest) (ManualCompactionRequest, bool, error) + type MessageAttachment struct + MIMEType string + Name string + ResourceRef string + SizeBytes int64 + TextStats *MessageAttachmentTextStats + func (a MessageAttachment) Validate() error + type MessageAttachmentTextStats struct + LogicalLineCount int64 + UnicodeCodePointCount int64 + type MessageReference struct + Kind MessageReferenceKind + Label string + ReferenceID string + ResourceRef string + Text string + Truncated bool + func (r MessageReference) Validate() error + type MessageReferenceKind string + type MigrationRequiredError struct + Version string + func (failure *MigrationRequiredError) Error() string + func (failure *MigrationRequiredError) Is(target error) bool + type Options struct + Storage publicstorage.Source + type PendingToolCompletionRequest struct + CompletionRequestID string + ContinuationRunID RunID + ContinuationTurnID TurnID + Input TurnInput + Labels RunLabels + Output string + Status PendingToolCompletionStatus + Summary string + Target PendingToolSettlementTarget + type PendingToolCompletionResult struct + CompletionRequestID string + Replayed bool + RunID RunID + Status TurnStatus + ThreadID ThreadID + Turn *TurnResult + TurnID TurnID + func (r PendingToolCompletionResult) Validate() error + type PendingToolCompletionStatus string + const PendingToolCompletionCanceled + const PendingToolCompletionCompleted + const PendingToolCompletionFailed + type PendingToolRecovery struct + func (recovery *PendingToolRecovery) Settle(ctx context.Context, request PendingToolRecoveryRequest) (PendingToolSettlementResult, error) + type PendingToolRecoveryRequest struct + Activity *observation.ActivityPresentation + Output string + Status PendingToolSettlementStatus + Summary string + type PendingToolRecoveryTarget struct + ParentThreadID ThreadID + Target PendingToolSettlementTarget + func (target PendingToolRecoveryTarget) Validate() error + type PendingToolSettlementRequest struct + Activity *observation.ActivityPresentation + Output string + Status PendingToolSettlementStatus + Summary string + Target PendingToolSettlementTarget + type PendingToolSettlementResult struct + Event ThreadDetailEvent + Projection *ThreadTurnProjection + ProjectionAvailability TurnProjectionAvailability + ProjectionError string + Target PendingToolSettlementTarget + func (r PendingToolSettlementResult) Validate() error + type PendingToolSettlementStatus string + const PendingToolSettlementCanceled + const PendingToolSettlementCompleted + const PendingToolSettlementFailed + type PendingToolSettlementTarget struct + EffectAttemptID string + Handle string + RunID RunID + ThreadID ThreadID + ToolCallID string + ToolName string + TurnID TurnID + func (t PendingToolSettlementTarget) Validate() error + type ProjectThreadTurnRequest struct + Events []ThreadDetailEvent + RunID RunID + ThreadID ThreadID + TraceID TraceID + TurnID TurnID + type PromptScopeID string + type PublishSubAgentPendingToolCompletion struct + ChildThreadID ThreadID + Input TurnInput + InputRequestID string + Labels RunLabels + Output string + Status PendingToolCompletionStatus + Summary string + Target PendingToolSettlementTarget + type PublishSubAgentPendingToolCompletionRequest struct + ChildThreadID ThreadID + Input TurnInput + InputRequestID string + Labels RunLabels + Output string + ParentThreadID ThreadID + Status PendingToolCompletionStatus + Summary string + Target PendingToolSettlementTarget + type ReadApprovalQueueRequest struct + ThreadID ThreadID + type ReadArtifactRequest struct + ArtifactID ArtifactID + ThreadID ThreadID + type ReadSubAgentDetailRequest struct + AfterOrdinal int64 + ChildThreadID ThreadID + IncludeRaw bool + Limit int + ParentThreadID ThreadID + type ReadThreadTurnRequest struct + ThreadID ThreadID + TurnID TurnID + type ReadTurnProjectionRequest struct + RunID RunID + ThreadID ThreadID + TurnID TurnID + type RecoverInterruptedTurnResult struct + Failure *ThreadTurnFailure + Replayed bool + RunID RunID + Status TurnStatus + ThreadID ThreadID + TurnID TurnID + func (r RecoverInterruptedTurnResult) Validate() error + type RequestConflictError struct + Err error + Operation string + RequestID string + func (e *RequestConflictError) Error() string + func (e *RequestConflictError) Is(target error) bool + func (e *RequestConflictError) Unwrap() error + type ResolveApprovalRequest struct + Decision ApprovalDecision + DecisionID string + ExpectedApprovalRevision int64 + ExpectedCurrent ApprovalIdentity + ExpectedGeneration int64 + ExpectedRevision int64 + ExpectedRootThreadID ThreadID + func (r ResolveApprovalRequest) Validate() error + type ResolveApprovalResult struct + Approval ApprovalRecord + Queue ApprovalQueue + Receipt ApprovalDecisionReceipt + Replayed bool + func (r ResolveApprovalResult) Validate() error + type RetryTurnRequest struct + Labels RunLabels + Reason string + ThreadID ThreadID + type RootThreadsPage struct + GeneratedAt time.Time + HasMore bool + NextCursor ThreadInventoryCursor + Threads []ThreadSummary + func (p RootThreadsPage) Validate() error + type RunID string + type RunLabels struct + Correlation map[string]string + Host map[string]string + type RunMetrics struct + Compactions int + LLMRequests int + ProviderUsage publicprovider.Usage + Retries int + Steps int + ToolCalls int + WallTimeMS int64 + type RunTurnRequest struct + Completion TurnCompletionPolicy + Input TurnInput + Labels RunLabels + Limits TurnLimits + ManualCompactions ManualCompactionSource + Reasoning config.ReasoningSelection + RunID RunID + Signals TurnSignalSpec + SupplementalContext []TurnSupplementalContextItem + ThreadID ThreadID + ToolSurfaceProvider ToolSurfaceProvider + TurnID TurnID + func (r RunTurnRequest) Validate() error + type SendSubAgentInput struct + Attachments []MessageAttachment + ChildThreadID ThreadID + InputRequestID string + Interrupt bool + Labels RunLabels + Message string + References []MessageReference + type SendSubAgentInputRequest struct + Attachments []MessageAttachment + ChildThreadID ThreadID + InputRequestID string + Interrupt bool + Labels RunLabels + Message string + ParentThreadID ThreadID + References []MessageReference + type SetThreadTitleRequest struct + ThreadID ThreadID + Title string + type SignalDisposition string + const SignalContinue + const SignalTerminal + const SignalWaiting + type SpawnSubAgent struct + Attachments []MessageAttachment + ForkMode SubAgentForkMode + HostProfileRef string + Labels RunLabels + Message string + ParentTurnID TurnID + PublicationID string + References []MessageReference + TaskDescription string + TaskName string + ThreadID ThreadID + type SpawnSubAgentRequest struct + Attachments []MessageAttachment + ForkMode SubAgentForkMode + HostProfileRef string + Labels RunLabels + Message string + ParentThreadID ThreadID + ParentTurnID TurnID + PublicationID string + References []MessageReference + TaskDescription string + TaskName string + ThreadID ThreadID + type StreamObservation struct + Attempt int + FinishInferred bool + FinishReason observation.FinishReason + Labels RunLabels + RawFinishReason string + Reason string + Text string + ToolCallStream *modelToolCallStream + Type StreamObservationType + func (s StreamObservation) Validate() error + type StreamObservationType string + const StreamObservationAssistantDelta + const StreamObservationModelRetry + const StreamObservationModelStreamAbort + const StreamObservationModelStreamDone + const StreamObservationReasoningDelta + const StreamObservationToolCallDelta + const StreamObservationToolCallEnd + const StreamObservationToolCallStart + func (t StreamObservationType) Valid() bool + type SubAgentActivityTimelineResult struct + GeneratedAt time.Time + Timeline observation.ActivityTimeline + func (r SubAgentActivityTimelineResult) Validate() error + type SubAgentDetail struct + ActivityTimeline observation.ActivityTimeline + Context ThreadContextSnapshot + Events []ThreadDetailEvent + GeneratedAt time.Time + HasMore bool + NextOrdinal int64 + RetainedFrom int64 + Snapshot SubAgentSnapshot + func (d SubAgentDetail) Validate() error + type SubAgentDetailRequest struct + AfterOrdinal int64 + ChildThreadID ThreadID + IncludeRaw bool + Limit int + type SubAgentForkMode string + const SubAgentForkFullPath + const SubAgentForkNone + type SubAgentManager struct + func (manager *SubAgentManager) Close(ctx context.Context, request CloseSubAgent) (SubAgentSnapshot, error) + func (manager *SubAgentManager) PublishPendingToolCompletion(ctx context.Context, request PublishSubAgentPendingToolCompletion) (SubAgentSnapshot, error) + func (manager *SubAgentManager) SendInput(ctx context.Context, request SendSubAgentInput) (SubAgentSnapshot, error) + func (manager *SubAgentManager) Spawn(ctx context.Context, request SpawnSubAgent) (SubAgentSnapshot, error) + func (manager *SubAgentManager) Wait(ctx context.Context, request WaitSubAgents) (WaitSubAgentsResult, error) + type SubAgentReader struct + func (reader *SubAgentReader) ActivityTimeline(ctx context.Context, meta observation.ActivityRunMeta) (SubAgentActivityTimelineResult, error) + func (reader *SubAgentReader) List(ctx context.Context) ([]SubAgentSnapshot, error) + func (reader *SubAgentReader) ReadDetail(ctx context.Context, request SubAgentDetailRequest) (SubAgentDetail, error) + type SubAgentSnapshot struct + CanClose bool + CanInterrupt bool + CanSendInput bool + Closed bool + CreatedAt time.Time + ForkMode SubAgentForkMode + HostProfileRef string + LastMessage string + LatestTurnID TurnID + ParentThreadID ThreadID + ParentTurnID TurnID + Path string + QueuedInputs int + Status SubAgentStatus + TaskDescription string + TaskName string + ThreadID ThreadID + UpdatedAt time.Time + WaitingPrompt string + func (s SubAgentSnapshot) Validate() error + type SubAgentStatus string + const SubAgentStatusCancelled + const SubAgentStatusClosed + const SubAgentStatusClosing + const SubAgentStatusCompleted + const SubAgentStatusFailed + const SubAgentStatusIdle + const SubAgentStatusInterrupted + const SubAgentStatusRunning + const SubAgentStatusWaiting + type ThreadAgentTodoState struct + Items []AgentTodo + ThreadID ThreadID + UpdatedAt time.Time + UpdatedByRunID RunID + UpdatedByToolCall string + UpdatedByTurnID TurnID + Version int64 + func (s ThreadAgentTodoState) Validate() error + type ThreadCompactionRequest struct + Labels RunLabels + Limits TurnLimits + Reasoning config.ReasoningSelection + RequestID string + Source string + type ThreadCompactor struct + func (compactor *ThreadCompactor) Compact(ctx context.Context, request ThreadCompactionRequest) (CompactThreadResult, error) + type ThreadContextSnapshot struct + Compactions []observation.CompactionEvent + Model string + Policy config.ContextPolicy + Provider string + ThreadID ThreadID + UpdatedAt time.Time + Usage *observation.ContextStatus + func (s ThreadContextSnapshot) Validate() error + type ThreadControlSignal struct + ArgsHash string + CallID string + Disposition string + Name string + Payload map[string]any + Text string + type ThreadCreator struct + func (creator *ThreadCreator) Create(ctx context.Context) (ThreadSummary, error) + type ThreadDeleter struct + func (deleter *ThreadDeleter) Delete(ctx context.Context) error + type ThreadDetailApproval struct + ArgsHash string + Metadata map[string]string + Reason string + State string + ToolID string + ToolKind string + ToolName string + type ThreadDetailCompaction struct + Metadata map[string]string + OperationID string + Phase string + Reason string + RequestID string + Source string + TokensAfterEstimate int64 + TokensBefore int64 + Trigger string + type ThreadDetailControlSignal struct + ArgsHash string + CallID string + Disposition string + Name string + Payload map[string]any + Text string + type ThreadDetailEvent struct + ActivityTimeline *observation.ActivityTimeline + Approval *ThreadDetailApproval + Compaction *ThreadDetailCompaction + CreatedAt time.Time + Error string + ID string + Kind ThreadDetailEventKind + Message *ThreadDetailMessage + Metadata map[string]string + Ordinal int64 + ParentID string + RunID RunID + Step int + ThreadID ThreadID + ToolCall *ThreadDetailToolCall + ToolResult *ThreadDetailToolResult + TurnID TurnID + TurnMarker *ThreadDetailTurnMarker + Type string + type ThreadDetailEventKind string + const ThreadDetailEventApproval + const ThreadDetailEventAssistantMessage + const ThreadDetailEventCompaction + const ThreadDetailEventCustom + const ThreadDetailEventError + const ThreadDetailEventInput + const ThreadDetailEventToolActivity + const ThreadDetailEventToolCall + const ThreadDetailEventToolDispatch + const ThreadDetailEventToolResult + const ThreadDetailEventTurnMarker + const ThreadDetailEventUserMessage + type ThreadDetailEvents struct + Events []ThreadDetailEvent + GeneratedAt time.Time + HasMore bool + NextOrdinal int64 + RetainedFrom int64 + func (p ThreadDetailEvents) Validate() error + type ThreadDetailMessage struct + Activity *observation.ActivityPresentation + Attachments []MessageAttachment + Content string + Kind string + Preview string + Reasoning string + References []MessageReference + Role string + type ThreadDetailToolCall struct + ArgsHash string + ArgsJSON string + ArgsPreview string + ControlSignal *ThreadDetailControlSignal + ID string + Name string + type ThreadDetailToolResult struct + CallID string + Content string + ContentSHA256 string + EffectAttemptID string + FullOutput *ArtifactRef + OriginalBytes int + OriginalLines int + Preview string + Status string + Strategy string + ToolName string + Truncated bool + VisibleBytes int + VisibleLines int + type ThreadDetailTurnMarker struct + Metadata map[string]string + Status string + type ThreadForkRequest struct + DestinationThreadID ThreadID + OperationID ForkOperationID + type ThreadForker struct + func (forker *ThreadForker) Fork(ctx context.Context, request ThreadForkRequest) (ForkThreadResult, error) + type ThreadID string + type ThreadInventory struct + func (inventory *ThreadInventory) List(ctx context.Context, request ListRootThreadsRequest) (RootThreadsPage, error) + type ThreadInventoryCursor string + type ThreadOverview struct + LatestTurn *ThreadTurnSnapshot + Thread ThreadSnapshot + func (o ThreadOverview) Validate() error + type ThreadPhase string + const ThreadPhaseIdle + const ThreadPhaseTurn + func (p ThreadPhase) Valid() bool + type ThreadReader struct + func (reader *ThreadReader) Read(ctx context.Context) (ThreadSnapshot, error) + func (reader *ThreadReader) ReadTurn(ctx context.Context, turnID TurnID) (ThreadTurnSnapshot, error) + type ThreadSnapshot struct + CanAppendMessage bool + CanRetry bool + CreatedAt time.Time + ID ThreadID + LatestRunID RunID + LatestTurnID TurnID + Phase ThreadPhase + Recoverable bool + Status ThreadStatus + ThroughOrdinal int64 + Title string + TitleError string + TitleGeneration int64 + TitleSource ThreadTitleSource + TitleStatus ThreadTitleStatus + TitleUpdatedAt time.Time + UpdatedAt time.Time + WaitingPrompt string + func (s ThreadSnapshot) Validate() error + type ThreadStatus string + const ThreadStatusCancelled + const ThreadStatusCompleted + const ThreadStatusFailed + const ThreadStatusIdle + const ThreadStatusInterrupted + const ThreadStatusRunning + const ThreadStatusWaiting + func (s ThreadStatus) Valid() bool + type ThreadSummary struct + CanAppendMessage bool + CanRetry bool + CreatedAt time.Time + ID ThreadID + LatestTurnID TurnID + Phase ThreadPhase + Recoverable bool + Status ThreadStatus + Title string + TitleError string + TitleGeneration int64 + TitleSource ThreadTitleSource + TitleStatus ThreadTitleStatus + TitleUpdatedAt time.Time + UpdatedAt time.Time + WaitingPrompt string + func (s ThreadSummary) Validate() error + type ThreadTitleEditor struct + func (editor *ThreadTitleEditor) Set(ctx context.Context, title string) (ThreadSnapshot, error) + type ThreadTitleMode string + const ThreadTitleModeHostOwned + const ThreadTitleModeProvider + type ThreadTitleSource string + const ThreadTitleSourceHost + const ThreadTitleSourceProvider + const ThreadTitleSourceUnset + func ParseThreadTitleSource(raw string) (ThreadTitleSource, error) + func (s ThreadTitleSource) Valid() bool + type ThreadTitleStatus string + const ThreadTitleStatusFailed + const ThreadTitleStatusPending + const ThreadTitleStatusReady + const ThreadTitleStatusUnset + func ParseThreadTitleStatus(raw string) (ThreadTitleStatus, error) + func (s ThreadTitleStatus) Valid() bool + type ThreadTurnCursor string + type ThreadTurnFailure struct + Code ThreadTurnFailureCode + Message string + func (f ThreadTurnFailure) Validate() error + type ThreadTurnFailureCode string + const ThreadTurnFailureAuthorizationContract + const ThreadTurnFailureAuthorizationUnavailable + const ThreadTurnFailureCancelled + const ThreadTurnFailureEffectOutcomeUnknown + const ThreadTurnFailureEngineContract + const ThreadTurnFailureInterrupted + const ThreadTurnFailureLegacyUnclassified + const ThreadTurnFailureProvider + const ThreadTurnFailureStorage + const ThreadTurnFailureToolDispatch + func (c ThreadTurnFailureCode) Valid() bool + type ThreadTurnProjection struct + ProjectedAt time.Time + RunID RunID + Segments []ThreadTurnProjectionSegment + Status TurnStatus + ThreadID ThreadID + ThroughOrdinal int64 + TraceID TraceID + TurnID TurnID + func ProjectThreadTurn(req ProjectThreadTurnRequest) ThreadTurnProjection + func (p ThreadTurnProjection) Validate() error + type ThreadTurnProjectionSegment struct + ActivityTimeline *observation.ActivityTimeline + EventIDs []string + Kind ThreadTurnProjectionSegmentKind + Signal *ThreadTurnProjectionSignal + Text string + type ThreadTurnProjectionSegmentKind string + const ThreadTurnProjectionSegmentActivityTimeline + const ThreadTurnProjectionSegmentAssistantText + const ThreadTurnProjectionSegmentControlSignal + type ThreadTurnProjectionSignal struct + ArgsHash string + CallID string + Disposition string + Name string + Payload map[string]any + Text string + type ThreadTurnRetrySource struct + TurnID TurnID + type ThreadTurnSnapshot struct + CanRetry bool + ControlSignals []ThreadControlSignal + Failure *ThreadTurnFailure + Ordinal int64 + Projection ThreadTurnProjection + Recoverable bool + RetrySource *ThreadTurnRetrySource + RunID RunID + StartedAt time.Time + Status TurnStatus + ThroughOrdinal int64 + TurnID TurnID + UpdatedAt time.Time + UserAttachments []MessageAttachment + UserEntryID string + UserInput string + UserMessageOrigin ThreadUserMessageOrigin + UserReferences []MessageReference + func (s ThreadTurnSnapshot) Validate() error + type ThreadTurnsPage struct + BeforeCursor *ThreadTurnCursor + GeneratedAt time.Time + HasMore bool + SinceCursor ThreadTurnCursor + ThreadID ThreadID + ThroughOrdinal int64 + Turns []ThreadTurnSnapshot + func (p ThreadTurnsPage) Validate() error + type ThreadUserMessageOrigin string + const ThreadUserMessageOriginDelegatedMission + const ThreadUserMessageOriginPendingToolCompletion + const ThreadUserMessageOriginSubAgentInput + const ThreadUserMessageOriginUser + type ToolSurface struct + Epoch string + HostContext map[string]string + HostedToolDefinitions []publicprovider.HostedToolDefinition + Reason string + SystemPrompt string + ToolDefinitions []tools.ToolDefinition + Tools *tools.Registry + type ToolSurfaceProvider func(context.Context, ToolSurfaceRequest) (ToolSurface, error) + type ToolSurfaceRequest struct + HostContext map[string]string + Labels RunLabels + Phase string + PromptScopeID PromptScopeID + RunID RunID + Step int + ThreadID ThreadID + TraceID TraceID + TurnID TurnID + type TraceID string + type TurnCompletionPolicy string + const TurnCompletionExplicitSignal + const TurnCompletionNaturalStop + type TurnID string + type TurnInput struct + Attachments []MessageAttachment + References []MessageReference + Text string + func (i TurnInput) Validate() error + type TurnLimits struct + MaxCostUSD float64 + MaxInputTokens int64 + MaxLengthContinuations int + MaxStopHookContinuations int + MaxToolCalls int + MaxTotalTokens int64 + type TurnProjectionAvailability string + const TurnProjectionAvailabilityReady + const TurnProjectionAvailabilityUnavailable + func (a TurnProjectionAvailability) Valid() bool + type TurnRequest struct + Completion TurnCompletionPolicy + Input TurnInput + Labels RunLabels + Limits TurnLimits + ManualCompactions ManualCompactionSource + Reasoning config.ReasoningSelection + RunID RunID + Signals TurnSignalSpec + SupplementalContext []TurnSupplementalContextItem + ToolSurfaceProvider ToolSurfaceProvider + TurnID TurnID + type TurnResult struct + ActivityTimeline observation.ActivityTimeline + CompletionReason observation.CompletionReason + ContinuationReason observation.ContinuationReason + Diagnostics map[string]string + Failure *ThreadTurnFailure + FinishInferred bool + FinishReason observation.FinishReason + Metrics RunMetrics + Output string + Projection *ThreadTurnProjection + ProjectionAvailability TurnProjectionAvailability + ProjectionError string + RawFinishReason string + Replayed bool + RunID RunID + Signal *TurnSignal + Status TurnStatus + ThreadID ThreadID + TurnID TurnID + func (r TurnResult) Validate() error + type TurnRunner struct + func (runner *TurnRunner) Run(ctx context.Context, request TurnRequest) (TurnResult, error) + type TurnSignal struct + Activity *observation.ActivityPresentation + ArgsHash string + CallID string + Disposition SignalDisposition + Labels map[string]string + Name string + OutputText string + Payload map[string]any + func ProjectCoreControlSignal(call tools.ToolCall) (TurnSignal, bool, error) + type TurnSignalSpec struct + Definitions []tools.ToolDefinition + Project func(tools.ToolCall) (TurnSignal, bool, error) + type TurnStatus string + const TurnStatusCancelled + const TurnStatusCompleted + const TurnStatusFailed + const TurnStatusInterrupted + const TurnStatusRunning + const TurnStatusWaiting + func (s TurnStatus) IsTerminal() bool + func (s TurnStatus) Valid() bool + type TurnSupplementalContextItem struct + Kind string + Metadata map[string]string + Sensitive bool + Text string + Title string + Truncated bool + type UpdateThreadAgentTodosRequest struct + ExpectedVersion int64 + Items []AgentTodo + RunID RunID + ThreadID ThreadID + ToolCallID string + TurnID TurnID + type WaitSubAgents struct + ChildThreadIDs []ThreadID + Timeout time.Duration + type WaitSubAgentsRequest struct + ChildThreadIDs []ThreadID + ParentThreadID ThreadID + Timeout time.Duration + type WaitSubAgentsResult struct + Snapshots []SubAgentSnapshot + TimedOut bool + func (r WaitSubAgentsResult) Validate() error Other modules containing this package github.com/floegence/floret github.com/floegence/floret/v3 github.com/floegence/floret/v4 github.com/floegence/floret/v5 github.com/floegence/floret/v6 github.com/floegence/floret/v7
Go to main page