client

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

type CreateEmitterRequest struct {
	QueueID     string `validate:"required"`
	Name        string `validate:"required"`
	Description string

	// Mode determines if this is a recurring cron emitter or a one-shot scheduled emitter
	Mode app.QueueEmitterMode `validate:"required"`

	// For cron mode: the cron schedule expression (e.g., "0 * * * *")
	CronSchedule string
	// For cron mode: spread fire times deterministically across this window by
	// shifting the schedule's minute field (offset = hash(emitter ID) % window
	// minutes). Zero or sub-minute windows disable jitter.
	JitterWindow time.Duration
	// For scheduled mode: when to fire the signal
	ScheduledAt *time.Time

	SignalType      signal.SignalType `validate:"required"`
	SignalTemplate  signal.Signal
	SignalExpiresIn time.Duration
}

type Params struct {
	fx.In

	DB      *gorm.DB `name:"psql"`
	Cfg     *internal.Config
	TClient temporalclient.Client
	L       *zap.Logger
	MW      metrics.Writer
}

type ToggleCronEmittersForOwnerRequest struct {
	OwnerID   string `validate:"required"`
	OwnerType string `validate:"required"`

	FromStatus app.Status `validate:"required"`
	ToStatus   app.Status `validate:"required"`
	Reason     string
}

type ToggleCronEmittersForOwnerResponse struct {
	Changed    int      `json:"changed"`
	Errors     int      `json:"errors"`
	EmitterIDs []string `json:"emitter_ids"`
}

type ToggleCronEmittersRequest struct {
	OrgID         string
	InstallID     string
	Disable       bool
	Reason        string
	StopWorkflows bool
}

type ToggleCronEmittersResponse struct {
	Changed    int      `json:"changed"`
	Errors     int      `json:"errors"`
	EmitterIDs []string `json:"emitter_ids"`
}