workflow

Documentation

Index

• Variables
• func ActivityFactory(ctx context.Context, opts ActivityOptions) (targets.Factory, error)
• func WorkflowFactory(ctx context.Context, opts WorkflowOptions) (targets.Factory, error)
• type ActivityOptions
• type EventSink
• type WorkflowOptions

Variables

var (
	ErrDuplicateInvocation = errors.New("duplicate invocation")
)

Functions

func ActivityFactory

func ActivityFactory(ctx context.Context, opts ActivityOptions) (targets.Factory, error)

func WorkflowFactory

func WorkflowFactory(ctx context.Context, opts WorkflowOptions) (targets.Factory, error)

Types

type ActivityOptions

type ActivityOptions struct {
	AppID              string
	ActivityActorType  string
	WorkflowActorType  string
	ReminderInterval   *time.Duration
	Scheduler          todo.ActivityScheduler
	Actors             actors.Interface
	SchedulerReminders bool
}

type EventSink

type EventSink func(*backend.OrchestrationMetadata)

type WorkflowOptions

type WorkflowOptions struct {
	AppID             string
	WorkflowActorType string
	ActivityActorType string
	ReminderInterval  *time.Duration

	Resiliency         resiliency.Provider
	Actors             actors.Interface
	Scheduler          todo.WorkflowScheduler
	SchedulerReminders bool
	EventSink          EventSink
}