- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 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/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/pkg/networking/core/fake.go
} env := model.NewEnvironment() env.Watcher = mesh.NewFixedWatcher(m) xdsUpdater := opts.XDSUpdater if xdsUpdater == nil { xdsUpdater = model.NewEndpointIndexUpdater(env.EndpointIndex) } serviceDiscovery := aggregate.NewController(aggregate.Options{}) se := serviceentry.NewController( configController, xdsUpdater, env.Watcher, serviceentry.WithClusterID(opts.ClusterID))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
pilot/test/xds/fake.go
s.ConfigUpdate(&model.PushRequest{ Full: true, Reason: model.NewReasonStats(model.NetworksTrigger), }) }) } var xdsUpdater model.XDSUpdater = s if opts.EnableFakeXDSUpdater { xdsUpdater = xdsfake.NewWithDelegate(s) } mc := multicluster.NewFakeController() creds := kubesecrets.NewMulticluster(opts.DefaultClusterName, mc)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
SystemNamespace string DomainSuffix string ClusterID cluster.ID XDSUpdater model.XDSUpdater Network LookupNetwork } type Options struct { Client kubeclient.Client Revision string SystemNamespace string DomainSuffix string ClusterID cluster.ID XDSUpdater model.XDSUpdater LookupNetwork LookupNetwork } func New(options Options) Index {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
k.MeshServiceController.DeleteRegistry(clusterID, provider.External) } if err := k.Controller.Cleanup(); err != nil { log.Warnf("failed cleaning up services in %s: %v", clusterID, err) } if k.opts.XDSUpdater != nil { k.opts.XDSUpdater.ConfigUpdate(&model.PushRequest{Full: true, Reason: model.NewReasonStats(model.ClusterUpdate)}) } } // Multicluster structure holds the remote kube Controllers and multicluster specific attributes.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
cmd/admin-handlers-idp-config.go
if cfgTarget != madmin.Default { // This cannot give an error at this point. subSysTargets, _ := s.GetAvailableTargets(subSys) subSysTargetsSet := set.CreateStringSet(subSysTargets...) if isUpdate && !subSysTargetsSet.Contains(cfgTarget) { return ErrAdminConfigIDPCfgNameDoesNotExist } if !isUpdate && subSysTargetsSet.Contains(cfgTarget) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
ClusterAliases map[string]string // Metrics for capturing node-based metrics. Metrics model.Metrics // XDSUpdater will push changes to the xDS server. XDSUpdater model.XDSUpdater // MeshNetworksWatcher observes changes to the mesh networks config. MeshNetworksWatcher mesh.NetworksWatcher // MeshWatcher observes changes to the mesh config
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
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) -
pilot/pkg/model/endpointshards.go
ConfigUpdateFunc func(req *PushRequest) } var _ XDSUpdater = &EndpointIndexUpdater{} 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) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 15.6K bytes - Viewed (0)