cron

Documentation

Index

• type Dispatcher
  • func NewDispatcher[T any](logger *slog.Logger) Dispatcher[T]

Types

type Dispatcher

type Dispatcher[T any] interface {
	// AddTask return func to remove task
	AddTask(r T, expr *cronexpr.Expression, location *time.Location) func()

	Shutdown()

	// GetReadyTask get ready task chain
	GetReadyTask() <-chan T
}

func NewDispatcher

func NewDispatcher[T any](logger *slog.Logger) Dispatcher[T]