Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/TalkingData/owl
/ newGetter
Method
newGetter
controller/queue.go:52–55 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
50
}
51
52
func
(q *Queue) newGetter() *list.Element {
53
w := newWaiter()
54
return
q.getters.PushBack(w)
55
}
56
57
func
(q *Queue) notifyPutter(getter *list.Element) bool {
58
if
getter != nil {
Callers
1
Get
Method · 0.95
Calls
1
newWaiter
Function · 0.85
Tested by
no test coverage detected