simplescheduler

Documentation

Index

• type SchedMinHeap
  • func (h SchedMinHeap) Len() int
  • func (h SchedMinHeap) Less(i, j int) bool
  • func (h *SchedMinHeap) Pop() interface{}
  • func (h *SchedMinHeap) Push(x interface{})
  • func (h SchedMinHeap) Swap(i, j int)
• type SimpleExpirer
  • func NewSimpleExpirer(cfg *config.Config) *SimpleExpirer
  • func (s *SimpleExpirer) Add(key sdk.KeyInfo)
  • func (s *SimpleExpirer) Close()
  • func (s *SimpleExpirer) GetChan() *chan sdk.KeyInfo
  • func (s *SimpleExpirer) Start()

Types

type SchedMinHeap

type SchedMinHeap []*schedHeapItem

func (SchedMinHeap) Len

func (h SchedMinHeap) Len() int

func (SchedMinHeap) Less

func (h SchedMinHeap) Less(i, j int) bool

func (*SchedMinHeap) Pop

func (h *SchedMinHeap) Pop() interface{}

func (*SchedMinHeap) Push

func (h *SchedMinHeap) Push(x interface{})

func (SchedMinHeap) Swap

func (h SchedMinHeap) Swap(i, j int)

type SimpleExpirer

type SimpleExpirer struct {
	C chan sdk.KeyInfo
	// contains filtered or unexported fields
}

func NewSimpleExpirer

func NewSimpleExpirer(cfg *config.Config) *SimpleExpirer

func (*SimpleExpirer) Add

func (s *SimpleExpirer) Add(key sdk.KeyInfo)

func (*SimpleExpirer) Close

func (s *SimpleExpirer) Close()

func (*SimpleExpirer) GetChan

func (s *SimpleExpirer) GetChan() *chan sdk.KeyInfo

func (*SimpleExpirer) Start

func (s *SimpleExpirer) Start()