workpool

Documentation

Index

• func CustomControllerRateLimiter(qps int, bucketNum int) workqueue.RateLimiter
• type FuncResult
• type GoRoutineExecutor
• type GoRoutineFunc
• type GoRoutinePool
  • func NewRateLimitedGoRoutinePool(size int, stopCH <-chan struct{}, ctx context.Context, qps int, bucketNum int) *GoRoutinePool
  • func (p *GoRoutinePool) Run() []interface{}
  • func (p *GoRoutinePool) Submit(executor GoRoutineExecutor)

Functions

func CustomControllerRateLimiter

func CustomControllerRateLimiter(qps int, bucketNum int) workqueue.RateLimiter

Types

type FuncResult

type FuncResult struct {
	Result interface{}
	Err    error
}

FuncResult struct

type GoRoutineExecutor

type GoRoutineExecutor struct {
	TaskID string
	GoRoutineFunc
	GoRoutineParams []interface{}
}

GoRoutineExecutor body

type GoRoutineFunc

type GoRoutineFunc func(params ...interface{}) (interface{}, error)

GoRoutineFunc process func

type GoRoutinePool

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

GoRoutinePool go routine pool

func NewRateLimitedGoRoutinePool

func NewRateLimitedGoRoutinePool(size int, stopCH <-chan struct{}, ctx context.Context, qps int, bucketNum int) *GoRoutinePool

NewRateLimitedGoRoutinePool bucketNum 默认最好为1, 这样qps才会准确

func (*GoRoutinePool) Run

func (p *GoRoutinePool) Run() []interface{}

Run pool

func (*GoRoutinePool) Submit

func (p *GoRoutinePool) Submit(executor GoRoutineExecutor)

Submit task