- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 823 for syncAt (0.12 sec)
-
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) -
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) -
pkg/kubelet/cm/dra/claiminfo.go
for _, claimInfo := range cache.claimInfo { if claimInfo.hasPodReference(UID) { return true } } return false } // syncToCheckpoint syncs the full claim info cache state to a checkpoint. func (cache *claimInfoCache) syncToCheckpoint() error { claimInfoStateList := make(state.ClaimInfoStateList, 0, len(cache.claimInfo)) for _, infoClaim := range cache.claimInfo {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 7.9K bytes - Viewed (0) -
pkg/adsc/adsc_test.go
desc: "stream-3-completed-mcp-resources", initialRequests: ConfigInitialRequests(), validator: func(testCase testCase) error { if !testCase.inAdsc.HasSynced() { return errors.New("ADSC should be synced") } return nil }, }, { desc: "stream-4-uncompleted-mcp-resources", initialRequests: ConfigInitialRequests(), // XDS Server don't push this kind resource.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 15.4K bytes - Viewed (0) -
pkg/kube/krt/join_test.go
Labeled: Labeled{map[string]string{"app": "foo"}}, IP: "9.9.9.9", }) AllPods := krt.JoinCollection([]krt.Collection[SimplePod]{SimplePods, ExtraSimplePods.AsCollection()}) assert.Equal(t, AllPods.Synced().WaitUntilSynced(stop), true) // Assert Equal -- not EventuallyEqual -- to ensure our WaitForCacheSync is proper assert.Equal(t, fetcherSorted(AllPods)(), []SimplePod{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0) -
api/openapi-spec/v3/apis__networking.k8s.io__v1_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: Fri Mar 08 04:18:56 UTC 2024 - 324.8K bytes - Viewed (0) -
pkg/controller/bootstrap/tokencleaner.go
// secretLister is able to list/get secrets and is populated by the shared informer passed to NewTokenCleaner. secretLister corelisters.SecretLister // secretSynced returns true if the secret shared informer has been synced at least once. secretSynced cache.InformerSynced queue workqueue.TypedRateLimitingInterface[string] } // NewTokenCleaner returns a new *NewTokenCleaner.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.3K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_populator.go
UpdateFunc: nil, // Not needed, NodeName is immutable. DeleteFunc: g.deleteResourceSlice, }) synced = append(synced, sliceHandler.HasSynced) } go cache.WaitForNamedCacheSync("node_authorizer", wait.NeverStop, synced...) } func (g *graphPopulator) addPod(obj interface{}) { g.updatePod(nil, obj) } func (g *graphPopulator) updatePod(oldObj, obj interface{}) { pod := obj.(*corev1.Pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/kubeadm/app/util/etcd/etcd.go
continue } etcdEndpoints = append(etcdEndpoints, etcdEndpoint) } return etcdEndpoints, len(podList.Items), nil } // Sync synchronizes client's endpoints with the known endpoints from the etcd membership. func (c *Client) Sync() error { // Syncs the list of endpoints var cli etcdClient var lastError error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 11:04:08 UTC 2024 - 21.2K bytes - Viewed (0)