Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for EDSCacheUpdate (0.28 sec)

  1. pilot/pkg/serviceregistry/util/xdsfake/updater.go

    		fx.Delegate.EDSUpdate(c, hostname, ns, entry)
    	}
    }
    
    func (fx *Updater) EDSCacheUpdate(c model.ShardKey, hostname, ns string, entry []*model.IstioEndpoint) {
    	select {
    	case fx.Events <- Event{Type: "eds cache", ID: hostname, Endpoints: entry, Namespace: ns}:
    	default:
    	}
    	if fx.Delegate != nil {
    		fx.Delegate.EDSCacheUpdate(c, hostname, ns, entry)
    	}
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 29 18:40:34 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  2. pilot/pkg/xds/eds.go

    			ConfigsUpdated: sets.New(model.ConfigKey{Kind: kind.ServiceEntry, Name: serviceName, Namespace: namespace}),
    			Reason:         model.NewReasonStats(model.EndpointUpdate),
    		})
    	}
    }
    
    // EDSCacheUpdate computes destination address membership across all clusters and networks.
    // This is the main method implementing EDS.
    // It replaces InstancesByPort in model - instead of iterating over all endpoints it uses
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 15:58:06 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/controller.go

    		keys.Insert(makeInstanceKey(i))
    	}
    	s.queueEdsEvent(keys, s.doEdsUpdate)
    }
    
    // edsCacheUpdate updates eds cache serially such that we can prevent allinstances
    // got at t1 can accidentally override that got at t2 if multiple threads are
    // running this function. Queueing ensures latest updated wins.
    func (s *Controller) edsCacheUpdate(instances []*model.ServiceInstance) {
    	// Find all keys we need to lookup
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  4. pilot/pkg/model/endpointshards.go

    			ConfigsUpdated: sets.New(ConfigKey{Kind: kind.ServiceEntry, Name: serviceName, Namespace: namespace}),
    			Reason:         NewReasonStats(EndpointUpdate),
    		})
    	}
    }
    
    func (f *EndpointIndexUpdater) EDSCacheUpdate(shard ShardKey, serviceName string, namespace string, eps []*IstioEndpoint) {
    	f.Index.UpdateServiceEndpoints(shard, serviceName, namespace, eps)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/controller.go

    		c.Unlock()
    		if !f {
    			return
    		}
    		shard := model.ShardKeyFromRegistry(c)
    		endpoints := c.buildEndpointsForService(conv, true)
    		if len(endpoints) > 0 {
    			c.opts.XDSUpdater.EDSCacheUpdate(shard, string(hostname), svc.Namespace, endpoints)
    		}
    		cu.Insert(model.ConfigKey{
    			Kind:      kind.ServiceEntry,
    			Name:      string(hostname),
    			Namespace: svc.Namespace,
    		})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  6. pilot/pkg/model/push_context.go

    	// must be sent. The shard name is used as a key - current implementation is using the
    	// registry name.
    	EDSUpdate(shard ShardKey, hostname string, namespace string, entry []*IstioEndpoint)
    
    	// EDSCacheUpdate is called when the list of endpoints or labels in a Service is changed.
    	// For each cluster and hostname, the full list of active endpoints (including empty list)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 09:02:11 UTC 2024
    - 91.8K bytes
    - Viewed (0)
Back to top