MCPcopy Create free account
hub / github.com/cloudreve/cloudreve / Queue

Method Queue

pkg/queue/scheduler.go:23–23  ·  view source on GitHub ↗

Queue add a new Task into the queue

(task Task)

Source from the content-addressed store, hash-verified

21 Scheduler interface {
22 // Queue add a new Task into the queue
23 Queue(task Task) error
24 // Request get a new Task from the queue
25 Request() (Task, error)
26 // Shutdown stop all worker

Callers 7

QueueTaskMethod · 0.65
ThumbQueueMethod · 0.65
MediaMetaQueueMethod · 0.65
IoIntenseQueueMethod · 0.65
RemoteDownloadQueueMethod · 0.65
EntityRecycleQueueMethod · 0.65
SlaveQueueMethod · 0.65

Implementers 1

fifoSchedulerpkg/queue/scheduler.go

Calls

no outgoing calls

Tested by

no test coverage detected