- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,199 for syncIt (0.1 sec)
-
istioctl/pkg/writer/pilot/testdata/multiXdsStatusSinglePilot.txt
NAME CLUSTER CDS LDS EDS RDS ECDS ISTIOD VERSION proxy1 cluster1 STALE SYNCED SYNCED NOT SENT NOT SENT istiod1 1.20
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 03:42:52 UTC 2024 - 300 bytes - Viewed (0) -
pkg/kubelet/status/status_manager_test.go
} } func TestChangedStatus(t *testing.T) { syncer := newTestManager(&fake.Clientset{}) testPod := getTestPod() syncer.SetPodStatus(testPod, getRandomPodStatus()) verifyUpdates(t, syncer, 1) syncer.SetPodStatus(testPod, getRandomPodStatus()) verifyUpdates(t, syncer, 1) } func TestChangedStatusKeepsStartTime(t *testing.T) { syncer := newTestManager(&fake.Clientset{}) testPod := getTestPod()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 68.1K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
{ID: "config", SyncStatus: "synced"}, {ID: "c0", SecretName: "istio-system/s0", SyncStatus: "synced"}, {ID: "c1", SecretName: "istio-system/s1", SyncStatus: "synced"}, }) // Remove one c.DeleteSecret("s1") assert.EventuallyEqual(t, c.controller.ListRemoteClusters, []cluster.DebugInfo{ {ID: "config", SyncStatus: "synced"}, {ID: "c0", SecretName: "istio-system/s0", SyncStatus: "synced"}, }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
pkg/controller/resourcequota/resource_quota_controller.go
if err := rq.resyncMonitors(ctx, newResources); err != nil { utilruntime.HandleError(fmt.Errorf("failed to sync resource monitors: %v", err)) return } // at this point, we've synced the new resources to our monitors, so record that fact. oldResources = newResources // wait for caches to fill for a while (our sync period).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 21.3K bytes - Viewed (0) -
docs/bucket/replication/DESIGN.md
...
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.7K bytes - Viewed (0) -
pilot/pkg/config/kube/ingress/status_test.go
func testRunningAddressesWithService(t *testing.T) { syncer := makeStatusSyncer(t, "istio-ingress") address := syncer.runningAddresses() if len(address) != 1 || address[0] != serviceIP { t.Errorf("Address is not correctly set to service ip") } } func testRunningAddressesWithHostname(t *testing.T) { syncer := makeStatusSyncer(t, "istio-ingress-hostname") address := syncer.runningAddresses()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 5.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/README.md
## Where does it come from? `apiextensions-apiserver` is synced from https://github.com/kubernetes/kubernetes/blob/master/staging/src/k8s.io/apiextensions-apiserver.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 08 06:41:15 UTC 2023 - 742 bytes - Viewed (0) -
staging/src/k8s.io/api/README.md
## Where does it come from? `api` is synced from https://github.com/kubernetes/kubernetes/blob/master/staging/src/k8s.io/api. Code changes are made in that location, merged into `k8s.io/kubernetes` and later synced here. ## Things you should *NOT* do
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 03 01:38:34 UTC 2021 - 1.9K bytes - Viewed (0) -
pkg/proxy/healthcheck/proxier_health.go
// or the proxier is fully synced. continue } if currentTime.Sub(hs.oldestPendingQueuedMap[ipFamily]) < hs.healthTimeout { // there's an unprocessed update queued for this proxier, but it's not late yet. continue } return false, proxierLastUpdated } return true, lastUpdated } // SyncNode syncs the node and determines if it is eligible or not. Eligible is
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 16 10:41:18 UTC 2023 - 8K bytes - Viewed (0) -
pilot/pkg/config/memory/controller_test.go
ctl := memory.NewController(store) ctl.RegisterHasSyncedHandler(func() bool { return atomic.LoadInt32(&v) > 0 }) if ctl.HasSynced() { t.Error("has synced but should not") } atomic.StoreInt32(&v, 1) if !ctl.HasSynced() { t.Error("has not synced but should") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 18 15:37:45 UTC 2021 - 1.8K bytes - Viewed (0)