scheduler

package

v0.15.0 Latest Latest Go to latest Published: Mar 23, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/hookdeck/outpost

Links

Documentation ¶

Index ¶

func WithLogger(logger *logging.Logger) func(*config)
func WithMaxConsecutiveErrors(n int) func(*config)
func WithPollBackoff(backoff time.Duration) func(*config)
func WithVisibilityTimeout(vt uint) func(*config)
type ScheduleOption
- func WithTaskID(id string) ScheduleOption
type ScheduleOptions
type Scheduler
- func New(name string, rsmqClient rsmq.Client, exec func(context.Context, string) error, ...) Scheduler

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func WithLogger ¶ added in v0.6.0

func WithLogger(logger *logging.Logger) func(*config)

func WithMaxConsecutiveErrors ¶ added in v0.14.0

func WithMaxConsecutiveErrors(n int) func(*config)

func WithPollBackoff ¶ added in v0.9.0

func WithPollBackoff(backoff time.Duration) func(*config)

func WithVisibilityTimeout ¶

func WithVisibilityTimeout(vt uint) func(*config)

Types ¶

type ScheduleOption ¶

type ScheduleOption func(*ScheduleOptions)

func WithTaskID ¶

func WithTaskID(id string) ScheduleOption

type ScheduleOptions ¶

type ScheduleOptions struct {
	ID string
}

type Scheduler ¶

type Scheduler interface {
	Init(context.Context) error
	Schedule(context.Context, string, time.Duration, ...ScheduleOption) error
	Monitor(context.Context) error
	Cancel(context.Context, string) error
	Shutdown() error
}

func New ¶

func New(name string, rsmqClient rsmq.Client, exec func(context.Context, string) error, opts ...func(*config)) Scheduler

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL