Versions in this module Expand all Collapse all v1 v1.32.0 Apr 4, 2025 Changes in this version + func AutorunCollector(ctx context.Context) error + func GarbageCollector(ctx context.Context, completedTaskExpiration string) error + func Init(ctx context.Context, wg *sync.WaitGroup, store *configstore.Store) error + func InstanceCollector(ctx context.Context, maxConcurrentExecutions int, waitDuration time.Duration) error + func RetryCollector(ctx context.Context) error + type Engine struct + func GetEngine() Engine + func (e Engine) Resolve(publicID string, sm *semaphore.Weighted) error + func (e Engine) SyncResolve(publicID string, sm *semaphore.Weighted) (*resolution.Resolution, error)
Go to main page