Versions in this module Expand all Collapse all v0 v0.2.0 Apr 19, 2026 v0.1.0 Mar 16, 2026 Changes in this version + func DecorateStarterForTests(temporalModule *module.Module, timeout time.Duration) *module.Module + func ExecuteWorkflow(ctx context.Context, starter Starter, options client.StartWorkflowOptions, ...) (client.WorkflowRun, error) + func Name(method interface{}) string + func NewFuture[T any](ctx workflow.Context) (Future[T], Settable[T]) + func NewManifesto() module.Manifesto + func NewModule() *module.Module + func OverrideStarter[T Starter](temporalModule *module.Module) *module.Module + func Provide[T Registerer](register interface{}, opts ...RegisterOption) fx.Option + func RegisterActivity(registry worker.Registry, a interface{}) + func RegisterWorkflow(registry worker.Registry, w interface{}) + func ScheduleAnnotation[T Schedule]() interface + func SchedulerCommand(scheduler *Scheduler) *cli.Command + func ShouldContinueAsNew(ctx workflow.Context) bool + func SideEffect[T any](ctx workflow.Context, f func(ctx workflow.Context) T) (T, error) + func WaitActivityWithoutResult(ctx workflow.Context, activity interface{}, input ...any) error + func WaitActivity[O any](ctx workflow.Context, activity interface{}, input ...any) (O, error) + func WorkerCommand(w *Worker) *cli.Command + func WorkflowName(w interface{}) string + type Channel struct + func NewChannel[T any](ctx workflow.Context) Channel[T] + func (c Channel[T]) Close() + func (c Channel[T]) Receive(ctx workflow.Context) (t T, more bool) + func (c Channel[T]) ReceiveWithTimeout(ctx workflow.Context, timeout time.Duration) (t T, ok bool, more bool) + func (c Channel[T]) Send(ctx workflow.Context, value T) + func (c Channel[T]) SendAsync(value T) (ok bool) + type Config struct + ApiKey string + Host string + Namespace string + type Future struct + Future workflow.Future + func ExecuteActivity[O any](ctx workflow.Context, activity interface{}, args ...any) Future[O] + func (f Future[T]) Get(ctx workflow.Context) (T, error) + func (f Future[T]) GetOrDefault(ctx workflow.Context) T + func (f Future[T]) GetWithTimeout(ctx workflow.Context, timeout time.Duration) (T, error) + func (f Future[T]) IsReady() bool + type RegisterOption func() interface + type Registerer interface + Register func(worker.Registry) + type Schedule interface + Schedule func(queue string) client.ScheduleOptions + type Scheduler struct + func NewScheduler(params SchedulerParams) *Scheduler + func (w *Scheduler) Invoke(ctx context.Context, queue string) error + type SchedulerParams struct + Logger *slog.Logger + Schedules []Schedule + Temporal client.Client + type Settable struct + Settable workflow.Settable + func (f Settable[T]) Set(value T, err error) + func (f Settable[T]) SetError(err error) + func (f Settable[T]) SetValue(value T) + type Starter interface + ExecuteWorkflow func(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) (client.WorkflowRun, error) + SignalWithStartWorkflow func(ctx context.Context, workflowID string, signalName string, ...) (client.WorkflowRun, error) + SignalWorkflow func(ctx context.Context, workflowID string, runID string, signalName string, ...) error + func NewStarter(client client.Client) Starter + type TestingStarter struct + func NewTestingStarter(env *testsuite.TestWorkflowEnvironment) *TestingStarter + func (s TestingStarter) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow interface{}, ...) (client.WorkflowRun, error) + func (s TestingStarter) SignalWithStartWorkflow(ctx context.Context, workflowID string, signalName string, ...) (client.WorkflowRun, error) + func (s TestingStarter) SignalWorkflow(ctx context.Context, workflowID string, runID string, signalName string, ...) error + type TestingWorkflowRun struct + func (r *TestingWorkflowRun) Get(ctx context.Context, valuePtr interface{}) error + func (r *TestingWorkflowRun) GetID() string + func (r *TestingWorkflowRun) GetRunID() string + func (r *TestingWorkflowRun) GetWithOptions(ctx context.Context, valuePtr interface{}, ...) error + type WaitGroup struct + func NewWaitGroup(ctx workflow.Context) *WaitGroup + func (w *WaitGroup) Go(ctx workflow.Context, f func(ctx workflow.Context) error) + func (w *WaitGroup) Wait(ctx workflow.Context) error + type Worker struct + func NewWorker(params WorkersParams) *Worker + func (w *Worker) Invoke(cliCtx *cli.Context, queue string, enableSessionWorker bool) error + type WorkersParams struct + Registerers []Registerer + Runner *infraCli.Runner + Temporal client.Client
Go to main page