worker

type Health struct {
	Running     bool   `json:"running"`
	QueueHealth bool   `json:"queue_health"`
	Error       string `json:"error,omitempty"`
}

type Orchestrator interface {
	SyncSource(ctx context.Context, sourceID string) (*domain.SyncResult, error)
	SyncAll(ctx context.Context) ([]*domain.SyncResult, error)
}

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

type WorkerConfig struct {
	TaskQueue      driven.TaskQueue
	Orchestrator   Orchestrator
	Scheduler      *services.Scheduler
	Logger         *slog.Logger
	Concurrency    int // Number of concurrent task processors
	DequeueTimeout int // Seconds to wait for a task before checking again
}