emailworker

package

v1.15.16 Latest Latest Go to latest Published: Jul 31, 2026 License: GPL-3.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type ErrorInfo struct {
	Error string `json:"error"`
	Email string `json:"email"`
	Time  int64  `json:"time"`
}

type TaskStore interface {
	FindOne(ctx context.Context, id int64) (*task.Task, error)
	Update(ctx context.Context, data *task.Task) error
}

TaskStore is the minimal task repository interface needed by the batch-email worker.

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

func NewWorker(ctx context.Context, id int64, tasks TaskStore, sender emailpkg.Sender) *Worker

func (w *Worker) GetID() int64

func (w *Worker) IsRunning() uint8

func (w *Worker) Start()

Start processes a batch-email task until completion or cancellation.

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

WorkerManager owns asynchronous batch-email workers. It is an application worker, so it belongs in internal rather than the reusable email package.

var (
	Manager *WorkerManager
)

func NewWorkerManager(tasks TaskStore, sender emailpkg.Sender) *WorkerManager

func (m *WorkerManager) AddWorker(id int64)

AddWorker starts a worker only when one is not already processing the task.

func (m *WorkerManager) GetWorker(id int64) *Worker

GetWorker returns the worker currently assigned to id.

func (m *WorkerManager) RemoveWorker(id int64)

RemoveWorker cancels and removes the worker assigned to id.