workflow

type Activity interface{}

type ActivityOptions struct {
	RetryOptions RetryOptions
}

type Registry struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type RetryOptions struct {
	// Maximum number of times to retry
	MaxAttempts int

	// Time to wait before first retry
	FirstRetryInterval time.Duration

	// Maximum delay for any individual retry attempt
	MaxRetryInterval time.Duration

	// Coeffecient for calculation the next retry delay
	BackoffCoefficient float64

	// Timeout after which retries are aborted
	RetryTimeout time.Duration
}

type SubWorkflowOptions struct {
	InstanceID string

	RetryOptions RetryOptions
}

type Workflow interface{}

type WorkflowExecutor interface {
	ExecuteTask(ctx context.Context, t *task.Workflow) ([]history.Event, []history.WorkflowEvent, error)

	Close()
}

type WorkflowExecutorCache interface {
	Store(ctx context.Context, instance core.WorkflowInstance, workflow WorkflowExecutor) error
	Get(ctx context.Context, instance core.WorkflowInstance) (WorkflowExecutor, bool, error)
	StartEviction(ctx context.Context)
}

type WorkflowExecutorCacheOptions struct {
	// CacheDuration is the duration after which a workflow executor is removed from the cache.
	CacheDuration time.Duration
}