Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunBenchmark ¶
func WorkToString ¶
Types ¶
type WorkPool ¶
func (*WorkPool) WorkGenerate ¶
func (p *WorkPool) WorkGenerate(item *serializableModels.ClientMessage) (string, error)
type WorkProcessor ¶
type WorkProcessor struct {
Queue *models.RandomAccessQueue
// WorkQueueChan is where we write requests from the websocket
WorkQueueChan chan *serializableModels.ClientMessage
WSService *websocket.WebsocketService
WorkPool *WorkPool
// contains filtered or unexported fields
}
func NewWorkProcessor ¶
func NewWorkProcessor(ws *websocket.WebsocketService, gpuOnly bool, devices []opencl.Device) *WorkProcessor
func (*WorkProcessor) StartRequestQueueWorker ¶
func (wp *WorkProcessor) StartRequestQueueWorker()
RequestQueueWorker - is a worker that receives work requests directly from the websocket, adds them to the queue, and determines what should be worked on next
Source Files
Click to show internal directories.
Click to hide internal directories.