scheduler

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 13, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Option added in v1.1.0 

type Option func(*config)

func WithLogger added in v0.6.0 

func WithLogger(logger *logging.Logger) Option

func WithMaxConsecutiveErrors added in v0.14.0 

func WithMaxConsecutiveErrors(n int) Option

func WithMaxExecBackoff added in v1.1.0 

func WithMaxExecBackoff(d time.Duration) Option

func WithMaxReceiveCount added in v1.1.0 

func WithMaxReceiveCount(n uint64) Option

func WithPollBackoff added in v0.9.0 

func WithPollBackoff(backoff time.Duration) Option

WithPollBackoff sets the maximum time the monitor sleeps when no message is due. When the queue holds a message that is not yet visible, the monitor instead sleeps until that message comes due, so the actual sleep is min(timeUntilNextMessage, backoff). Worst-case lateness is therefore bounded by backoff, and is zero when backoff is at most the shortest delay anything is scheduled with — the config auto mode (retry_poll_backoff_ms = 0) guarantees this; explicit values may trade retry latency for idle cost.

func WithVisibilityTimeout 

func WithVisibilityTimeout(vt uint) Option

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 ...Option) Scheduler

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.