taskpool

Documentation

Index

• type IJob
• type Option
  • func WithTaskConf(conf config.Config) Option
  • func WithTaskLogger(log log.Logger) Option
• type TaskPool
  • func GetTaskClient() *TaskPool
  • func NewTaskPool(opts ...Option) *TaskPool
  • func (t *TaskPool) AddJobs(jobs ...IJob)
  • func (t *TaskPool) Concurrency() int
  • func (t *TaskPool) Run()
  • func (t *TaskPool) Stop()
  • func (t *TaskPool) WithTaskSize(taskSize int)

Types

type IJob

type IJob interface {
	Run()
}

type Option

type Option func(*TaskPool)

func WithTaskConf

func WithTaskConf(conf config.Config) Option

func WithTaskLogger

func WithTaskLogger(log log.Logger) Option

type TaskPool

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

var (
	TaskClient *TaskPool
)

func GetTaskClient

func GetTaskClient() *TaskPool

func NewTaskPool

func NewTaskPool(opts ...Option) *TaskPool

func (*TaskPool) AddJobs

func (t *TaskPool) AddJobs(jobs ...IJob)

func (*TaskPool) Concurrency

func (t *TaskPool) Concurrency() int

func (*TaskPool) Run

func (t *TaskPool) Run()

func (*TaskPool) Stop

func (t *TaskPool) Stop()

func (*TaskPool) WithTaskSize

func (t *TaskPool) WithTaskSize(taskSize int)