- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for processGraphChanges (0.51 sec)
-
pkg/controller/garbagecollector/graph.go
Name: s.Name, APIVersion: s.APIVersion, UID: s.UID, } } var _ fmt.Stringer = objectReference{} var _ logr.Marshaler = objectReference{} // The single-threaded GraphBuilder.processGraphChanges() is the sole writer of the // nodes. The multi-threaded GarbageCollector.attemptToDeleteItem() reads the nodes. // WARNING: node has different locks on different fields. setters and getters
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 13:37:56 UTC 2023 - 7.1K bytes - Viewed (0) -
pkg/controller/garbagecollector/graph_builder.go
// the in-memory graph according to the changes. graphChanges workqueue.TypedRateLimitingInterface[*event] // uidToNode doesn't require a lock to protect, because only the // single-threaded GraphBuilder.processGraphChanges() reads/writes it. uidToNode *concurrentUIDToNode // GraphBuilder is the producer of attemptToDelete and attemptToOrphan, GC is the consumer. attemptToDelete workqueue.TypedRateLimitingInterface[*node]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector_test.go
ctx.gc.dependencyGraphBuilder.processGraphChanges(ctx.logger) } } else { for i := 0; i < count; i++ { if ctx.gc.dependencyGraphBuilder.graphChanges.Len() == 0 { ctx.t.Errorf("expected at least %d pending changes, got %d", count, i+1) return } ctx.gc.dependencyGraphBuilder.processGraphChanges(ctx.logger) } } }, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.6K bytes - Viewed (0) -
pkg/controller/garbagecollector/garbagecollector.go
return forgetItem } } err := gc.attemptToDeleteItem(ctx, n) if err == enqueuedVirtualDeleteEventErr { // a virtual event was produced and will be handled by processGraphChanges, no need to requeue this node return forgetItem } else if err == namespacedOwnerOfClusterScopedObjectErr {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.9K bytes - Viewed (0)