README
¶
Workflows
A workflow is custom application logic that consists of a set of tasks and or state transitions.
Implementing a new Workflow
A compliant workflow needs to implement the Workflow interface included in the workflow.go file.
Using Temporal
When using temporal as the workflow, the task queue must be provided as an Option in the start request struct with the key: task_queue
Associated Information
The following link to the workflow proposal will provide more information on this feature area: https://github.com/dapr/dapr/issues/4576
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StartRequest ¶
type StartRequest struct {
Options map[string]string `json:"workflow_options"`
WorkflowReference WorkflowReference `json:"workflow_reference"`
WorkflowName string `json:"function_name"`
Input interface{} `json:"input"`
}
StartRequest is the object describing a Start Workflow request.
type StateResponse ¶
type StateResponse struct {
WFInfo WorkflowReference
StartTime string `json:"start_time"`
Metadata map[string]string `json:"metadata"`
}
type Workflow ¶
type Workflow interface {
Init(metadata Metadata) error
Start(ctx context.Context, req *StartRequest) (*WorkflowReference, error)
Terminate(ctx context.Context, req *WorkflowReference) error
Get(ctx context.Context, req *WorkflowReference) (*StateResponse, error)
}
Workflow is an interface to perform operations on Workflow.
type WorkflowReference ¶
type WorkflowReference struct {
InstanceID string `json:"instance_id"`
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.