Documentation
¶
Index ¶
- Constants
- Variables
- func StartHandler(ctx workflow.Context, workflowID string, req HandlerRequest)
- func UpdateWithStart(ctx context.Context, tc temporalclient.Client, qs *app.QueueSignal, ...) (tclient.WorkflowUpdateHandle, error)
- type CancelRequest
- type CancelResponse
- type ExecuteResponse
- type FinishedRequest
- type FinishedResponse
- type HandlerRequest
- type Params
- type ReadyRequest
- type ReadyResponse
- type StatusRequest
- type StatusResponse
- type UpdateWithStartOptions
- type ValidateResponse
- type Workflows
Constants ¶
View Source
const ( CancelUpdateName string = "cancel" CancelUpdateType = handlerTypeUpdate )
View Source
const ( FinishedHandlerName string = "finished" FinishedHandlerType = handlerTypeUpdate )
View Source
const ( ReadyHandlerName string = "ready" ReadyHandlerType = handlerTypeUpdate )
View Source
const ( StatusQueryName string = "status" StatusQueryType = handlerTypeQuery )
View Source
const ExecuteUpdateName string = "execute"
View Source
const ValidateUpdateName string = "validate"
Variables ¶
View Source
var ErrAlreadyExecuted = errors.New("signal already succeeded")
Functions ¶
func StartHandler ¶
func StartHandler(ctx workflow.Context, workflowID string, req HandlerRequest)
func UpdateWithStart ¶ added in v0.19.894
func UpdateWithStart( ctx context.Context, tc temporalclient.Client, qs *app.QueueSignal, opts UpdateWithStartOptions, ) (tclient.WorkflowUpdateHandle, error)
UpdateWithStart sends a Temporal update-with-start to the handler workflow for the given QueueSignal. Returns the WorkflowUpdateHandle for callers to retrieve results via handle.Get().
Types ¶
type CancelRequest ¶ added in v0.19.850
type CancelRequest struct{}
type CancelResponse ¶ added in v0.19.850
type CancelResponse struct{}
type ExecuteResponse ¶
type ExecuteResponse struct{}
type FinishedRequest ¶
type FinishedRequest struct{}
type FinishedResponse ¶
type HandlerRequest ¶
type ReadyRequest ¶
type ReadyRequest struct{}
type ReadyResponse ¶
type ReadyResponse struct {
RunID string `json:"run_id"`
}
type StatusRequest ¶ added in v0.19.850
type StatusRequest struct{}
type StatusResponse ¶ added in v0.19.850
type UpdateWithStartOptions ¶ added in v0.19.894
type UpdateWithStartOptions struct {
UpdateName string
WaitForStage tclient.WorkflowUpdateStage
Args []any
}
UpdateWithStartOptions configures the update sent to a handler workflow.
type ValidateResponse ¶
type ValidateResponse struct{}
type Workflows ¶
type Workflows struct {
// contains filtered or unexported fields
}
func NewWorkflows ¶
Source Files
¶
Click to show internal directories.
Click to hide internal directories.