Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
Index your code
hub
/
github.com/kopia/kopia
/ NewQueue
Function
NewQueue
internal/parallelwork/parallel_work_queue.go:169–174 ·
view source on GitHub ↗
NewQueue returns new parallel work queue.
()
Source
from the content-addressed store, hash-verified
167
168
// NewQueue returns new parallel work queue.
169
func
NewQueue() *Queue {
170
return
&Queue{
171
queueItems: list.New(),
172
monitor: sync.NewCond(&sync.Mutex{}),
173
}
174
}
Callers
8
TestEnqueueFrontAndProcess
Function · 0.92
TestEnqueueBackAndProcess
Function · 0.92
TestProcessWithError
Function · 0.92
TestWaitForActiveWorkers
Function · 0.92
TestProgressCallback
Function · 0.92
CleanupOldData
Function · 0.92
ListBlobs
Method · 0.92
Entry
Function · 0.92
Calls
no outgoing calls
Tested by
5
TestEnqueueFrontAndProcess
Function · 0.74
TestEnqueueBackAndProcess
Function · 0.74
TestProcessWithError
Function · 0.74
TestWaitForActiveWorkers
Function · 0.74
TestProgressCallback
Function · 0.74