timewheel

Documentation

Index

• type Notify
• type TimeWheel
  • func NewTimeWheel(ctx context.Context, maxTickers ...time.Duration) TimeWheel

Types

type Notify

type Notify func(context.Context, TimeWheel)

Notify is a function that is called when a timer expires.

type TimeWheel

type TimeWheel interface {
	// TickNext the next tick time
	TickNext(ddl time.Duration)
	// AddRunner add runner
	AddRunner(runner Notify)
	// Stop stop the time wheel
	Stop()
}

TimeWheel time wheel

func NewTimeWheel

func NewTimeWheel(ctx context.Context, maxTickers ...time.Duration) TimeWheel

NewTimeWheel new time wheel