- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for AllTrackingEventTypes (0.48 sec)
-
pilot/pkg/xds/eventhandler.go
import ( v3 "istio.io/istio/pilot/pkg/xds/v3" "istio.io/istio/pkg/util/sets" ) // EventType represents the type of object we are tracking, mapping to envoy TypeUrl. type EventType = string var AllTrackingEventTypes = sets.New[EventType]( v3.ClusterType, v3.ListenerType, v3.RouteType, v3.EndpointType, ) // EventHandler allows for generic monitoring of xDS ACKS and disconnects, for the purpose of tracking
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 1.3K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
return } // if typeUrl is not empty, report all events that are not being watched unWatched := sets.NewWithLength[EventType](len(AllTrackingEventTypes)) watchedTypes := con.proxy.GetWatchedResourceTypes() for tyeUrl := range AllTrackingEventTypes { if _, exists := watchedTypes[tyeUrl]; !exists { unWatched.Insert(tyeUrl) } } for tyeUrl := range unWatched {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pilot/pkg/status/distribution/reporter.go
} // Skip unsupported event types. This ensures we do not leak memory for types // which may not be handled properly. For example, a type not in AllEventTypes // will not be properly unregistered. if _, f := xds.AllTrackingEventTypes[distributionType]; !f { return } d := distributionEvent{nonce: nonce, distributionType: distributionType, conID: conID} select { case r.distributionEventQueue <- d: return default:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 11.5K bytes - Viewed (0)