@@ -735,7 +735,7 @@ func (s *sharedIndexInformer) HandleDeltas(obj interface{}, isInInitialList bool
735
735
// Conforms to ResourceEventHandler
736
736
func (s * sharedIndexInformer ) OnAdd (obj interface {}, isInInitialList bool ) {
737
737
// Invocation of this function is locked under s.blockDeltas, so it is
738
- // save to distribute the notification
738
+ // safe to distribute the notification
739
739
s .cacheMutationDetector .AddObject (obj )
740
740
s .processor .distribute (addNotification {newObj : obj , isInInitialList : isInInitialList }, false )
741
741
}
@@ -757,15 +757,15 @@ func (s *sharedIndexInformer) OnUpdate(old, new interface{}) {
757
757
}
758
758
759
759
// Invocation of this function is locked under s.blockDeltas, so it is
760
- // save to distribute the notification
760
+ // safe to distribute the notification
761
761
s .cacheMutationDetector .AddObject (new )
762
762
s .processor .distribute (updateNotification {oldObj : old , newObj : new }, isSync )
763
763
}
764
764
765
765
// Conforms to ResourceEventHandler
766
766
func (s * sharedIndexInformer ) OnDelete (old interface {}) {
767
767
// Invocation of this function is locked under s.blockDeltas, so it is
768
- // save to distribute the notification
768
+ // safe to distribute the notification
769
769
s .processor .distribute (deleteNotification {oldObj : old }, false )
770
770
}
771
771
@@ -1088,7 +1088,7 @@ func (p *processorListener) run() {
1088
1088
}
1089
1089
}
1090
1090
1091
- // shouldResync deterimines if the listener needs a resync. If the listener's resyncPeriod is 0,
1091
+ // shouldResync determines if the listener needs a resync. If the listener's resyncPeriod is 0,
1092
1092
// this always returns false.
1093
1093
func (p * processorListener ) shouldResync (now time.Time ) bool {
1094
1094
p .resyncLock .Lock ()
0 commit comments