Versions in this module Expand all Collapse all v0 v0.8.13 Aug 7, 2026 v0.8.12 Aug 7, 2026 Changes in this version + type AgentdExecutor interface + Execute func(ctx context.Context, podIP string, req *NodeExecRequest) (*NodeExecResponse, error) + type HTTPAgentdExecutor struct + Client *http.Client + Port int + func (e *HTTPAgentdExecutor) Execute(ctx context.Context, podIP string, req *NodeExecRequest) (*NodeExecResponse, error) + type NodeExecRequest struct + Input json.RawMessage + NodeID string + NodeType string + Spec json.RawMessage + Timeout string + type NodeExecResponse struct + Branch string + Detail string + ErrorCode string + Output json.RawMessage + type ReconcilerLogger interface + Error func(err error, msg string, keysAndValues ...any) + Info func(msg string, keysAndValues ...any) + type ReconcilerStore interface + ClaimQueuedRuns func(ctx context.Context, limit int) ([]*wf.WorkflowRunRow, error) + CreateNodeRun func(ctx context.Context, row *wf.WorkflowNodeRunRow) error + IncrementTriggerFailures func(ctx context.Context, triggerID string) (int, error) + ResetTriggerFailures func(ctx context.Context, triggerID string) error + UpdateNodeRunStatus func(ctx context.Context, nodeRunID, status string, output json.RawMessage, ...) error + UpdateWorkflowRunStatus func(ctx context.Context, runID, status string, errorCode *string, ...) error + type Scheduler struct + BatchLimit int + Logger ReconcilerLogger + Store SchedulerStore + TickInterval time.Duration + func (s *Scheduler) NeedLeaderElection() bool + func (s *Scheduler) Start(ctx context.Context) error + type SchedulerStore interface + CreateTriggerFire func(ctx context.Context, row *wf.TriggerFireRow) error + CreateWorkflowRunWithFire func(ctx context.Context, fire *wf.TriggerFireRow, run *wf.WorkflowRunRow) error + DisableTrigger func(ctx context.Context, triggerID string) error + GetWorkflow func(ctx context.Context, ownerType, ownerID, workflowID string) (*wf.WorkflowRow, error) + IncrementTriggerFailures func(ctx context.Context, triggerID string) (int, error) + ListDueCronTriggers func(ctx context.Context, now time.Time, limit int) ([]*wf.TriggerRow, error) + UpdateTriggerFireTimestamps func(ctx context.Context, triggerID string, lastFiredAt time.Time, ...) error + type WorkflowReconciler struct + AgentdClient AgentdExecutor + K8sClient WorkspaceActivator + Logger ReconcilerLogger + MaxConcurrent int + Store ReconcilerStore + TickInterval time.Duration + func (r *WorkflowReconciler) Cancel(runID string) + func (r *WorkflowReconciler) NeedLeaderElection() bool + func (r *WorkflowReconciler) Start(ctx context.Context) error + type WorkspaceActivator interface + EnsureActive func(ctx context.Context, workspaceID string, timeout time.Duration) (podIP string, err error)
Go to main page