Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for edsUpdates (0.2 sec)

  1. pilot/pkg/xds/pushqueue_test.go

    				Kind:      kind.ServiceEntry,
    				Name:      "bar",
    				Namespace: "ns1",
    			},
    		)
    		if !reflect.DeepEqual(model.ConfigsOfKind(info.ConfigsUpdated, kind.ServiceEntry), expectedEds) {
    			t.Errorf("Expected EdsUpdates to be %v, got %v", expectedEds, model.ConfigsOfKind(info.ConfigsUpdated, kind.ServiceEntry))
    		}
    		if info.Full {
    			t.Errorf("Expected full to be false, got true")
    		}
    	})
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/serviceentry/controller.go

    	s.mutex.RUnlock()
    	s.edsUpdate(allInstances)
    	// HACK to workaround Service syncing after WorkloadEntry: https://github.com/istio/istio/issues/45114
    	s.workloadInstances.ForEach(func(wi *model.WorkloadInstance) {
    		if wi.Kind == model.WorkloadEntryKind {
    			s.NotifyWorkloadInstanceHandlers(wi, model.EventAdd)
    		}
    	})
    }
    
    // edsUpdate triggers an EDS push serially such that we can prevent all instances
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. pilot/pkg/model/context.go

    	a := make(Resources, 0, len(r))
    	for _, rr := range r {
    		a = append(a, &discovery.Resource{Resource: rr})
    	}
    	return a
    }
    
    // XdsUpdates include information about the subset of updated resources.
    // See for example EDS incremental updates.
    type XdsUpdates = sets.Set[ConfigKey]
    
    // XdsLogDetails contains additional metadata that is captured by Generators and used by xds processors
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (0)
  4. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    			} else {
    				log.Debugf("Handle EDS endpoint: skip collecting workload entry endpoints, service %s/ has not been populated",
    					hostname)
    			}
    		}
    
    		esc.c.opts.XDSUpdater.EDSUpdate(shard, string(hostname), namespace, endpoints)
    	}
    }
    
    // getPod fetches a pod by name or IP address.
    // A pod may be missing (nil) for two reasons:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  5. pilot/pkg/model/endpointshards.go

    func NewEndpointIndexUpdater(ei *EndpointIndex) *EndpointIndexUpdater {
    	return &EndpointIndexUpdater{Index: ei}
    }
    
    func (f *EndpointIndexUpdater) ConfigUpdate(*PushRequest) {}
    
    func (f *EndpointIndexUpdater) EDSUpdate(shard ShardKey, serviceName string, namespace string, eps []*IstioEndpoint) {
    	pushType := 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)
  6. pilot/pkg/model/push_context.go

    type XDSUpdater interface {
    	// EDSUpdate 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)
    	// 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)
    
    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