Function WithScheduleCron

jetstream/jetstream_options.go:748–756

WithScheduleCron schedules a message using a cron expression. Accepts 6-field cron format (seconds minutes hours day-of-month month day-of-week) or predefined schedules (e.g. [ScheduleHourly], [ScheduleDaily]). Requires [StreamConfig.AllowMsgSchedules] to be enabled.

(expr string)

// [ScheduleDaily]).
// Requires [StreamConfig.AllowMsgSchedules] to be enabled.
func WithScheduleCron(expr string) PublishOpt {
	return func(opts *pubOpts) error {
		if expr == "" {
			return fmt.Errorf("%w: cron expression cannot be empty", ErrInvalidOption)
		}
		opts.schedule = expr
		return nil
	}
}

// WithScheduleTarget sets the subject where scheduled messages will be
// delivered.