hydaelyn

package module

Go to main page

Versions in this module

v0

v0.11.9

Jul 18, 2026

v0.11.8

Jul 18, 2026

v0.11.7

Jul 18, 2026

v0.11.6

Jul 18, 2026

v0.11.5

Jul 18, 2026

v0.11.4

Jul 18, 2026

v0.11.3

Jul 18, 2026

v0.11.2

Jul 18, 2026

v0.11.1

Jul 18, 2026

v0.11.0

Jul 18, 2026

v0.10.1

Jul 16, 2026

v0.10.0

Jul 16, 2026

retracted

Changes in this version

type Runner

+ func NewDevelopment(configs ...api.Config) *Runner

+ func NewProduction(cfg api.Config) (*Runner, error)

+ func (r *Runner) ActiveLeaseCountContext(ctx context.Context, runID, taskID string) int

+ func (r *Runner) Close(ctx context.Context) error

+ func (r *Runner) Mode() api.RuntimeMode

+ func (r *Runner) ReadyTasksContext(ctx context.Context, runID string) []api.Task

+ func (r *Runner) ReplayContext(ctx context.Context, runID string, mode api.ReplayMode) (api.Projection, error)

+ func (r *Runner) ReplayRunStateContext(ctx context.Context, runID string) (api.Projection, error)

+ func (r *Runner) ResponseOutboxContext(ctx context.Context, runID string) []api.UserMessage

+ func (r *Runner) StoreCapabilities(ctx context.Context) (api.StoreCapabilities, error)

v0.9.0

Jun 29, 2026

Changes in this version

+ var ErrIdempotencyConflict = api.ErrIdempotencyConflict

type Runner

+ func (r *Runner) AppendUsage(ctx context.Context, record api.UsageRecord) error

+ func (r *Runner) PendingResumeTokens(ctx context.Context, selector api.ResumeTokenSelector) ([]api.ResumeToken, error)

+ func (r *Runner) QueryUsage(ctx context.Context, selector api.UsageSelector) ([]api.UsageRecord, error)

+ func (r *Runner) SumUsageCredits(ctx context.Context, selector api.UsageSelector) (int64, error)

v0.8.1

May 25, 2026

v0.8.0

May 24, 2026

v0.7.0

May 5, 2026

Changes in this version

+ var ErrActionReconcileRequired = api.ErrActionReconcileRequired

+ var ErrActionTaskRequired = api.ErrActionTaskRequired

+ var ErrCompletionCriteriaUnmet = api.ErrCompletionCriteriaUnmet

+ var ErrDependencyFailed = api.ErrDependencyFailed

+ var ErrDependencyUnmet = api.ErrDependencyUnmet

+ var ErrFlowBypass = api.ErrFlowBypass

+ var ErrHandoffCycle = api.ErrHandoffCycle

+ var ErrHandoffDepthExceeded = api.ErrHandoffDepthExceeded

+ var ErrInvalidAddress = api.ErrInvalidAddress

+ var ErrInvalidCommand = api.ErrInvalidCommand

+ var ErrInvalidConfiguration = api.ErrInvalidConfiguration

+ var ErrInvalidTransition = api.ErrInvalidTransition

+ var ErrLeaseHolderMismatch = api.ErrLeaseHolderMismatch

+ var ErrLeaseNotActive = api.ErrLeaseNotActive

+ var ErrNoRecipients = api.ErrNoRecipients

+ var ErrNotFound = api.ErrNotFound

+ var ErrOwnerMismatch = api.ErrOwnerMismatch

+ var ErrPolicyDenied = api.ErrPolicyDenied

+ var ErrPolicyObligationFailed = api.ErrPolicyObligationFailed

+ var ErrResponseTaskRequired = api.ErrResponseTaskRequired

+ var ErrStaleTaskVersion = api.ErrStaleTaskVersion

+ var ErrSubscriptionClosed = api.ErrSubscriptionClosed

+ var ErrTerminalState = api.ErrTerminalState

+ var ErrWaitTimeout = api.ErrWaitTimeout

+ func DefaultConfig() api.Config

+ type Runner struct

+ func (r *Runner) AckEnvelope(ctx context.Context, cmd api.AckEnvelopeCommand) error

