scheduler

package

v0.27.5 Latest Latest Go to latest Published: Mar 18, 2025 License: BSD-3-Clause Imports: 4 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type DurationExecutor struct {
	// contains filtered or unexported fields
}

DurationExecutor executes a task and then stops immediately after the specified duration.

func NewDurationExecutor(duration time.Duration, log logging.Logger) *DurationExecutor

NewDurationExecutor creates a new DurationExecutor with the given duration and logger.

func (de *DurationExecutor) Run(ctx context.Context, task func(ctx context.Context) error) error

Run executes the given task and waits for the specified duration before stopping.

type PeriodicExecutor struct {
	// contains filtered or unexported fields
}

func NewPeriodicExecutor(interval time.Duration, log logging.Logger) *PeriodicExecutor

func (pe *PeriodicExecutor) Close() error

func (pe *PeriodicExecutor) Start(ctx context.Context, task func(ctx context.Context) error)