worker

package

v1.1.1 Latest Latest Go to latest Published: Nov 30, 2025 License: Apache-2.0 Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type JobEventCallback func(ctx context.Context, event domain.WebhookEvent)

JobEventCallback is called when a job event occurs

type MetricsCallback func(jobType, status string, duration time.Duration)

MetricsCallback is called to report job metrics

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

Pool manages a pool of workers for executing jobs

func NewPool(workers int, repo repository.Repository, registry *domain.JobRegistry) *Pool

NewPool creates a new worker pool

func (p *Pool) CancelJob(ctx context.Context, jobID string) error

CancelJob cancels a running job

func (p *Pool) GetStatus(ctx context.Context) *domain.WorkerStatus

GetStatus returns the current status of the worker pool

func (p *Pool) SetJobEventCallback(callback JobEventCallback)

SetJobEventCallback sets the callback for job events (used for webhooks)

func (p *Pool) SetLogRetention(days int)

SetLogRetention configures log retention cleanup

func (p *Pool) SetMetricsCallback(callback MetricsCallback)

SetMetricsCallback sets the callback for job metrics

func (p *Pool) Start(ctx context.Context) error

Start starts the worker pool

func (p *Pool) Stop(ctx context.Context) error

Stop stops the worker pool gracefully