Function WithScheduleEvery

jetstream/jetstream_options.go:733–741

WithScheduleEvery schedules a message for repeated delivery at the given interval. The minimum interval is 1 second. Requires [StreamConfig.AllowMsgSchedules] to be enabled.

(d time.Duration)

// interval. The minimum interval is 1 second.
// Requires [StreamConfig.AllowMsgSchedules] to be enabled.
func WithScheduleEvery(d time.Duration) PublishOpt {
	return func(opts *pubOpts) error {
		if d < time.Second {
			return fmt.Errorf("%w: schedule interval must be at least 1s", ErrInvalidOption)
		}
		opts.schedule = "@every " + d.String()
		return nil
	}
}

// WithScheduleCron schedules a message using a cron expression.
// Accepts 6-field cron format (seconds minutes hours day-of-month month