- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 78 for adsupdate (0.15 sec)
-
src/main/java/org/codelibs/fess/es/config/bsbhv/BsFileConfigBhv.java
doInsert(entity, null); } public void update(FileConfig entity) { doUpdate(entity, null); } public void update(FileConfig entity, RequestOptionCall<IndexRequestBuilder> opLambda) { entity.asDocMeta().indexOption(opLambda); doUpdate(entity, null); } public void insertOrUpdate(FileConfig entity) { doInsertOrUpdate(entity, null, null);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.8K 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) -
src/main/java/org/codelibs/fess/es/user/bsbhv/BsUserBhv.java
doInsert(entity, null); } public void update(User entity) { doUpdate(entity, null); } public void update(User entity, RequestOptionCall<IndexRequestBuilder> opLambda) { entity.asDocMeta().indexOption(opLambda); doUpdate(entity, null); } public void insertOrUpdate(User entity) { doInsertOrUpdate(entity, null, null); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12K bytes - Viewed (0) -
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) -
src/test/java/org/codelibs/opensearch/extension/analysis/SynonymLoader.java
this.env = env; this.settings = settings; this.expand = expand; this.analyzer = analyzer; createSynonymMap(false); } public boolean isUpdate(final long time) { if (System.currentTimeMillis() - lastChecked > reloadInterval) { lastChecked = System.currentTimeMillis(); final long timestamp = reloadableFile.lastModified();
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 6.7K 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)