Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for AllTrackingEventTypes (0.48 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top