+ func (r *Runner) AcquireTaskExecution(ctx context.Context, cmd api.AcquireTaskExecutionCommand) (api.TaskExecutionLease, bool, error)

+ func (r *Runner) ActiveLeaseCount(runID, taskID string) int

+ func (r *Runner) AdvanceRun(ctx context.Context, cmd api.AdvanceRunCommand) (api.Run, error)

+ func (r *Runner) Agents() []api.AgentProfile

+ func (r *Runner) AppendEvent(ctx context.Context, event api.Event) error

+ func (r *Runner) Begin(ctx context.Context) (api.UnitOfWork, error)

+ func (r *Runner) CompleteActionAttempt(ctx context.Context, cmd api.CompleteActionAttemptCommand) (api.ActionAttempt, error)

+ func (r *Runner) CreateTask(ctx context.Context, cmd api.CreateTaskCommand) (api.Task, error)

+ func (r *Runner) DeadLetter(ctx context.Context, cmd api.DeadLetterCommand) error

+ func (r *Runner) DecideApproval(ctx context.Context, cmd api.DecideApprovalCommand) error

+ func (r *Runner) DispatchTask(ctx context.Context, cmd api.DispatchTaskCommand) (api.TaskEnvelope, error)

+ func (r *Runner) DispatchTaskFanOut(ctx context.Context, cmd api.FanOutDispatchTaskCommand) ([]api.TaskEnvelope, error)

+ func (r *Runner) DrainResponseOutbox(ctx context.Context) (int, error)

+ func (r *Runner) EndTraceSpan(ctx context.Context, cmd api.EndTraceSpanCommand) error

+ func (r *Runner) Events(runID string) []api.Event

+ func (r *Runner) ExecuteCommand(ctx context.Context, command api.Command) (any, error)

+ func (r *Runner) HeartbeatTaskExecution(ctx context.Context, cmd api.HeartbeatTaskExecutionCommand) error

+ func (r *Runner) InvokeTool(ctx context.Context, cmd api.ToolInvocation) (api.ToolInvocationResult, error)

+ func (r *Runner) ListEnvelopes(ctx context.Context, runID string) ([]api.TaskEnvelope, error)

+ func (r *Runner) ListEvents(ctx context.Context, runID string) ([]api.Event, error)

+ func (r *Runner) ListMessages(ctx context.Context, runID string) ([]api.UserMessage, error)

+ func (r *Runner) ListQueuedMessages(ctx context.Context) ([]api.UserMessage, error)

+ func (r *Runner) ListTasks(ctx context.Context, runID string) ([]api.Task, error)

+ func (r *Runner) ListTraceSpans(ctx context.Context, runID string) ([]api.TraceSpan, error)

+ func (r *Runner) LoadEnvelope(ctx context.Context, envelopeID string) (api.TaskEnvelope, error)

+ func (r *Runner) LoadMessage(ctx context.Context, runID, messageID string) (api.UserMessage, error)

+ func (r *Runner) LoadRun(ctx context.Context, runID string) (api.Run, error)

+ func (r *Runner) LoadTask(ctx context.Context, runID, taskID string) (api.Task, error)

+ func (r *Runner) PublishResponse(ctx context.Context, cmd api.PublishResponseCommand) error

+ func (r *Runner) QueueEnvelope(ctx context.Context, env api.TaskEnvelope) error

+ func (r *Runner) QueueMessage(ctx context.Context, message api.UserMessage) error

+ func (r *Runner) QueueRun(ctx context.Context, cmd api.StartRunCommand) (api.Run, error)

+ func (r *Runner) ReadyTasks(runID string) []api.Task

+ func (r *Runner) Recover(ctx context.Context, runID string) (api.Projection, error)

+ func (r *Runner) RecoverResumeToken(ctx context.Context, cmd api.RecoverResumeTokenCommand) (api.ResumeToken, error)

+ func (r *Runner) RegisterAgent(profile api.AgentProfile)

+ func (r *Runner) RegisterFlow(flow api.Flow) error

+ func (r *Runner) RegisterTool(tool api.Tool)

+ func (r *Runner) ReleaseTaskExecution(ctx context.Context, cmd api.ReleaseTaskExecutionCommand) error

+ func (r *Runner) Replay(runID string, mode api.ReplayMode) (api.Projection, error)

