scheduler

package
v1.1.0 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 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

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.