workflows

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

• type Metadata
• type StartRequest
• type StateResponse
• type Workflow
• type WorkflowReference

Types

type Metadata

type Metadata struct {
	metadata.Base `json:",inline"`
}

Metadata represents a set of workflow specific properties.

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"`
}