Versions in this module Expand all Collapse all v0 v0.1.1 Oct 12, 2026 Changes in this version + const DefaultNamePrefix + var ErrEmptyActivityARN = errors.New("stepfunctions: activity ARN is empty") + var ErrNoPendingApproval = errors.New("stepfunctions: no gate awaiting this approval") + var ErrNoRoleARN = errors.New("stepfunctions: ProvisionConfig.RoleARN is required") + func RenderInterpreterASL(coordinatorActivityARN, stepActivityARN string) (string, error) + type MemoryTokenStore struct + func NewMemoryTokenStore() *MemoryTokenStore + func (m *MemoryTokenStore) Delete(_ context.Context, runID, gateID string) error + func (m *MemoryTokenStore) Get(_ context.Context, runID, gateID string) (string, bool, error) + func (m *MemoryTokenStore) Put(_ context.Context, runID, gateID, token string) error + type Options struct + TokenStore TokenStore + WorkerName string + type Provider struct + func New(client *sfnutil.Client, resources Provisioned, opts Options) *Provider + func NewFromConfig(ctx context.Context, cfg ProvisionConfig, opts Options) (*Provider, error) + func (p *Provider) Cancel(ctx context.Context, id string) error + func (p *Provider) Get(ctx context.Context, id string) (*omniworkflow.Run, error) + func (p *Provider) NewWorker(executor omniworkflow.StepExecutor) omniworkflow.Worker + func (p *Provider) Signal(ctx context.Context, id string, signal omniworkflow.Signal) error + func (p *Provider) Start(ctx context.Context, req omniworkflow.StartRequest) (*omniworkflow.Run, error) + type ProvisionConfig struct + NamePrefix string + Region string + RoleARN string + type Provisioned struct + CoordinatorActivityARN string + StateMachineARN string + StepActivityARN string + func Provision(ctx context.Context, cfg ProvisionConfig) (*Provisioned, error) + func ProvisionWithClient(ctx context.Context, client *sfnutil.Client, cfg ProvisionConfig) (*Provisioned, error) + type TokenStore interface + Delete func(ctx context.Context, runID, gateID string) error + Get func(ctx context.Context, runID, gateID string) (token string, ok bool, err error) + Put func(ctx context.Context, runID, gateID, token string) error
Go to main page