executor

package

v0.0.2 Latest Latest Go to latest Published: Aug 19, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Executor interface {
	Start(ctx context.Context, params any) error
	Stop(wait bool) error
	Stats() *Stats
}

func New(j job.Job, opts ...Option) Executor

type Option func(*executor)

func NoTimeout() Option

func Once() Option

func WithCooldown(cooldown time.Duration) Option

func WithRetry(attempts uint, interval time.Duration) Option

func WithTimeout(timeout time.Duration) Option

type Stats struct {
	Retries  uint          `json:"retries"`
	Cooldown time.Duration `json:"cooldown"`
}