Versions in this module Expand all Collapse all v1 v1.9.3 Oct 26, 2026 Changes in this version + const ContributorName + const DurableWardenName + const WardenName + func DurableAction(intent string) string + func Register(d *dispatcher.Dispatcher, reg fc.Registry, wreg fc.WardenRegistry, deps Deps) error + type ArtifactCacheConfig struct + BudgetBytes int64 + Directory string + UsedBytes int64 + type ArtifactConfig struct + Backend *string + Cache *ArtifactCacheConfig + DefaultBucket *string + Enabled bool + type ArtifactDetail struct + Artifact *ArtifactRow + AsOf string + Enabled bool + type ArtifactDownload struct + AsOf string + Enabled bool + ExpiresAt *string + Supported bool + URL *string + type ArtifactJobLinks struct + AsOf string + JobID string + type ArtifactLinkRow struct + ArtifactID string + Attempt int + CreatedAt *string + Name string + Role string + type ArtifactRow struct + Backend string + Bucket string + ContentHash *string + ContentType *string + CreatedAt *string + DeletedAt *string + DownloadAvailable bool + ExpiresAt *string + ID string + Key string + Lifecycle artifact.Lifecycle + ScopeAppID *string + ScopeOrgID *string + Size int64 + type ArtifactsListInput struct + Cursor string + IncludeDeleted bool + Lifecycle artifact.Lifecycle + Limit int + ScopeAppID string + ScopeOrgID string + type ArtifactsPage struct + Enabled bool + type BeforeInput struct + Before string + type CountResult struct + AsOf string + Count int64 + type CronDetail struct + AsOf string + Payload Payload + type CronRow struct + CreatedAt *string + EffectiveQueue string + Enabled bool + ID string + JobName string + LastRunAt *string + Location *string + LockedBy *string + LockedUntil *string + Name string + NextFires []string + NextRunAt *string + Queue *string + Schedule string + ScheduleError *string + ScopeAppID *string + ScopeOrgID *string + UpdatedAt *string + type CronRunResult struct + AsOf string + CronID string + Job JobRow + type CronSummary struct + Disabled int + Enabled int + type DLQBulkResult struct + AsOf string + Conflicts int + Errors int + Failure *fc.Error + Interrupted bool + Limit int + Replayed int + type DLQCountsInput struct + Queue string + Replayed *bool + type DLQDetail struct + ArtifactBindings Payload + AsOf string + InputBytes int64 + LeaseTTL Duration + Payload Payload + PrimaryInputHash *string + Priority int + ResourceClass *string + ResourceLimits resource.Set + Resources resource.Set + Timeout Duration + type DLQListInput struct + Cursor string + Limit int + NamePrefix string + Queue string + Replayed *bool + ScopeAppID string + ScopeOrgID string + type DLQPurgeResult struct + AsOf string + Before string + Count int64 + Failure *fc.Error + Interrupted bool + type DLQReplayAllInput struct + Limit int + Queue string + type DLQReplayResult struct + AsOf string + EntryID string + Job JobRow + type DLQRow struct + CreatedAt *string + Error *string + FailedAt *string + ID string + JobID string + JobName string + MaxRetries int + Queue string + ReplayedAt *string + ReplayedJobID *string + RetryCount int + ScopeAppID *string + ScopeOrgID *string + type DeletedResult struct + AsOf string + ID string + type Deps struct + Durable *operator.Service + Engine *engine.Engine + Logger forge.Logger + Security security.Boundary + Store store.Store + type Duration struct + MS int64 + Text string + type EmptyInput struct + type EngineConfig struct + Artifacts ArtifactConfig + AsOf string + Executors []ExecutorRow + Pool PoolConfig + Queues []QueueConfigRow + Resources ResourceConfig + Scheduler SchedulerConfig + ScratchRoot string + WakeNotifierSupported bool + WorkerID string + type ExecutionPolicy struct + AllowDowngrade bool + GracePeriod Duration + Image *string + Level string + type ExecutorRow struct + Default bool + Level string + Name string + Subprocess *SubprocessConfig + type HandlerArtifactInput struct + MaxSize int64 + Mode string + Name string + Required bool + type HandlerDetail struct + AsOf string + Job *JobHandlerDetail + type HandlerInput struct + Kind string + Name string + type HandlerRow struct + InputCount int + Kind string + Name string + Versions []int + type IDInput struct + ID string + type JobAction struct + AsOf string + Job JobRow + type JobArtifactLinks struct + Enabled bool + Links []ArtifactLinkRow + type JobCounts struct + AsOf string + Counts map[job.State]int64 + Total int64 + type JobDetail struct + ArtifactBindings Payload + Artifacts JobArtifactLinks + AsOf string + DLQEntryID *string + EffectiveLeaseTTL Duration + EvictCount int + HeartbeatAt *string + InputBytes int64 + LastError *string + LeaseEpoch int + LeaseExpiresAt *string + LeaseTTL Duration + Payload Payload + PrimaryInputHash *string + ResourceClass *string + ResourceLimits resource.Set + Resources resource.Set + Timeout Duration + type JobHandlerDetail struct + EffectiveLeaseTTL Duration + Execution ExecutionPolicy + Inputs []HandlerArtifactInput + LeaseTTL *Duration + ResourceClass *string + ResourceFunction bool + ResourceLimits resource.Set + Resources resource.Set + type JobRow struct + CompletedAt *string + CreatedAt *string + ID string + MaxRetries int + Name string + Priority int + Queue string + RetryCount int + RunAt *string + ScopeAppID *string + ScopeOrgID *string + StartedAt *string + State job.State + WorkerID *string + type JobsListInput struct + Cursor string + Limit int + NamePrefix string + Queue string + ScopeAppID string + ScopeOrgID string + States []job.State + type LocalResources struct + Capacity resource.Set + Enabled bool + Free resource.Set + Leases []ResourceLeaseRow + Reclaimable resource.Set + type NameInput struct + Name string + type OverviewSummary struct + AsOf string + Crons CronSummary + Jobs JobCounts + Runs map[workflow.RunState]int64 + UnreplayedDeadLetters int64 + Workers WorkerSummary + type Page struct + AsOf string + Complete bool + Items []T + NextCursor *string + type Payload struct + Bytes *int + JSON json.RawMessage + JSONText string + Kind string + type PoolConfig struct + Concurrency int + DefaultLeaseTTL Duration + JobHeartbeatInterval Duration + LeasesEnabled bool + MaxPollInterval Duration + PollInterval Duration + Queues []string + ReapInterval Duration + ReapingEnabled bool + ShutdownTimeout Duration + StaleJobThreshold Duration + StoreCallTimeout Duration + StoreCallsBounded bool + WorkerHeartbeatInterval Duration + WorkerStaleThreshold Duration + type QueueConfigRow struct + Name string + Settings QueueSettings + type QueueDetail struct + AsOf string + type QueueInput struct + Queue string + type QueueRow struct + Counts map[job.State]int64 + LocalActiveCount *int + LocalSettings *QueueSettings + Name string + PolledByThisProcess bool + Total int64 + type QueueSettings struct + EffectiveRateBurst *int + MaxConcurrency int + RateBurst int + RateLimit float64 + type QueuesPage struct + WorkerDiscoveryEnabled bool + type RequestedRlimits struct + AddressSpace int64 + Core int64 + FSize int64 + NProc int64 + NoFile int64 + type ResourceConfig struct + AdvertisedWorkerCapacity resource.Set + CustomKeys []string + Defaults resource.Set + Enabled bool + EstimatorConfigured bool + Queues map[string]resource.Set + type ResourceLeaseRow struct + AcquiredAt *string + Held resource.Set + Owner string + type SchedulerConfig struct + LeaderTTL Duration + LockTTL Duration + RefreshInterval Duration + StoreCallTimeout Duration + StoreCallsBounded bool + TickInterval Duration + type SubprocessConfig struct + AllowSameUser bool + GID *int + HasRlimits bool + RequestedLimits RequestedRlimits + ScratchDir *string + StrictRlimits bool + UID *int + UserConfigured bool + type WorkerDetail struct + AsOf string + Enabled bool + LeaderID *string + Resources LocalResources + SilentAfter *Duration + Worker *WorkerRow + type WorkerRow struct + Capacity resource.Set + ClockSkew bool + Concurrency int + CreatedAt *string + HeartbeatAge *Duration + HeartbeatInterval *Duration + HeartbeatStatus string + Hostname *string + ID string + IsLeader bool + LastSeen *string + LeaderUntil *string + Queues []string + Self bool + State cluster.WorkerState + type WorkerSummary struct + Enabled bool + LeaderID *string + Recent int + Silent int + SilentAfter *Duration + Unknown int + type WorkersPage struct + Enabled bool + HeartbeatReference *Duration + LeaderID *string + SilentAfter *Duration + type WorkflowCheckpoint struct + CreatedAt *string + ID string + Payload Payload + StepName string + type WorkflowDetail struct + AsOf string + Checkpoints []WorkflowCheckpoint + Children []WorkflowRow + Error *string + Input Payload + Output Payload + VersionRegistered bool + type WorkflowReplayCommandInput struct + ExpectedGeneration *int64 + type WorkflowReplayInput struct + FromStep string + ID string + type WorkflowReplayPreview struct + AsOf string + FromStep string + Generation int64 + Reruns []string + RunID string + State workflow.RunState + Version int + type WorkflowReplayResult struct + AcceptedGeneration int64 + AsOf string + Plan WorkflowReplayPreview + type WorkflowRow struct + CompletedAt *string + CreatedAt *string + Duration *Duration + ID string + Name string + ParentRunID *string + RecordedVersion int + ReplayGeneration int64 + ScopeAppID *string + ScopeOrgID *string + StartedAt *string + State workflow.RunState + UpdatedAt *string + Version int + type WorkflowsListInput struct + Cursor string + Limit int + NamePrefix string + ScopeAppID string + ScopeOrgID string + State workflow.RunState v1.9.2 Oct 20, 2026 v1.9.1 Oct 18, 2026 v1.9.0 Oct 18, 2026 v1.8.0 Oct 11, 2026 v1.7.0 Oct 8, 2026
Go to main page