activities

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

type CreateQueueSignalRequest struct {
	QueueID string        `json:"queue_id" validate:"required"`
	Signal  signal.Signal `json:"signal" validate:"required"`

	// OwnerID and OwnerType are optional — when set they populate the polymorphic
	// owner association on the created QueueSignal so no separate UPDATE is needed.
	OwnerID   string     `json:"owner_id,omitempty"`
	OwnerType string     `json:"owner_type,omitempty"`
	ExpiresAt *time.Time `json:"expires_at,omitempty"`
}

type IncrementQueueSignalExecutionCountRequest struct {
	QueueSignalID string `json:"queue_signal_id" validate:"required"`
}

type Params struct {
	fx.In

	V  *validator.Validate
	DB *gorm.DB `name:"psql"`
}

type ResetStaleInProgressSignalsRequest struct {
	QueueID string `json:"queue_id" validate:"required"`
}

type UpdateQueueSignalRunIDRequest struct {
	QueueSignalID string `json:"queue_signal_id" validate:"required"`
	RunID         string `json:"run_id" validate:"required"`
}