queue

package

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

Details

View Source

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

View Source

const (
	StatusHandlerName string = "status"
	StatusHandlerType        = handlerTypeUpdate
)

View Source

const EnqueueUpdateName string = "enqueue"

View Source

const RestartUpdateName string = "restart"

View Source

const StopUpdateName string = "stop"

This section is empty.

This section is empty.

type EnqueueResponse struct {
	ID         string
	WorkflowID string
}

type Params struct {
	fx.In

	Cfg *internal.Config
	V   *validator.Validate
}

type QueueRef struct {
	WorkflowID string
	ID         string
}

type QueueState struct {
	QueueRefs []QueueRef
}

QueueState is the data that is passed between continue-as-news

type QueueWorkflowRequest struct {
	QueueID string
	Version string

	State *QueueState
}

type ReadyRequest struct{}

type ReadyResponse struct{}

type RestartRequest struct{}

type RestartResponse struct{}

type StatusRequest struct{}

type StatusResponse struct {
	Ready bool

	QueueDepthCount int
	InFlightCount   int
	InFlight        []string
}

type StopRequest struct{}

type StopResponse struct{}

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

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

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

func (w *Workflows) Queue(ctx workflow.Context, req QueueWorkflowRequest) error

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