scheduler

Documentation

Overview

Package scheduler contains a priority queue based on time.

Index

• type Scheduler
  • func New() *Scheduler
  • func (s *Scheduler) Add(due time.Time, key string)
  • func (s *Scheduler) Next() (time.Time, string)
  • func (s *Scheduler) Remove(key string)

Types

type Scheduler

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

A Scheduler implements a priority queue based on time. The scheduler is not thread-safe for multiple writers.

func New

func New() *Scheduler

New creates a new Scheduler.

func (*Scheduler) Add

func (s *Scheduler) Add(due time.Time, key string)

Add adds an item to the scheduler.

func (*Scheduler) Next

func (s *Scheduler) Next() (time.Time, string)

Next retrieves the next time an item is due.

func (*Scheduler) Remove

func (s *Scheduler) Remove(key string)

Remove removes an item from the scheduler and de-schedules it.