Function WithScheduleTimeZone

jetstream/jetstream_options.go:813–821

WithScheduleTimeZone sets the time zone for cron schedule expressions. The zone must be a valid IANA time zone name (e.g., "America/New_York"). Only valid with cron schedule expressions; the server will reject this header if used with @at or @every schedules. Requires [StreamConfig.AllowMsgSchedules

(zone string)

// header if used with @at or @every schedules.
// Requires [StreamConfig.AllowMsgSchedules] to be enabled.
func WithScheduleTimeZone(zone string) PublishOpt {
	return func(opts *pubOpts) error {
		if zone == "" {
			return fmt.Errorf("%w: schedule time zone cannot be empty", ErrInvalidOption)
		}
		opts.scheduleTZ = zone
		return nil
	}
}

type nextOptFunc func(*nextOpts)