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 HydrateLogStreamRequest struct {
	LogStreamID string `validate:"required"`
	OrgID       string `validate:"required"`
}

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

type Params struct {
	fx.In

	V          *validator.Validate
	DB         *gorm.DB `name:"psql"`
	Cfg        *internal.Config
	AcctClient *account.Client
}

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"`
}

type WorkflowCompletionOutcome struct {
	Status                 app.Status `json:"status"`
	StatusHumanDescription string     `json:"status_human_description,omitempty"`
}