queue

type EnqueueHandlerInput struct {
	Signal    signal.Signal `json:"signal"`
	OwnerID   string        `json:"owner_id,omitempty"`
	OwnerType string        `json:"owner_type,omitempty"`
}

type EnqueueResponse struct {
	ID         string
	WorkflowID string
}

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
}

type QueueWorkflowRequest struct {
	QueueID string
	Version string

	ReleaseWindow *ReleaseWindow

	State *QueueState
}

type ReadyRequest struct{}

type ReadyResponse struct{}

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
}