MCPcopy Index your code
hub / github.com/rilldata/rill / enqueue

Method enqueue

runtime/controller.go:1049–1052  ·  view source on GitHub ↗

enqueue marks a resource to be scheduled in the next iteration of the event loop. It does so by adding it to c.queue, which will be processed by processQueue(). It must be called while c.mu is held.

(name *runtimev1.ResourceName)

Source from the content-addressed store, hash-verified

1047// It does so by adding it to c.queue, which will be processed by processQueue().
1048// It must be called while c.mu is held.
1049func (c *Controller) enqueue(name *runtimev1.ResourceName) {
1050 c.queue[nameStr(name)] = name
1051 c.setQueueUpdated()
1052}
1053
1054// setQueueUpdated notifies the event loop that the queue has been updated and needs to be processed.
1055// It must be called while c.mu is held.

Callers 10

RunMethod · 0.95
CreateMethod · 0.95
UpdateMetaMethod · 0.95
UpdateNameMethod · 0.95
UpdateSpecMethod · 0.95
DeleteMethod · 0.95
ReconcileMethod · 0.95
safeMutateRenamedMethod · 0.95
safeRenameMethod · 0.95

Calls 2

setQueueUpdatedMethod · 0.95
nameStrFunction · 0.85

Tested by

no test coverage detected