Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WorkflowIDCallback ¶
func WorkflowIDCallback(req *ExecuteJobRequest) string
NOTE(jm): this should not be required once temporal-gen supports passing in a workflow-id via parameter
Types ¶
type ExecuteJobRequest ¶
type Params ¶
type Params struct {
fx.In
V *validator.Validate
EVClient teventloop.Client
MetricsWriter metrics.Writer
QueueClient *queueclient.Client
}
type Workflows ¶
type Workflows struct {
// contains filtered or unexported fields
}
this is a workflow that is used to execute a job. It is designed to be reusable outside the context of this namespace, and for all jobs. Thus, it has it's own activities, and other components to allow it to work more effectively.
func (*Workflows) ExecuteJob ¶
func (w *Workflows) ExecuteJob(ctx workflow.Context, req *ExecuteJobRequest) (app.RunnerJobStatus, error)
@temporal-gen-v2 workflow @execution-timeout 1h @task-timeout 1m @task-queue "api" @id-generator WorkflowIDCallback
Click to show internal directories.
Click to hide internal directories.