- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 78 for adsupdate (0.22 sec)
-
pilot/pkg/xds/delta_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
ads := s.ConnectADS() s.MemRegistry.AddService(&model.Service{ Hostname: "adsupdate.default.svc.cluster.local", DefaultAddress: "10.11.0.1", Ports: []*model.Port{ { Name: "http-main", Port: 2080, Protocol: protocol.HTTP, }, }, Attributes: model.ServiceAttributes{ Name: "adsupdate", Namespace: "default", }, })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/xdsfake/updater.go
"istio.io/istio/pkg/test" ) // NewFakeXDS creates a XdsUpdater reporting events via a channel. func NewFakeXDS() *Updater { return &Updater{ SplitEvents: false, Events: make(chan Event, 100), } } // NewWithDelegate creates a XdsUpdater reporting events via a channel. func NewWithDelegate(delegate model.XDSUpdater) *Updater { return &Updater{ Events: make(chan Event, 100),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 29 18:40:34 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
shard := model.ShardKeyFromRegistry(s) // This is delete. if len(endpoints) == 0 { for k := range keys { s.XdsUpdater.EDSUpdate(shard, string(k.hostname), k.namespace, nil) } } else { for k, eps := range endpoints { s.XdsUpdater.EDSUpdate(shard, string(k.hostname), k.namespace, eps) } } } // buildEndpoints builds endpoints for the instance keys.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/ready/probe.go
} s, err := util.GetUpdateStatusStats(p.LocalHostAddr, p.AdminPort) if err != nil { return err } CDSUpdated := s.CDSUpdatesSuccess > 0 LDSUpdated := s.LDSUpdatesSuccess > 0 if CDSUpdated && LDSUpdated { p.receivedFirstUpdate = true return nil } if !CDSUpdated && !LDSUpdated { return fmt.Errorf("config not received from XDS server (is Istiod running?): %s", s.String())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 00:35:05 UTC 2024 - 4.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
for _, port := range svc.Ports { key := fmt.Sprintf("%s:%s", service, port.Name) for _, i := range sd.instancesByPortName[key] { eps = append(eps, i.Endpoint) } } if sd.XdsUpdater != nil { sd.XdsUpdater.EDSUpdate(sd.shardKey(), string(service), svc.Attributes.Namespace, eps) } } // AddEndpoint adds an endpoint to a 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) -
pilot/pkg/xds/eds.go
if event == model.EventDelete { inboundServiceDeletes.Increment() s.Env.EndpointIndex.DeleteServiceShard(shard, hostname, namespace, false) } else { inboundServiceUpdates.Increment() } } // EDSUpdate 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) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go
// Also update any internal caching. endpoints := ec.buildEndpointsForService(svc, true) shard := model.ShardKeyFromRegistry(ec) ec.opts.XDSUpdater.EDSUpdate(shard, svc.Hostname.String(), se.GetNamespace(), endpoints) } } func (ec *serviceExportCacheImpl) EndpointDiscoverabilityPolicy(svc *model.Service) model.EndpointDiscoverabilityPolicy { if svc == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
DomainSuffix string XDSUpdater model.XDSUpdater Stop chan struct{} SkipRun bool ConfigCluster bool SystemNamespace string } type FakeController struct { *Controller Endpoints *model.EndpointIndex } func NewFakeControllerWithOptions(t test.Failer, opts FakeControllerOptions) (*FakeController, *xdsfake.Updater) { xdsUpdater := opts.XDSUpdater
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
pilot/pkg/model/network_test.go
t.Logf("failed shutting down fake dns servers") } }) meshNetworks := mesh.NewFixedNetworksWatcher(nil) xdsUpdater := xdsfake.NewFakeXDS() env := &model.Environment{NetworksWatcher: meshNetworks, ServiceDiscovery: memory.NewServiceDiscovery()} if err := env.InitNetworksManager(xdsUpdater); err != nil { t.Fatal(err) } var gateways []model.NetworkGateway t.Run("initial resolution", func(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 6.9K bytes - Viewed (0)