- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 41 for adsupdate (0.33 sec)
-
pkg/adsc/adsc.go
// If nil, the defaults will be used. Metadata *pstruct.Struct // Updates includes the type of the last update received from the server. Updates chan string errChan chan error XDSUpdates chan *discovery.DiscoveryResponse VersionInfo map[string]string // Last received message, by type Received map[string]*discovery.DiscoveryResponse mutex sync.RWMutex Mesh *v1alpha1.MeshConfig
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
src/cmd/go/internal/modload/build.go
Err: "module not in current build", }, } } return moduleInfo(ctx, rs, module.Version{Path: path, Version: v}, 0, nil) } // addUpdate fills in m.Update if an updated version is available. func addUpdate(ctx context.Context, m *modinfo.ModulePublic) { if m.Version == "" { return } info, err := Query(ctx, m.Path, "upgrade", m.Version, CheckAllowed)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 16 16:56:39 UTC 2024 - 13.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
endpointsPendingPodUpdate.Record(float64(len(pc.needResync))) } func (pc *PodCache) proxyUpdates(pod *v1.Pod, isPodUpdate bool) { if pc.c != nil { if pc.c.opts.XDSUpdater != nil { ip := pod.Status.PodIP pc.c.opts.XDSUpdater.ProxyUpdate(pc.c.Cluster(), ip) } if isPodUpdate { // Recompute service(s) due to pod label change.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
} func toFlowSchemaApplyConfiguration(fsUpdate fsStatusUpdate) *flowcontrolapplyconfiguration.FlowSchemaApplyConfiguration { condition := flowcontrolapplyconfiguration.FlowSchemaCondition(). WithType(fsUpdate.condition.Type). WithStatus(fsUpdate.condition.Status). WithReason(fsUpdate.condition.Reason). WithLastTransitionTime(fsUpdate.condition.LastTransitionTime). WithMessage(fsUpdate.condition.Message)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
maven-core/pom.xml
<id>create-buildnumber</id> <goals> <goal>create</goal> </goals> <configuration> <doCheck>false</doCheck> <doUpdate>false</doUpdate> <revisionOnScmFailure>NON_CANONICAL</revisionOnScmFailure> </configuration> </execution> </executions> </plugin> <plugin>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 09:06:12 UTC 2024 - 15.2K bytes - Viewed (0) -
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) -
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
Full: true, ConfigsUpdated: sets.New(model.ConfigKey{Kind: kind.ServiceEntry, Name: mcsHost.String(), Namespace: ns}), Reason: model.NewReasonStats(model.ServiceUpdate), } ic.opts.XDSUpdater.ConfigUpdate(pushReq) } // GetServiceImportIPs returns the list of ClusterSet IPs for the ServiceImport. // Exported for testing only. func GetServiceImportIPs(si *unstructured.Unstructured) []string {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/NGramSynonymTokenizer.java
prevToken = null; readBufferIndex = BUFFER_SIZE; readBufferLen = 0; ch = 0; blkStart = 0; nextBlkStart = 0; if (synonymLoader != null && synonymLoader.isUpdate(lastModified)) { lastModified = synonymLoader.getLastModified(); final SynonymMap map = synonymLoader.getSynonymMap(); if (map != null) { synonymMap = map;
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 17K bytes - Viewed (0) -
pilot/pkg/xds/sds.go
configs = append(configs, config.HashCode()) } return configs } func (sr SecretResource) Cacheable() bool { return true } func sdsNeedsPush(updates model.XdsUpdates) bool { if len(updates) == 0 { return true } for update := range updates { switch update.Kind { case kind.Secret: return true case kind.ReferenceGrant: return true } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 23:04:36 UTC 2024 - 15.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
if c.extractGatewaysInner(svc) { gwsChanged = true break } } c.Unlock() if gwsChanged { c.NotifyGatewayHandlers() // TODO ConfigUpdate via gateway handler c.opts.XDSUpdater.ConfigUpdate(&model.PushRequest{Full: true, Reason: model.NewReasonStats(model.NetworksTrigger)}) } } // extractGatewaysInner performs the logic for extractGatewaysFromService without locking the controller.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0)