Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

scheduler

package

Go to main page

Versions in this module

v0

v0.1.1

May 14, 2025

Changes in this version

+ type FuncLogger struct

+ func (l *FuncLogger) Debug(format string, args ...any)

+ func (l *FuncLogger) Error(format string, args ...any)

+ func (l *FuncLogger) Info(format string, args ...any)

+ func (l *FuncLogger) Warn(format string, args ...any)

+ type Logger interface

+ Debug func(format string, args ...any)

+ Error func(format string, args ...any)

+ Info func(format string, args ...any)

+ Warn func(format string, args ...any)

+ func NewFuncLogger(logFunc func(format string, args ...any)) Logger

+ type Priority int

+ const PriorityHigh

+ const PriorityLow

+ const PriorityNormal

+ type PriorityQueue struct

+ func NewPriorityQueue() *PriorityQueue

+ func (pq *PriorityQueue) Dequeue() *Task

+ func (pq *PriorityQueue) Enqueue(task *Task)

+ func (pq *PriorityQueue) IsEmpty() bool

+ func (pq *PriorityQueue) Len() int

+ func (pq *PriorityQueue) Less(i, j int) bool

+ func (pq *PriorityQueue) Pop() interface{}

+ func (pq *PriorityQueue) Push(x interface{})

+ func (pq *PriorityQueue) Swap(i, j int)

+ type ResourceLimits struct

+ MaxCPU int

+ MaxMemory int

+ MaxTime time.Duration

type Task

+ func (t *Task) GetRunCount() int

+ type TaskItem struct

type TaskOption

+ func WithLoggerFunc(logFunc func(format string, args ...any)) TaskOption

+ func WithMaxCPU(maxCPU int) TaskOption

+ func WithMaxExecutionTime(maxTime time.Duration) TaskOption

+ func WithMaxMemory(maxMemory int) TaskOption

+ func WithPriority(priority Priority) TaskOption

+ func WithResourceLimits(limits ResourceLimits) TaskOption

+ type WorkerPool struct

+ func NewWorkerPool(size int, logger Logger) *WorkerPool

+ func (wp *WorkerPool) Start()

+ func (wp *WorkerPool) Stop()

+ func (wp *WorkerPool) Submit(task *Task)

v0.0.2

May 14, 2025

v0.0.1

May 14, 2025

Changes in this version

+ type Job func(ctx context.Context) error

+ type JobResult struct

+ Duration time.Duration

+ Err error

+ Name string

+ Success bool

+ type Task struct

+ func NewTask(opts ...TaskOption) *Task

+ func (t *Task) Run()

+ func (t *Task) Stop()

+ type TaskOption func(*Task)

+ func WithCancelOnFailure(cancel bool) TaskOption

+ func WithErrorHandler(handler func(error)) TaskOption

+ func WithJob(job func(context.Context) error) TaskOption

+ func WithLogger(logger func(string, ...any)) TaskOption

+ func WithMaxRuns(n int) TaskOption

+ func WithMetricCollector(collector func(JobResult)) TaskOption

+ func WithName(name string) TaskOption

+ func WithParallelism(n int) TaskOption

+ func WithPostHook(hook func()) TaskOption

+ func WithPreHook(hook func()) TaskOption

+ func WithRecover(hook func(interface{})) TaskOption

+ func WithRepeat(interval time.Duration) TaskOption

+ func WithRetry(n int) TaskOption

+ func WithStartupDelay(delay time.Duration) TaskOption

+ func WithTimeout(timeout time.Duration) TaskOption