workers

type JobsManager struct {
	FailedJobs    chan *WorkerJob // Channel to handle failed jobs
	JobTimeout    time.Duration   // Duration after which a job is considered timed out
	WorkerManager *WorkerManager  // Reference to the worker manager for job tracking
	// contains filtered or unexported fields
}

type Worker struct {
	Address string
	Name    string // Name of the worker for identification
	// contains filtered or unexported fields
}

type WorkerBanRules struct {
	BanTimeout          time.Duration // Duration for which the worker is banned
	FailuresToGetBanned int           // Maximum consecutive failed jobs before banning
}

type WorkerInfo struct {
	Address      string `json:"address"`
	Name         string `json:"name"`
	SuccessCount int64  `json:"successCount"`
	FailedCount  int64  `json:"failedCount"`
}

type WorkerJob struct {
	VoteID     types.VoteID
	Address    string
	Timestamp  time.Time
	Expiration time.Time // When the job should expire
}

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