Function WithScheduleAt

jetstream/jetstream_options.go:723–728

WithScheduleAt schedules a message for one-time delivery at a specific time. Requires [StreamConfig.AllowMsgSchedules] to be enabled.

(t time.Time)

// WithScheduleAt schedules a message for one-time delivery at a specific time.
// Requires [StreamConfig.AllowMsgSchedules] to be enabled.
func WithScheduleAt(t time.Time) PublishOpt {
	return func(opts *pubOpts) error {
		opts.schedule = "@at " + t.UTC().Format(time.RFC3339)
		return nil
	}
}

// WithScheduleEvery schedules a message for repeated delivery at the given
// interval. The minimum interval is 1 second.