handler

package

v0.19.771 Latest Latest Go to latest Published: Feb 7, 2026 License: AGPL-3.0 Imports: 11 Imported by: 0

Details

View Source

const (
	FinishedHandlerName string = "finished"
	FinishedHandlerType        = handlerTypeUpdate
)

View Source

const (
	ReadyHandlerName string = "ready"
	ReadyHandlerType        = handlerTypeUpdate
)

View Source

const ExecuteUpdateName string = "execute"

View Source

const ValidateUpdateName string = "validate"

This section is empty.

func StartHandler(ctx workflow.Context, workflowID string, req HandlerRequest)

type ExecuteResponse struct{}

type FinishedRequest struct{}

type FinishedResponse struct{}

type HandlerRequest struct {
	QueueID       string `validate:"required"`
	QueueSignalID string `validate:"required"`
}

type Params struct {
	fx.In

	Cfg *internal.Config
	V   *validator.Validate
}

type ReadyRequest struct{}

type ReadyResponse struct{}

type ValidateResponse struct{}

type Workflows struct {
	// contains filtered or unexported fields
}

func NewWorkflows(params Params) (*Workflows, error)

func (q *Workflows) All() []any

func (w *Workflows) Handler(ctx workflow.Context, req HandlerRequest) error

@temporal-gen workflow @task-queue "handler" @id-template queue-{{.QueueID}}-handler-{{.QueueSignalID}}

Path	Synopsis
activities