workerpool

Documentation

Index

• type ExecutionFn
• type FnParam
• type Job
• type JobID
• type WorkerPool
  • func New(ctx context.Context, wg *sync.WaitGroup, logger *slog.Logger, ...) (*WorkerPool, error)
  • func (wp *WorkerPool) Add(ctx context.Context, settings *models.Settings, execFn ExecutionFn) JobID
  • func (wp *WorkerPool) Close() error
  • func (wp *WorkerPool) Delete(ctx context.Context, jobID JobID)
  • func (wp *WorkerPool) GenerateFrom(jobsBulk []Job)
  • func (wp *WorkerPool) Run(wg *sync.WaitGroup)
  • func (wp *WorkerPool) SetTgBot(tgbot *bot.Bot)

Types

type ExecutionFn

type ExecutionFn func(ctx context.Context, fnParam FnParam) error

type FnParam

type FnParam struct {
	Logger   *slog.Logger
	Tgbot    *bot.Bot
	Repo     repository.Repository
	Settings *models.Settings
}

type Job

type Job struct {
	context.Context

	ID       JobID
	Settings *models.Settings
	ExecFn   ExecutionFn
	// contains filtered or unexported fields
}

type JobID

type JobID int64

type WorkerPool

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

func New

func New(ctx context.Context, wg *sync.WaitGroup, logger *slog.Logger, repo repository.Repository) (*WorkerPool, error)

func (*WorkerPool) Add

func (wp *WorkerPool) Add(ctx context.Context, settings *models.Settings, execFn ExecutionFn) JobID

func (*WorkerPool) Close

func (wp *WorkerPool) Close() error

func (*WorkerPool) Delete

func (wp *WorkerPool) Delete(ctx context.Context, jobID JobID)

func (*WorkerPool) GenerateFrom

func (wp *WorkerPool) GenerateFrom(jobsBulk []Job)

func (*WorkerPool) Run

func (wp *WorkerPool) Run(wg *sync.WaitGroup)

func (*WorkerPool) SetTgBot

func (wp *WorkerPool) SetTgBot(tgbot *bot.Bot)