Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for SvcUpdate (0.29 sec)

  1. pilot/pkg/xds/eds.go

    	"istio.io/istio/pilot/pkg/util/protoconv"
    	"istio.io/istio/pilot/pkg/xds/endpoints"
    	"istio.io/istio/pkg/config/schema/kind"
    	"istio.io/istio/pkg/util/sets"
    )
    
    // SvcUpdate is a callback from service discovery when service info changes.
    func (s *DiscoveryServer) SvcUpdate(shard model.ShardKey, hostname string, namespace string, event model.Event) {
    	// When a service deleted, we should cleanup the endpoint shards and also remove keys from EndpointIndex to
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 15:58:06 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/memory/discovery.go

    	event := model.EventAdd
    	if o, f := sd.services[svc.Hostname]; f {
    		old = o
    		event = model.EventUpdate
    	}
    	sd.services[svc.Hostname] = svc
    
    	if sd.XdsUpdater != nil {
    		sd.XdsUpdater.SvcUpdate(sd.shardKey(), string(svc.Hostname), svc.Attributes.Namespace, model.EventAdd)
    	}
    	sd.handlers.NotifyServiceHandlers(old, svc, event)
    	sd.mutex.Unlock()
    }
    
    // RemoveService removes an in-memory service.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Mar 28 23:10:01 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/serviceentry/controller.go

    		s.XdsUpdater.SvcUpdate(shard, string(svc.Hostname), svc.Attributes.Namespace, model.EventAdd)
    		configsUpdated.Insert(makeConfigKey(svc))
    	}
    
    	for _, svc := range updatedSvcs {
    		s.XdsUpdater.SvcUpdate(shard, string(svc.Hostname), svc.Attributes.Namespace, model.EventUpdate)
    		configsUpdated.Insert(makeConfigKey(svc))
    	}
    	// If service entry is deleted, call SvcUpdate to cleanup endpoint shards for services.
    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

    func (f *EndpointIndexUpdater) EDSCacheUpdate(shard ShardKey, serviceName string, namespace string, eps []*IstioEndpoint) {
    	f.Index.UpdateServiceEndpoints(shard, serviceName, namespace, eps)
    }
    
    func (f *EndpointIndexUpdater) SvcUpdate(shard ShardKey, hostname string, namespace string, event Event) {
    	if event == EventDelete {
    		f.Index.DeleteServiceShard(shard, hostname, namespace, false)
    	}
    }
    
    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.opts.XDSUpdater.ConfigUpdate(&model.PushRequest{Full: true, Reason: model.NewReasonStats(model.NetworksTrigger)})
    	}
    
    	shard := model.ShardKeyFromRegistry(c)
    	event := model.EventDelete
    	c.opts.XDSUpdater.SvcUpdate(shard, string(svc.Hostname), svc.Attributes.Namespace, event)
    
    	c.handlers.NotifyServiceHandlers(nil, svc, event)
    }
    
    // recomputeServiceForPod is called when a pod changes and service endpoints need to be recomputed.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top