cleanup

pkg/blockbuilder/queue.go

@@ -28,6 +28,7 @@ func NewJobQueue() *JobQueue {
 }
 
 // Enqueue adds a new job to the pending queue
+// This is a naive implementation, intended to be refactored
 func (q *JobQueue) Enqueue(job *Job) error {
 	q.mu.Lock()
 	defer q.mu.Unlock()

pkg/blockbuilder/scheduler.go

@@ -17,15 +17,15 @@ type Scheduler interface {
 // unimplementedScheduler provides default implementations that panic.
 type unimplementedScheduler struct{}
 
-func (s *unimplementedScheduler) HandleGetJob(ctx context.Context, builderID string) (*Job, bool, error) {
+func (s *unimplementedScheduler) HandleGetJob(_ context.Context, _ string) (*Job, bool, error) {
 	panic("unimplemented")
 }
 
-func (s *unimplementedScheduler) HandleCompleteJob(ctx context.Context, builderID string, job *Job) error {
+func (s *unimplementedScheduler) HandleCompleteJob(_ context.Context, _ string, _ *Job) error {
 	panic("unimplemented")
 }
 
-func (s *unimplementedScheduler) HandleSyncJob(ctx context.Context, builderID string, job *Job) error {
+func (s *unimplementedScheduler) HandleSyncJob(_ context.Context, _ string, _ *Job) error {
 	panic("unimplemented")
 }
 
@@ -51,10 +51,10 @@ func (s *SchedulerImpl) HandleGetJob(ctx context.Context, builderID string) (*Jo
 	}
 }
 
-func (s *SchedulerImpl) HandleCompleteJob(ctx context.Context, builderID string, job *Job) error {
+func (s *SchedulerImpl) HandleCompleteJob(_ context.Context, builderID string, job *Job) error {
 	return s.queue.MarkComplete(job.ID, builderID)
 }
 
-func (s *SchedulerImpl) HandleSyncJob(ctx context.Context, builderID string, job *Job) error {
+func (s *SchedulerImpl) HandleSyncJob(_ context.Context, builderID string, job *Job) error {
 	return s.queue.SyncJob(job.ID, builderID, job)
 }

pkg/blockbuilder/transport.go

@@ -35,15 +35,15 @@ type Transport interface {
 // unimplementedTransport provides default implementations that panic
 type unimplementedTransport struct{}
 
-func (t *unimplementedTransport) SendGetJobRequest(ctx context.Context, req *GetJobRequest) (*GetJobResponse, error) {
+func (t *unimplementedTransport) SendGetJobRequest(_ context.Context, _ *GetJobRequest) (*GetJobResponse, error) {
 	panic("unimplemented")
 }
 
-func (t *unimplementedTransport) SendCompleteJob(ctx context.Context, req *CompleteJobRequest) error {
+func (t *unimplementedTransport) SendCompleteJob(_ context.Context, _ *CompleteJobRequest) error {
 	panic("unimplemented")
 }
 
-func (t *unimplementedTransport) SendSyncJob(ctx context.Context, req *SyncJobRequest) error {
+func (t *unimplementedTransport) SendSyncJob(_ context.Context, _ *SyncJobRequest) error {
 	panic("unimplemented")
 }
 

pkg/blockbuilder/worker.go

@@ -15,15 +15,15 @@ type Worker interface {
 // unimplementedWorker provides default implementations for the Worker interface.
 type unimplementedWorker struct{}
 
-func (u *unimplementedWorker) GetJob(ctx context.Context) (*Job, bool, error) {
+func (u *unimplementedWorker) GetJob(_ context.Context) (*Job, bool, error) {
 	panic("unimplemented")
 }
 
-func (u *unimplementedWorker) CompleteJob(ctx context.Context, job *Job) error {
+func (u *unimplementedWorker) CompleteJob(_ context.Context, _ *Job) error {
 	panic("unimplemented")
 }
 
-func (u *unimplementedWorker) SyncJob(ctx context.Context, job *Job) error {
+func (u *unimplementedWorker) SyncJob(_ context.Context, _ *Job) error {
 	panic("unimplemented")
 }