- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 1,199 for syncAt (0.2 sec)
-
platforms/native/language-native/src/integTest/groovy/org/gradle/language/cpp/AbstractCppPublishingIntegrationTest.groovy
} } @Override ExecutableFixture executable(Object path) { ExecutableFixture executable = super.executable(path) // Executables synced from a binary repo lose their executable bit executable.file.setExecutable(true) executable } Map<String, String> machine(String os, String architecture) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller.go
podLister corelisters.PodLister // dListerSynced returns true if the Deployment store has been synced at least once. // Added as a member to the struct to allow injection for testing. dListerSynced cache.InformerSynced // rsListerSynced returns true if the ReplicaSet store has been synced at least once. // Added as a member to the struct to allow injection for testing. rsListerSynced cache.InformerSynced
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 24.2K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
discovery.RegisterAggregatedDiscoveryServiceServer(rpcs, s) } var processStartTime = time.Now() // CachesSynced is called when caches have been synced so that server can accept connections. func (s *DiscoveryServer) CachesSynced() { log.Infof("All caches have been synced up in %v, marking server ready", time.Since(s.DiscoveryStartTime)) s.serverReady.Store(true) } func (s *DiscoveryServer) IsServerReady() bool {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (1) -
staging/src/k8s.io/apiserver/pkg/util/peerproxy/peerproxy_handler.go
return } // StorageVersion Informers and/or StorageVersionManager is not synced yet, pass request to next handler // This will happen for self requests from the kube-apiserver because we have a poststarthook // to ensure that external requests are not served until the StorageVersion Informer and // StorageVersionManager has synced if !h.HasFinishedSync() { handler.ServeHTTP(w, r) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 19 00:36:22 UTC 2023 - 11.5K bytes - Viewed (0) -
api/openapi-spec/v3/apis__resource.k8s.io__v1alpha2_openapi.json
NotOlderThan\n is interpreted as \"data at least as new as the provided `resourceVersion`\"\n and the bookmark event is send when the state is synced\n to a `resourceVersion` at least as fresh as the one provided by the ListOptions.\n If `resourceVersion` is unset, this is interpreted as \"consistent read\" and the\n bookmark event is send when the state is synced at least to the moment\n when request started being processed.\n- `resourceVersionMatch` set to any other value or unset\n Invalid error...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 12:18:45 UTC 2024 - 656.6K bytes - Viewed (0) -
docs/bucket/replication/README.md
### Sync/Async Replication By default, replication is completed asynchronously. If synchronous replication is desired, set the --sync flag while adding a remote replication target using the `mc admin bucket remote add` command. For mc releases on or after `RELEASE.2022-12-24T15-21-38Z`, the
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 24 23:46:33 UTC 2023 - 18.2K bytes - Viewed (0) -
pkg/kube/namespace/filter.go
d.discoveryNamespaces.Delete(ns.Name) } // AddHandler registers a handler on namespace, which will be triggered when namespace selected or deselected. // If the namespaces have been synced, trigger the new added handler. func (d *discoveryNamespacesFilter) AddHandler(f func(added, removed sets.String)) { d.lock.Lock() defer d.lock.Unlock() d.handlers = append(d.handlers, f) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 17:12:52 UTC 2024 - 9.3K bytes - Viewed (0) -
pkg/proxy/endpointschangetracker.go
} } // EndpointSliceUpdate updates the EndpointsChangeTracker by adding/updating or removing // endpointSlice (depending on removeSlice). It returns true if this update contained a // change that needs to be synced; note that this is different from the return value of // ServiceChangeTracker.Update(). func (ect *EndpointsChangeTracker) EndpointSliceUpdate(endpointSlice *discovery.EndpointSlice, removeSlice bool) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 13.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_status_updater_test.go
update := action.(core.UpdateAction) sts := update.GetObject().(*apps.StatefulSet) if sts.Status.ObservedGeneration != 3 { t.Errorf("expected observedGeneration to be synced with generation for statefulset %q", sts.Name) } return true, sts, nil }) if err := updater.UpdateStatefulSetStatus(context.TODO(), set, &status); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 13 15:37:10 UTC 2022 - 5.9K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
listenerStatus string routeStatus string endpointStatus string extensionconfigStatus string } const ignoredStatus = "IGNORED" // PrintAll takes a slice of Istiod syncz responses and outputs them using a tabwriter func (s *XdsStatusWriter) PrintAll(statuses map[string]*discovery.DiscoveryResponse) error { w, fullStatus, err := s.setupStatusPrint(statuses) if err != nil { return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:55 UTC 2024 - 6.1K bytes - Viewed (0)