timewheel

Documentation

Index

• type ProcessFunc
• type RingBuffer
  • func (r *RingBuffer) DeleteKeyTask(key string)
  • func (r *RingBuffer) End()
  • func (r *RingBuffer) Process()
  • func (r *RingBuffer) ProcessTask(idx int64)
  • func (r *RingBuffer) RegisterTask(task Task)
  • func (r *RingBuffer) Start()
• type Task

Types

type ProcessFunc

type ProcessFunc func()

type RingBuffer

type RingBuffer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

learn use of timeWheel

func (*RingBuffer) DeleteKeyTask

func (r *RingBuffer) DeleteKeyTask(key string)

func (*RingBuffer) End

func (r *RingBuffer) End()

func (*RingBuffer) Process

func (r *RingBuffer) Process()

func (*RingBuffer) ProcessTask

func (r *RingBuffer) ProcessTask(idx int64)

func (*RingBuffer) RegisterTask

func (r *RingBuffer) RegisterTask(task Task)

func (*RingBuffer) Start

func (r *RingBuffer) Start()

type Task

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