+ func (r *Runner) ReplayRunState(runID string) (api.Projection, error)

+ func (r *Runner) RequestApproval(ctx context.Context, cmd api.RequestApprovalCommand) (api.ApprovalRequest, api.ResumeToken, error)

+ func (r *Runner) RequestHandoff(ctx context.Context, cmd api.HandoffCommand) error

+ func (r *Runner) ResponseOutbox(runID string) []api.UserMessage

+ func (r *Runner) ResumeTokens() map[string]api.ResumeToken

+ func (r *Runner) Run(ctx context.Context, runID string) (api.Run, error)

+ func (r *Runner) RunEvents(ctx context.Context, runID string) ([]api.Event, error)

+ func (r *Runner) RunTimeline(ctx context.Context, runID string) ([]api.RunTimelineItem, error)

+ func (r *Runner) SaveRun(ctx context.Context, run api.Run) error

+ func (r *Runner) SaveTask(ctx context.Context, task api.Task) error

+ func (r *Runner) SaveTraceSpan(ctx context.Context, span api.TraceSpan) error

+ func (r *Runner) SelectItems(ctx context.Context, runID string, selector api.BlackboardSelector) ([]api.BlackboardItem, error)

+ func (r *Runner) SetMessagePolicy(policy api.MessagePolicyChecker)

+ func (r *Runner) SetOutputGateway(gateway api.OutputGateway)

+ func (r *Runner) SetPipeline(components api.PipelineComponents)

+ func (r *Runner) SetPolicyEngine(policy api.PolicyEngine)

+ func (r *Runner) StartActionAttempt(ctx context.Context, cmd api.StartActionAttemptCommand) (api.ActionAttempt, error)

+ func (r *Runner) StartRun(ctx context.Context, cmd api.StartRunCommand) (api.Run, api.Task, error)

+ func (r *Runner) StartTraceSpan(ctx context.Context, cmd api.StartTraceSpanCommand) (api.TraceSpan, error)

+ func (r *Runner) StoreProvider() api.StoreProvider

+ func (r *Runner) SubmitResponseOutput(ctx context.Context, cmd api.SubmitResponseOutputCommand) error

+ func (r *Runner) SubmitTypedReport(ctx context.Context, cmd api.SubmitTypedReportCommand) error

+ func (r *Runner) SubmitUserInput(ctx context.Context, cmd api.SubmitUserInputCommand) error

+ func (r *Runner) Subscribe(ctx context.Context, runID string, filter api.BlackboardFilter) (<-chan api.BlackboardItem, func() error, error)

+ func (r *Runner) Task(ctx context.Context, runID, taskID string) (api.Task, error)

+ func (r *Runner) TraceSpans(runID string) []api.TraceSpan

+ func (r *Runner) TransitionRun(ctx context.Context, cmd api.TransitionRunCommand) error

+ func (r *Runner) TransitionTask(ctx context.Context, cmd api.TransitionTaskCommand) error

+ func (r *Runner) UpdateEnvelope(ctx context.Context, env api.TaskEnvelope) error

+ func (r *Runner) UpdateMessage(ctx context.Context, message api.UserMessage) error

+ func (r *Runner) WaitForBlackboard(ctx context.Context, runID string, filter api.BlackboardFilter, ...) ([]api.BlackboardItem, error)

+ func (r *Runner) WriteItem(ctx context.Context, item api.BlackboardItem) error

v0.6.0

Apr 24, 2026

v0.5.3

Apr 24, 2026

v0.5.2

Apr 23, 2026

v0.5.1

Apr 22, 2026

v0.5.0

Apr 22, 2026

v0.4.3

Apr 21, 2026

v0.4.2

Apr 21, 2026

v0.4.1

Apr 21, 2026

Changes in this version

+ type Config = host.Config

+ type Profile = team.Profile

+ type Role = team.Role

+ type Runtime = host.Runtime

+ func New(cfg Config) *Runtime

+ type StartTeamRequest = host.StartTeamRequest

v0.4.0

Apr 20, 2026

v0.3.0

Apr 20, 2026

v0.2.3

Apr 17, 2026

v0.2.2

Apr 17, 2026

v0.2.1

Apr 16, 2026

v0.2.0

Apr 16, 2026

v0.1.0

Apr 15, 2026

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