- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 823 for syncAt (0.18 sec)
-
pkg/registry/core/service/ipallocator/cidrallocator_test.go
return false, ip, err })) c, err := NewMetaAllocator(client.NetworkingV1alpha1(), serviceCIDRInformer, ipInformer, false) if err != nil { return nil, err } // we can not force the state of the informers to be synced without racing // so we run our worker here go wait.Until(c.runWorker, time.Second, c.internalStopCh) return c, nil } func TestCIDRAllocateMultiple(t *testing.T) { r, err := newTestMetaAllocator()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 13.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go
See the License for the specific language governing permissions and limitations under the License. */ package healthz import ( "bytes" "context" "fmt" "net/http" "reflect" "strings" "sync" "sync/atomic" "time" "k8s.io/apimachinery/pkg/util/sets" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/endpoints/metrics" "k8s.io/apiserver/pkg/server/httplog"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 19:11:24 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
// rsListerSynced returns true if the pod store has been synced at least once. // Added as a member to the struct to allow injection for testing. rsListerSynced cache.InformerSynced rsIndexer cache.Indexer // A store of pods, populated by the shared informer passed to NewReplicaSetController podLister corelisters.PodLister // podListerSynced returns true if the pod store has been synced at least once.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
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/garbagecollector/graph_builder.go
defer gb.monitorLock.Unlock() if len(gb.monitors) == 0 { logger.V(4).Info("garbage controller monitor not synced: no monitors") return false } for resource, monitor := range gb.monitors { if !monitor.controller.HasSynced() { logger.V(4).Info("garbage controller monitor not yet synced", "resource", resource) return false } } return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
cidrSets []*cidrset.CidrSet // nodeLister is able to list/get nodes and is populated by the shared informer passed to controller nodeLister corelisters.NodeLister // nodesSynced returns true if the node shared informer has been synced at least once. nodesSynced cache.InformerSynced broadcaster record.EventBroadcaster recorder record.EventRecorder // queues are where incoming work is placed to de-dup and to allow "easy"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
// services that happened since nftables was synced. For a single object, // changes are accumulated, i.e. previous is state from before all of them, // current is state after applying all of those. endpointsChanges *proxy.EndpointsChangeTracker serviceChanges *proxy.ServiceChangeTracker mu sync.Mutex // protects the following fields svcPortMap proxy.ServicePortMap
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K 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 (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) -
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)