Versions in this module Expand all Collapse all v0 v0.1.1 Oct 12, 2026 v0.1.0 Aug 24, 2026 Changes in this version + const DefaultTaskQueue + func InterpreterWorkflow(ctx workflow.Context, in interpreterInput) (map[string]bool, error) + type Config struct + HostPort string + Namespace string + TaskQueue string + type Provider struct + func New(c client.Client, taskQueue string) *Provider + func NewFromConfig(cfg Config) (*Provider, error) + func (p *Provider) Cancel(ctx context.Context, id string) error + func (p *Provider) Close() + 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)
Go to main page