MCPcopy Create free account
hub / github.com/cloudwan/gohan / Add

Method Add

job/queue.go:94–97  ·  view source on GitHub ↗

Add new job

(job Job)

Source from the content-addressed store, hash-verified

92
93//Add new job
94func (queue *Queue) Add(job Job) {
95 queue.waitGroup.Add(1)
96 queue.queue <- job
97}
98
99//Wait until all job get done
100func (queue *Queue) Wait() {

Callers 15

TestQueueFunction · 0.95
forEachListFunction · 0.95
publishEventWithOptionsFunction · 0.45
cli_test.goFile · 0.45
setCachedSchemasMethod · 0.45
NewServerFunction · 0.45
addJSONContentTypeHeaderFunction · 0.45
MapRouteBySchemaFunction · 0.45
runSyncWatchesMethod · 0.45
getTokenFunction · 0.45
WatchMethod · 0.45
registerGohanFormatsFunction · 0.45

Calls

no outgoing calls

Tested by 1

TestQueueFunction · 0.76