common

Documentation

Index

• func IsIgnorableError(err error) bool
• func NewIgnorableError(err error) error
• type IgnorableError
  • func (i *IgnorableError) Error() string
• type Int64Tuple
• type Job
• type JobWithId
• type WorkerPool
  • func NewWorkerPool(ctx context.Context, workerNum int, rps int32) (*WorkerPool, error)
  • func (p *WorkerPool) Done()
  • func (p *WorkerPool) JobNum() int32
  • func (p *WorkerPool) Start()
  • func (p *WorkerPool) Submit(job Job)
  • func (p *WorkerPool) SubmitWithId(job Job) int64
  • func (p *WorkerPool) Wait() error
  • func (p *WorkerPool) WaitJobs(jobIds []int64) error

Functions

func IsIgnorableError

func IsIgnorableError(err error) bool

func NewIgnorableError

func NewIgnorableError(err error) error

Types

type IgnorableError

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

func (*IgnorableError) Error

func (i *IgnorableError) Error() string

type Int64Tuple

type Int64Tuple struct {
	Key, Value int64
}

type Job

type Job func(ctx context.Context) error

type JobWithId

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

type WorkerPool

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

WorkerPool a pool that can control the total amount and rate of concurrency

func NewWorkerPool

func NewWorkerPool(ctx context.Context, workerNum int, rps int32) (*WorkerPool, error)

NewWorkerPool build a worker pool, rps 0 is unlimited

func (*WorkerPool) Done

func (p *WorkerPool) Done()

func (*WorkerPool) JobNum

func (p *WorkerPool) JobNum() int32

func (*WorkerPool) Start

func (p *WorkerPool) Start()

func (*WorkerPool) Submit

func (p *WorkerPool) Submit(job Job)

func (*WorkerPool) SubmitWithId

func (p *WorkerPool) SubmitWithId(job Job) int64

func (*WorkerPool) Wait

func (p *WorkerPool) Wait() error

func (*WorkerPool) WaitJobs

func (p *WorkerPool) WaitJobs(jobIds []int64) error