scheduler

Documentation

Overview

The package is useless

Index

• type QueueScheduler
  • func NewQueueScheduler(rmDuplicate bool) *QueueScheduler
  • func (this *QueueScheduler) Count() int
  • func (this *QueueScheduler) Poll() *request.Request
  • func (this *QueueScheduler) Push(requ *request.Request)
• type Scheduler
• type SimpleScheduler
  • func NewSimpleScheduler() *SimpleScheduler
  • func (this *SimpleScheduler) Count() int
  • func (this *SimpleScheduler) Poll() *request.Request
  • func (this *SimpleScheduler) Push(requ *request.Request)

Types

type QueueScheduler

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

func NewQueueScheduler

func NewQueueScheduler(rmDuplicate bool) *QueueScheduler

func (*QueueScheduler) Count

func (this *QueueScheduler) Count() int

func (*QueueScheduler) Poll

func (this *QueueScheduler) Poll() *request.Request

func (*QueueScheduler) Push

func (this *QueueScheduler) Push(requ *request.Request)

type Scheduler

type Scheduler interface {
	Push(requ *request.Request)
	Poll() *request.Request
	Count() int
}

type SimpleScheduler

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

func NewSimpleScheduler

func NewSimpleScheduler() *SimpleScheduler

func (*SimpleScheduler) Count

func (this *SimpleScheduler) Count() int

func (*SimpleScheduler) Poll

func (this *SimpleScheduler) Poll() *request.Request

func (*SimpleScheduler) Push

func (this *SimpleScheduler) Push(requ *request.Request)