queue

type DirectExecuteRequest struct {
	QueueSignalID string `json:"queue_signal_id"`
}

type DirectExecuteResponse struct {
	QueueSignalID string `json:"queue_signal_id"`
}

type EnqueueHandlerInput struct {
	QueueSignalID string `json:"queue_signal_id"`
	WorkflowID    string `json:"workflow_id"`
}

type EnqueueResponse struct {
	ID         string
	WorkflowID string
}

type ForceRestartRequest struct{}

type ForceRestartResponse struct{}

type Params struct {
	fx.In

	Cfg *internal.Config
	V   *validator.Validate
}

type PauseRequest struct{}

type PauseResponse struct{}

type QueueRef struct {
	WorkflowID string
	ID         string
}

type QueueState struct {
	QueueRefs        []QueueRef
	Paused           bool
	LastActivityTime time.Time
}

type QueueWorkflowRequest struct {
	QueueID string
	Version string

	ReleaseWindow *ReleaseWindow

	State *QueueState
}

type ReadyResponse struct {
	Ready bool
}

type ReleaseWindow struct {
	// Days of the week (Mon, Tue, Wed, Thu, Fri, Sat, Sun)
	Days []string
	// StartTime in HH:MM format
	StartTime string
	// EndTime in HH:MM format
	EndTime string
	// Timezone (e.g. "America/New_York")
	Timezone string
}

type RestartRequest struct{}

type RestartResponse struct{}

type ResumeRequest struct{}

type ResumeResponse struct{}

type StatusRequest struct{}

type StatusResponse struct {
	Ready   bool
	Stopped bool
	Paused  bool

	QueueDepthCount int
	InFlightCount   int
	InFlight        []string
}

type StopRequest struct{}

type StopResponse struct{}

type Workflows struct {
	StartupHooks []func(workflow.Context, QueueWorkflowRequest) error
	// contains filtered or unexported fields
}