scheduler

Documentation

Index

• type Scheduler
  • func NewScheduler[T any]() *Scheduler[T]
  • func (s *Scheduler[T]) Close()
  • func (s *Scheduler[T]) ScheduleDeadline(item T, deadline time.Time)
  • func (s *Scheduler[T]) ScheduleDelay(item T, delay time.Duration)
  • func (s *Scheduler[T]) Scheduled() <-chan T

Types

type Scheduler

type Scheduler[T any] struct {
	// contains filtered or unexported fields
}

func NewScheduler

func NewScheduler[T any]() *Scheduler[T]

func (*Scheduler[T]) Close

func (s *Scheduler[T]) Close()

func (*Scheduler[T]) ScheduleDeadline

func (s *Scheduler[T]) ScheduleDeadline(item T, deadline time.Time)

func (*Scheduler[T]) ScheduleDelay

func (s *Scheduler[T]) ScheduleDelay(item T, delay time.Duration)

func (*Scheduler[T]) Scheduled

func (s *Scheduler[T]) Scheduled() <-chan T